RabbitMQ简介

AMQP

AMQP，即Advanced Message Queuing Protocol，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。类比HTTP

RabbitMQ架构及概念

RabbitMQ基础架构：

RabbitMQ中的相关概念：

• Broker：接收和分发消息的应用，RabbitMQ Server就是Message Broker
• Virtual Host: 处于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQ server提供服务时，可以化为出多个virtual host，每个用户在自己的vhost常见exchange/queue等
• Connection：publisher、consumer和broker之间的TCP连接
• Channel： 如果每次访问都建立一个Connection，在消息量大的时候建立TCP connection的开销是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个Thread常见单独的channel进行通讯，AMQP method包含了channel id帮助客户端和message broker识别channel，所以channel之间是完全隔离的。Channel作为轻量级的Connection极大减少了操作系统建立的TCP connection的开销
• Exchange：Message达到broker的第一站，根据分发规则，匹配查询表中的routing key，分发消息到queue中去。通常类型有：direct（point-to-point）,topic(publish-subscribe),fanout(multicast)
• Queue:消息最终被送到这里等待consumer取走
• Binding：exchange和queue之间的虚拟连接，binding中可以包含routing key。binding信息被保存到exchange中的查询表中，用于message的分发依据

RabbitMQ工作模式

• 简单模式
• work queues
• Publish/Subscribe发布与订阅模式
• Routing路由模式
• Topics主题模式
• RPC远程调用模式

JMS

JMS即java消息服务应用程序接口，是一个java平台中关于面向消息中间件的API

JMS是JavaEE规范的一种，类比JDBC

很多消息中间件实现了JMS规范，例如ActiveMQ，而RabbitMQ官方没有提供JMS的实现包，但开源社区有