互联网消息队列（Internet Message Queue）

1. 基础概念
   互联网消息队列是一种异步通信机制，允许分布式应用通过队列传递数据。发送方（生产者）将消息放入队列，接收方（消费者）按顺序或优先级处理消息，双方无需同时在线。例如电商系统中，订单生成后通过队列通知库存服务扣减库存，避免直接耦合。

2. 核心组件与工作流程

   • 生产者：创建并发送消息到指定队列（如用户提交订单时触发消息）。
   • 消息代理：管理队列的中间件（如RabbitMQ、Kafka），负责接收、存储和路由消息。
   • 队列：消息的缓冲容器，通常遵循先进先出（FIFO）原则，支持优先级或延迟投递。
   • 消费者：从队列获取消息并执行业务逻辑（如库存服务处理扣减请求）。
     流程示例：生产者 → 消息代理 → 队列 → 消费者确认 → 消息删除。

3. 消息传递模式

   • 点对点：一个消息仅被一个消费者处理（如订单分配系统）。
   • 发布/订阅：消息广播到多个消费者（如新闻推送至多个用户端）。
   • 请求/响应：通过临时队列实现双向通信（如支付状态查询）。

4. 消息持久化与可靠性

   • 持久化存储：消息代理将队列数据写入磁盘，防止服务重启丢失。
   • 确认机制：消费者处理成功后向代理发送ACK，否则消息重新入队。
   • 事务支持：生产者确保消息原子性投递（如数据库事务与消息发送保持一致）。

5. 高级特性与应用场景

   • 死信队列：处理多次失败的消息，避免阻塞主队列。
   • 消息优先级：紧急任务（如库存告警）优先处理。
   • 限流与削峰：突发流量时队列缓冲请求，保护后端系统（如秒杀活动）。
   • 微服务解耦：服务间通过队列通信，提升系统弹性与可扩展性。

6. 常见协议与工具

   • AMQP：高级消息队列协议（RabbitMQ使用）。
   • MQTT：轻量级协议，适用于物联网场景。
   • Kafka：高吞吐分布式流平台，支持持久化日志与批量消费。

7. 容错与监控

   • 集群部署：多节点消息代理避免单点故障。
   • 监控指标：队列深度、消息延迟、消费者状态（通过Prometheus等工具）。
   • 重试策略：指数退避算法避免频繁失败请求压垮系统。