微服务架构中，若追求高可靠、复杂路由和企业级功能，首选 RabbitMQ；若项目已深度使用 Redis 且场景简单、追求极低延迟和运维轻量，可选 Redis Stream。

快速决策逻辑

选型不是写代码，而是做决策。面对 RabbitMQ 和 Redis 队列，建议按以下逻辑快速收敛范围：

1. 确认消息重要性：如果消息丢失会导致资金损失或核心业务错误，优先 RabbitMQ，其确认机制和持久化更成熟。

2. 确认消息体量：如果消息体较大（如超过 10KB）或吞吐量极大，Redis 性能可能下降，RabbitMQ 或 Kafka 更稳妥。

3. 确认运维成本：如果团队希望少维护组件，且已在使用 Redis，Redis Stream 可复用现有设施；若愿意投入运维资源换取稳定性，RabbitMQ 是独立专业服务。

核心配置与代码实现

理论对比不如代码直观，以下是两者在典型场景下的核心配置差异：

1. RabbitMQ 持久化与队列声明（Spring Boot）

为确保消息不丢失，队列需声明为持久化，消息发送需开启 Confirm 机制。

@Bean
public Queue queue() {
    // durable=true 确保队列元数据持久化
    return new Queue("order_queue", true); 
}

// application.yml 配置确认机制
spring:
  rabbitmq:
    publisher-confirm-type: correlated
    listener:
      simple:
        acknowledge-mode: manual // 手动 ACK 确保消费成功后再删除

2. Redis Stream 消费组与读取命令

Redis Stream 需手动创建消费组以实现可靠消费，避免消息丢失。

# 创建消费组（MKSTREAM 自动创建流）
XGROUP CREATE order_stream order_group $ MKSTREAM

# 消费者读取消息（阻塞式）
XREADGROUP GROUP order_group consumer1 COUNT 1 BLOCK 5000 STREAMS order_stream >

3. 关键配置对比

• RabbitMQ：依赖磁盘持久化，配置vm_memory_high_watermark防止内存溢出。
• Redis：依赖内存，必须配置appendonly yes开启 AOF 持久化，且建议设置maxmemory-policy noeviction防止消息因内存满被淘汰。

验证与监控实操

选型上线后，需要通过具体工具和指标验证选择是否合理：

1. 性能压测工具

不要只看理论值，建议在测试环境使用官方工具进行基准测试：

• Redis：使用redis-benchmark -t stream -n 100000测试 Stream 写入性能。
• RabbitMQ：使用perf-test工具模拟生产消费场景，观察吞吐与延迟。

2. 消息积压监控

• RabbitMQ：通过 Management 插件 UI 查看Messages Ready和Messages Unacknowledged。
• Redis：使用命令XINFO STREAM order_stream查看length和groupspending 数量。

3. 丢失率检查

定期核对生产消息数与消费消息数。RabbitMQ 可通过 Ack 机制确认；Redis 需检查是否有因内存淘汰导致的消息丢失，查看日志中是否有OOM或CAN'T SAVE错误。

常见风险与规避

1. Redis 内存爆炸与消息丢失：Redis 数据常驻内存，如果消息堆积未及时消费，可能导致内存溢出（OOM）。
规避：配置maxmemory上限，并将maxmemory-policy设置为noeviction，确保写失败而非数据丢失。

2. RabbitMQ 运维门槛：RabbitMQ 集群搭建、镜像队列配置、插件管理有一定门槛。
规避：新手建议直接使用 Docker Compose 部署单节点，或选择云厂商的托管服务（Managed Service），避免自建集群的复杂性。

3. 消息顺序性误解：两者都支持一定程度的顺序性，但在分布式消费组模式下，全局顺序很难保证。
规避：不要盲目依赖队列保证业务顺序，最好在业务逻辑层做校验，或确保同一业务 ID 的消息路由到同一队列分区。

4. 大消息传输：当数据大小超过一定阈值（如 10KB），Redis 的入队性能可能显著下降。
规避：大文件传输建议走对象存储，队列只传引用（URL 或 ID）。

参考文档

• RabbitMQ Official Documentation
• Redis Streams Documentation
• Spring AMQP Project