节点类型与角色

RabbitMQ集群由磁盘节点（Disc Node）和内存节点（RAM Node）组成，两者在元数据存储和恢复能力上有本质区别，合理搭配是集群稳定运行的基础。

定义

磁盘节点：将集群元数据（队列、交换机、绑定、用户权限等）持久化到磁盘，重启后可从磁盘恢复数据。

内存节点：仅将元数据存储在内存中，重启后丢失。读写性能优于磁盘节点，但依赖磁盘节点完成数据恢复。

Maven依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.20.0</version>
</dependency>

节点类型配置

加入集群时指定节点类型

# 停止应用（保留配置）
rabbitmqctl stop_app

# 重置节点状态
rabbitmqctl reset

# 加入集群（默认为磁盘节点）
rabbitmqctl join_cluster rabbit@node-a

# 以内存节点身份加入集群
rabbitmqctl join_cluster rabbit@node-a --ram

# 重新启动应用
rabbitmqctl start_app

运行时转换节点类型

# 磁盘节点转为内存节点
rabbitmqctl stop_app
rabbitmqctl change_cluster_node_type ram
rabbitmqctl start_app

# 内存节点转为磁盘节点
rabbitmqctl stop_app
rabbitmqctl change_cluster_node_type disc
rabbitmqctl start_app

Java客户端连接（无差异）

import com.rabbitmq.client.*;

public class ClusterConnection {
    private static final String QUEUE_NAME = "mixed_cluster_queue";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        // 客户端连接无需关心节点类型，统一通过AMQP协议
        factory.setHost("rabbitmq-cluster.local");
        factory.setPort(5672);
        factory.setUsername("app_user");
        factory.setPassword("app_password");

        // 自动连接负载均衡后的可用节点
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // 声明持久化队列（元数据存储在集群中）
        channel.queueDeclare(QUEUE_NAME, true, false, false, null);

        // 发送持久化消息
        String message = "mixed-cluster-message";
        channel.basicPublish("", QUEUE_NAME,
            MessageProperties.PERSISTENT_TEXT_PLAIN,
            message.getBytes("UTF-8"));

        // 消费消息
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String msg = new String(delivery.getBody(), "UTF-8");
            System.out.println("收到: " + msg);
            channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
        };

        channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {});
    }
}

节点角色分工

集群中必须至少有一个磁盘节点。若最后一个磁盘节点离线，内存节点无法独立运行，整个集群将停止服务。

注意事项

1. 最小磁盘节点数：集群必须保留至少一个磁盘节点，否则内存节点无法重启和恢复元数据。

2. 内存节点依赖：内存节点重启时从同集群的磁盘节点同步最新元数据，若所有磁盘节点均离线则无法启动。

3. 性能规划：读写密集场景可增加内存节点分担路由负载；元数据安全优先场景应全部使用磁盘节点。

4. 单节点场景：单节点部署只能是磁盘节点，不支持内存节点模式。

5. 转换风险：运行时转换节点类型需停止应用，转换期间该节点不可用，建议在维护窗口操作。

要点总结

• 磁盘节点将元数据持久化到磁盘，重启后可独立恢复
• 内存节点仅存元数据于内存，依赖磁盘节点完成恢复
• 集群必须至少包含一个磁盘节点，否则无法运行
• 内存节点提供更高路由性能，适合分担读写压力
• 节点类型可通过change_cluster_node_type命令转换