生产环境若使用 Redis 作为消息队列且面临大数据量或高并发场景，建议采用 Redis Cluster 集群模式。但需明确 Redis 并非专用消息中间件，务必开启持久化并配合可靠客户端机制，以防数据丢失。

安全与网络配置

生产环境首要任务是安全加固，避免 Redis 暴露于公网或密码泄露。

1. 绑定内网 IP
修改 redis.conf，禁止绑定 0.0.0.0，仅监听内网网卡或本地：

bind 127.0.0.1 192.168.1.10
protected-mode yes

2. 防火墙策略
仅开放业务所需端口（如 7000-7005）及总线端口（端口 +10000），禁止公网访问：

# CentOS 7+ firewalld 示例
firewall-cmd `--zone`=public `--add-port`=7000-7005/tcp `--permanent`
firewall-cmd `--zone`=public `--add-port`=17000-17005/tcp `--permanent`
firewall-cmd `--reload`

3. 密码安全
配置文件设置 requirepass，严禁在命令行通过 -a 参数传递密码，避免进程列表泄露：

requirepass YourStrongPassword
# 启动后手动认证
redis-cli -p 7000
AUTH YourStrongPassword

集群部署命令

确保所有节点网络互通且配置文件已修改，使用以下命令创建集群。注意命令中不要包含多余符号：

redis-cli `--cluster` create 192.168.1.10:7000 192.168.1.10:7001 192.168.1.10:7002 192.168.1.11:7003 192.168.1.11:7004 192.168.1.11:7005 `--cluster-replicas` 1

执行后输入 yes 确认槽位分配。关键配置项检查：

cluster-enabled yes
appendonly yes
cluster-node-timeout 5000
cluster-require-full-coverage no

消息队列模式配置

在集群模式下，推荐使用 Redis Stream 而非 List，因为 Stream 支持消费者组（Consumer Group）和 ACK 机制，更适合可靠消息传递。

1. 创建消费者组

XGROUP CREATE mystream mygroup $ MKSTREAM

2. 消费消息（带 ACK）

XREADGROUP GROUP mygroup consumer1 COUNT 1 BLOCK 5000 STREAMS mystream >
# 业务处理成功后确认
XACK mystream mygroup 1234567890-0

3. 处理积压
使用 XPENDING 查看未确认消息，防止消息丢失。

客户端代码实战

应用端必须使用支持 Cluster 模式的客户端，普通单机连接会报错 MOVED。以下是 Python 客户端连接集群并消费 Stream 的示例：

from redis.cluster import RedisCluster

# 初始化集群客户端
startup_nodes = [{"host": "192.168.1.10", "port": "7000"}]
rc = RedisCluster(startup_nodes=startup_nodes, password="YourStrongPassword")

# 消费消息
messages = rc.xreadgroup("mygroup", "consumer1", {"mystream": ">"}, count=1, block=5000)
if messages:
    stream, entries = messages[0]
    for entry_id, fields in entries:
        # 处理业务逻辑
        print(f"Processing {entry_id}")
        # 必须手动 ACK
        rc.xack("mystream", "mygroup", entry_id)

验证与故障排查

1. 集群状态验证
使用命令 redis-cli -c -p 7000 cluster info 查看，cluster_state:ok 表示正常。通过 cluster nodes 确认主从关系及槽位分配。

2. 高可用测试
模拟拔掉主节点网线，观察从节点是否自动升主，客户端是否重连成功。

3. 消息可靠性验证
消费后不发送 XACK，重启消费者，检查消息是否重新出现在 Pending 列表：

XPENDING mystream mygroup - + 10

常见风险与坑

1. 消息丢失风险：Redis 作为队列默认异步复制，主节点挂掉瞬间未同步到从节点的数据会丢失。务必开启 AOF 持久化（appendonly yes）并在业务层实现 ACK 机制。

2. 客户端连接：不要直连单个 IP，客户端需内置集群拓扑发现能力，否则槽位迁移后无法访问。

3. 大 Key 问题：消息队列若单个 Key 过大（如列表过长），会导致槽位数据倾斜，影响集群平衡。建议控制单条消息大小。

4. 密码泄露：避免在脚本或命令行中明文传递密码，建议使用环境变量或配置中心管理敏感信息。