0、使用消息中间件的原因
假设有一个系统,需要调用其他的服务,按照传统的服务调用方式(同步),则需要同时调用很多的系统,而这些系统如果没有响应成功,则该系统就会一直等待。这样就会影响用户的体验
一是不需要必须同步调用所有的其他服务;二是可以异步调用其他服务
通过消息中间件可以解耦服务调用。即该系统发起消息到消息中间件,消息中间件再将消息投递给需要调用的其他系统
1、使用消息中间件的好处
⑴ 系统解耦
通过消息中间件减少了各个系统间的耦合度
⑵ 异步
⑶ 横向扩展
需要调用的某个系统可以再扩展开为多个系统集群,同时消费消息中间件里的消息
⑷ 安全可靠
消息中间件可以保存消息,直到消息被业务系统消费为止。如果系统出现异常,可以等到系统恢复后再次消费消息
⑸ 顺序的保证
kafka日志消息中间件可以保证消息的顺序
2、中间件
非底层操作系统软件,非业务应用软件,不是直接给最终用户使用的,不能直接给客户带来价值的软件统称为中间件
3、消息中间件
关注于数据的发送和接收,利用高效可靠的异步消息传递机制集成分布式系统
4、JMS
Java Message Service,Java消息服务。是一个Java平台中关于面向消息中间件的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步的通信
5、AMQP
Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可以传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制
6、JMS和AMQP对比
7、常见消息中间件
⑴ ActiveMQ
Apache出品,最流行的、能力强劲的开源消息总线。它完全支持JMS1.1和J2EE1.4规范的JMS Provider实现,尽管JMS出台已经很久了,但是它在当今的J2EE应用中仍然扮演着特殊的地位
① 支持多种语言和协议编写客户端
编程语言:Java,C,C++,C#,Ruby,Perl,Python,PHP
应用协议:OpenWire,Stomp REST,WS Notification,XMPP,AMQP
② 完全支持JMS1.1和J2EE1.4规范,包括持久化、XA消息和事务
③ 虚拟主题,组合目的,镜像队列
④ 消息持久化
⑵ RabbitMQ
一个开源的AMQP的实现,服务器端用Erlang语言编写,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗
① 支持多种客户端,如:
Java,C,.NET,Ruby,Python,PHP,JMS,ActionScript等
② AMQP的完整实现,vhost(虚拟主机)、Exchange(交换器)、Binding(绑定)、Routing Key(路由)等
③ 事务支持/发布确认
④ 消息持久化
⑶ kafka
一种高吞吐量的分布式发布订阅消息系统,是一个分布式的、分区的、可靠的分布式日志存储服务。通过一种独一无二的设计提供了一个消息系统的功能
① 通过O(1)算法复杂度的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也是能够保持长时间的稳定性能
② 高吞吐量:即使是非常普通的硬件,kafka也可以支持每秒数百万的消息
③ Partition(分区)、Consumer Group(消费者分组)