消息队列基础与选型？

# 1. 解耦 # 没有 MQ：订单服务直接调用短信服务、积分服务 # 订单服务 → 短信服务（短信服务挂了，订单也失败） # 订单服务 → 积分服务 # 有了 MQ：订单服务只发消息，不关心谁消费 # 订单服务 → MQ → 短信服务 # → 积分服务 # → 数据分析服务（新增消费者无需改订单服务） # 2. 异步 # 同步：用户注册 → 写DB(50ms) → 发短信(200ms) → 送积分(100ms) = 350ms # 异步：用户注册 → 写DB(50ms) → 发消息(1ms) = 51ms # 短信服务异步消费 → 发短信 # 积分服务异步消费 → 送积分 # 3. 削峰 # 秒杀场景：瞬时 10 万请求 # 没有 MQ：系统被打垮 # 有了 MQ：请求先入队列，系统按处理能力消费（如 1000/s）

# 点对点（Queue） # 一条消息只能被一个消费者消费 # 消费者消费后消息删除 # 适用：下单、扣库存（只能处理一次） # 发布订阅（Topic） # 一条消息可以被多个消费者消费 # 每个消费者有自己的消费进度 # 适用：广播通知、数据同步 # Kafka/RocketMQ 都是发布订阅模型 # 通过 Consumer Group 实现点对点效果 # 同一个 Consumer Group 内，一条消息只被一个消费者消费 # 不同 Consumer Group 之间，消息广播

# 选型决策树 # 1. 业务场景是什么？ # 日志收集 / 流处理 / 大数据 → Kafka # 金融 / 电商交易 / 事务消息 → RocketMQ # 通用业务 / 低延迟 → RabbitMQ # 2. 是否需要事务消息？ # 是 → RocketMQ（唯一原生支持） # 否 → 继续判断 # 3. 是否需要超高吞吐？ # 是 → Kafka # 否 → RocketMQ 或 RabbitMQ # 4. 团队技术栈？ # Java 为主 → RocketMQ（阿里系，中文文档好） # 多语言 → Kafka 或 RabbitMQ # 国内互联网公司推荐 # 阿里系 → RocketMQ # 字节/美团 → Kafka # 中小公司 → RocketMQ（功能全、运维简单）

# 通用概念 # Producer：生产者，发送消息 # Consumer：消费者，接收消息 # Broker：消息服务器，存储和转发消息 # Topic：主题，消息分类 # Partition/Queue：分区/队列，并行处理单元 # Consumer Group：消费者组，组内竞争消费 # Offset：消费位移，记录消费进度 # 消息传递语义 # At Most Once：最多一次（可能丢消息） # At Least Once：至少一次（可能重复，默认） # Exactly Once：精确一次（最理想，实现复杂）

# 1. 引入依赖 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> </dependency> # 2. 配置 rocketmq: name-server: localhost:9876 producer: group: order-producer-group # 3. 发送消息 @Autowired private RocketMQTemplate rocketMQTemplate; public void sendOrderMessage(Order order) { rocketMQTemplate.convertAndSend("order-topic", order); } # 4. 消费消息 @RocketMQMessageListener(topic = "order-topic", consumerGroup = "order-consumer-group") @Component public class OrderConsumer implements RocketMQListener<Order> { @Override public void onMessage(Order order) { // 处理订单消息 } }