消息队列

• MQ
• 作用
  • 服务解耦
  • 异步处理
  • 流量削峰/缓冲 # 如促销期
  • 消息总线可扩展 # x扩展不行，y扩展用专用总线(降低了灵活性), z扩展根据客户
  • 减少拥挤 # 消息划分价值
• 问题
  • 丢失/失败 # 持久化，日志，报警, 数据校对修正(worker扫库)
  • 重复 # 业务上防重
  • 消息重发
    • 状态表记录消息状态
• 应用分类
  • 缓冲队列
  • 任务队列
  • 消息队列
  • 请求队列
  • 数据总线队列
  • 混合队列
  • 优先级队列、副本队列、镜像队列
• 例子
  • redis扣库存→记录日志→同步worker→DB
• 框架
  • Pulsar
  • RocketMQ
  • RabbitMQ
  • Jafka
  • Kafka
  • NSQ
  • ZeroMQ
  • ActiveMQ
  • Beanstalkd
  • emqttd
  • Apollo MQ
  • Metaq
  • Disruptor
  • Canal