Mnesia 数据库

Mnesia 是 Erlang/OTP 内置的分布式数据库，RabbitMQ 使用它存储队列、交换器、绑定关系等元数据。

Mnesia 简介

Mnesia 是软硬实时数据库，支持事务、容错、分布式数据复制，数据以 Erlang 表（record）形式存储。

RabbitMQ 中 Mnesia 存储的核心数据：

• 虚拟主机（vhost）配置
• 交换器（exchange）定义
• 队列（queue）元数据
• 绑定关系（binding）
• 用户权限与策略

分布式存储机制

数据复制模式

Mnesia 支持三种表类型：

RabbitMQ 元数据默认使用 disc_copies，确保节点重启后元数据不丢失。

集群同步原理

% 添加节点到 Mnesia 集群
mnesia:change_config(extra_db_nodes, ['rabbit@node2']).
% 复制表结构到本地
mnesia:change_table_copy_type(schema, node(), disc_copies).

RabbitMQ 节点加入集群时：

1. 向种子节点请求 schema 表结构
2. 将自身注册为 Mnesia 集群节点
3. 复制所需表到本地 disc_copies

Mnesia 集群要求所有节点网络互通，元数据变更通过 Erlang 消息实时同步，无需额外同步组件。

读写逻辑

事务读

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

public class MnesiaReadExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        
        try (Connection conn = factory.newConnection();
             Channel ch = conn.createChannel()) {
            // 声明交换器（写入 Mnesia）
            ch.exchangeDeclare("test.exchange", "direct", true);
            // 声明队列（写入 Mnesia）
            ch.queueDeclare("test.queue", true, false, false, null);
            // 建立绑定关系（写入 Mnesia）
            ch.queueBind("test.queue", "test.exchange", "routing.key");
            
            System.out.println("元数据已写入 Mnesia");
        }
    }
}

事务写流程

1. 客户端发起元数据操作（如 exchangeDeclare）
2. 请求路由到集群中某个节点
3. 节点发起 Mnesia 事务：mnesia:transaction(Fun)
4. 事务在本地 disc_copies 表写入
5. 异步复制到其他集群节点的 disc_copies 表
6. 事务提交，返回成功

Mnesia 事务保证 ACID 特性，元数据写入要么全部成功，要么全部回滚，不会出现部分写入状态。

节点加入与离开

节点加入

// RabbitMQ 集群节点加入示例（管理命令）
// rabbitmqctl join_cluster rabbit@master-node
// 上述命令触发 Mnesia 数据同步

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;

public class ClusterJoinExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("master-node");
        factory.setPort(5672);
        
        try (Connection conn = factory.newConnection()) {
            System.out.println("已连接到主节点，新节点需通过 rabbitmqctl 加入集群");
            System.out.println("Mnesia 将自动同步元数据到新节点");
        }
    }
}

节点离开

• 正常离开：节点将本地未同步数据刷盘，从 Mnesia 集群移除
• 异常宕机：其他节点检测到心跳超时，标记该节点为 down，不触发数据删除

节点异常离线期间产生的元数据变更不会同步到离线节点，重新上线后需手动同步或重建。

性能调优

关键配置项

优化建议

1. 集群节点数建议 ≤ 3，Mnesia 多节点同步开销随节点数指数增长
2. 避免频繁元数据变更，批量操作合并为单次事务
3. 大集群使用 Quorum Queues 替代经典队列，减少 Mnesia 压力

注意事项

Mnesia 不是 RabbitMQ 的消息存储引擎，仅用于元数据存储。消息内容写入磁盘由消息存储机制负责。

Mnesia 集群要求所有节点版本一致，跨版本运行可能导致 schema 不兼容。

避免在 Mnesia 表中存储大对象，元数据应保持轻量，大文件应使用外部存储。

要点总结

• Mnesia 是 RabbitMQ 元数据存储核心组件，基于 Erlang/OTP 实现
• 支持 ram_copies、disc_copies、disc_only_copies 三种表类型
• 元数据写入通过 Mnesia 事务保证 ACID 特性
• 节点加入集群时自动同步 Mnesia 表结构
• 集群节点数建议 ≤ 3，避免同步开销过大
• 消息内容不存储在 Mnesia 中，仅元数据

文章存放路径：D:\git2\jwdev\articles\RABBITMQ\专家\底层原理与架构\Mnesia 数据库.md