版本升级策略

本文介绍RabbitMQ版本升级策略，涵盖滚动升级、兼容性校验与降级回滚流程。

定义

版本升级策略是在保证服务高可用的前提下，将RabbitMQ集群从旧版本平滑迁移至新版本的标准流程，包括滚动升级、灰度验证与降级回滚。

原理

滚动升级机制

升级流程:
1. 停止旧节点N的消息收发(Quiesce)
2. 关闭旧节点N
3. 启动新节点N'（同配置）
4. 新节点N'加入集群并同步数据
5. 验证N'健康后，继续升级下一节点
6. 重复直至所有节点升级完成

版本兼容性矩阵

功能标志（Feature Flags）

升级后需检查Feature Flags:
├─ enabled: 已启用新功能
├─ disabled: 保留旧行为
└─ stale: 旧版本遗留标志，可清理

示例

Maven依赖（客户端版本保持兼容）

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

升级前检查脚本

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.util.Map;

public class UpgradePreCheck {
    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()) {
            // 获取服务器版本
            Map<String, Object> serverProps = conn.getServerProperties();
            String version = (String) serverProps.get("version");
            System.out.println("Broker version: " + version);

            // 检查队列状态
            String[] queues = {"queue1", "queue2"};
            for (String q : queues) {
                try {
                    ch.queueDeclarePassive(q);
                    System.out.println("Queue " + q + " OK");
                } catch (Exception e) {
                    System.err.println("Queue " + q + " ERROR: " + e.getMessage());
                }
            }
        }
    }
}

滚动升级命令

# 步骤1: 停止节点消息收发
rabbitmqctl stop_app

# 步骤2: 关闭节点
rabbitmqctl shutdown

# 步骤3: 安装新版本（RPM/DEB）
sudo rpm -Uvh rabbitmq-server-3.13.0-1.el8.noarch.rpm

# 步骤4: 启动新节点
rabbitmq-server -detached

# 步骤5: 加入集群（如需要）
rabbitmqctl join_cluster rabbit@node1

# 步骤6: 启用功能标志
rabbitmqctl enable_feature_flag all

# 步骤7: 验证节点状态
rabbitmqctl cluster_status

降级回滚流程

# 紧急降级（数据不丢失前提）
# 步骤1: 停止所有新节点
rabbitmqctl stop_app

# 步骤2: 恢复旧版本二进制
sudo rpm -Uvh --oldpackage rabbitmq-server-3.12.0-1.el8.noarch.rpm

# 步骤3: 启动旧节点
rabbitmq-server -detached

# 步骤4: 验证数据完整性
rabbitmqctl list_queues name messages

注意事项

升级前必须备份mnesia数据目录，降级时旧版本无法读取新版本格式的数据。

滚动升级期间部分操作不可用（如策略修改），建议在业务低峰期执行。

大版本升级（3.x→4.x）不支持滚动升级，需停机并导出数据。

Erlang版本必须先于RabbitMQ升级，否则会启动失败。

升级后必须执行enable_feature_flag all，否则新特性不会生效。

要点总结

• 滚动升级逐节点替换，保证服务高可用
• 版本兼容性矩阵决定升级路径与Erlang要求
• 升级流程：检查 -> 停节点 -> 安装 -> 启动 -> 验证
• 降级需恢复旧版本二进制与mnesia数据
• 大版本升级不支持在线操作，需停机规划