MQ基础介绍

什么是MQ？

全称MessageQueue消息队列，主要是用于程序和程序之间异步通信、代码解耦、流量削峰

什么是JMS？

JMS（Java Message Service）是由Sun公司早期提出的消息API标准，旨在为java应用提供统一的消息操作，包括create、send、receive。它类似于JDBC(Java Database Connectivity)。这里JDBC 是可以用来访问许多不同关系数据库的 API。

JMS概念介绍

• JMS提供者：连接面向消息中间件的，JMS接口的一个实现，RocketMQ,ActiveMQ,Kafka等
• JMS生产者(Message Producer)：生产消息的服务
• JMS消费者(Message Consumer)：消费消息的服务
• JMS消息：数据对象
• JMS队列：存储待消费消息的区域
• JMS主题：一种支持发送消息给多个订阅者的机制
• JMS消息通常有两种类型：点对点（Point-to-Point)、发布/订阅（Publish/Subscribe）

JMS基础编程模型

• ConnectionFactory ：连接工厂，JMS 用它创建连接
• Connection ：JMS客户端到JMS Provider 的连接
• Session： 一个发送或接收消息的线程
• Destination ：消息的目的地；消息发送给谁
• MessageConsumer / MessageProducer： 消息消费者，消息生产者

什么是AMQP?

• JMS或者NMS（.NET语言的消息服务）都没有标准的底层协议，它们可以在任何底层协议上运行，但是API是与编程语言绑定的，AMQP解决了这个问题，它使用了一套标准的底层协议。
• AMQP（Advanced Message Queuing Protocol）在2003年时被提出，最早用于解决金融领域不同平台之间的消息传递交互问题，就是是一种协议，兼容JMS
• 更准确说的链接协议 binary- wire-level-protocol 直接定义网络交换的数据格式，类似http

JMS和AMQP的区别

• AMQP不从API层进行限定，直接定义网络交换的数据格式，这使得实现了AMQP的provider天然性就是跨平台
• 比如Java语言产生的消息，可以用其他语言比如python的进行消费
• AQMP可以用http来进行类比，不关心实现接口的语言，只要都按照相应的数据格式去发送报文请求，不同语言的client可以和不同语言的server进行通讯
• JMS消息类型：TextMessage、ObjectMessage、StreamMessage等
• AMQP消息类型：Byte[]

主流消息队列介绍

• ActiveMQ：ActiveMQ

  • Apache出品，历史悠久，支持多种语言的客户端和协议，支持多种语言Java，.NET, C++ 等
  • 基于JMS Provider的实现
  • 缺点：吞吐量不高，多队列的时候性能下降，存在消息丢失的情况，比较少大规模使用

• Kafka：Apache Kafka

  • 是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理大规模的网站中的所有动作流数据(网页浏览，搜索和其他用户的行动)，副本集机制，实现数据冗余，保障数据尽量不丢失，在处理大数据日志方面尤其擅长；支持多个生产者和消费者
  • 类似MQ，功能较为简单，主要支持简单的MQ功能
  • 缺点：不支持批量和广播消息，运维难度大，文档比较少, 需要掌握Scala

• RocketMQ：RocketMQ · 官方网站 | RocketMQ

  • 阿里开源的一款的消息中间件, 纯Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点，性能强劲(零拷贝技术)，支持海量堆积，支持指定次数和时间间隔的失败消息重发,支持consumer端tag过滤、延迟消息等，在阿里内部进行大规模使用，适合在电商，互联网金融等领域
  • 基于JMS Provider的实现
  • 缺点：社区相对不活跃，更新比较快，纯java支持

• RabbitMQ：Messaging that just works — RabbitMQ

  • 是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、C、用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不错
  • 缺点：使用Erlang开发，阅读和修改源码难度大