什么是MQ

本质是一个队列，只不过队列中存放的信息是message罢了，还是一种跨进程的通信机制，用于上下游传递信息。在互联网架构中，MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了MQ之后，信息发送上有只需要依赖MQ，不用依赖其他服务。

为什么要使用MQ

• 流量消峰
• 应用解耦
• 异步处理

MQ的分类

• ActiveMQ
  • 优点：单机吞吐量万级，时效性ms级，可用性高，基于主从架构高可用性，消息可靠性较低的概率丢失数据
  • 缺点：维护较少，高吞吐量场景较少使用
• Kafka
  • 大数据中使用率高，百万级TPS的吞吐量
  • 优点：吞吐量高、分布式、时效性高、不会丢失数据、使用广泛
  • 缺点：消息失败不支持重试
• RocketMQ
  • 优点：单机吞吐量高、0丢失、支持10亿级别的消息堆积
  • 缺点：支持客户端语言不多
• Rabbit
  • 当前最主流的消息中间件之一
  • 优点：支持高并发、性能好、吞吐量高、跨平台、支持多种语言、社区活跃高…
  • 缺点：商业版需要收费，学习成本高

MQ的选择

• Kafka：大数据、大型公司、日志采集
• RocketMQ：金融互联网、稳定性上值得信赖、高并发
• RabbitMQ：时效性微秒级、社区活跃度比较高、数据量没那么大

RabbitMQ

概念

是一个消息中间件：接收、存储和转发信息数据

• 生产者：生产数据发送信息的程序是生产者
• 交换机：

  

• 队列：

  

• 消费者：

  

核心部分

• 工作原理

  

• Broker：接收和分发信息的应用，RabbitMQ Server就是Message Broker

• Virtual host：

  

• Connection：publisher/consumer和broker之间的TCP连接

• Channel：

  

• Exchange:

  

• Queue：消息最终被送到这里consumer取走

• Binding：