随着分布式系统的规模和复杂度提高&＃xff0c;往往会出现如下问题&＃xff1a;&＃xff08;1&＃xff09;系统间同步通信&＃xff0c;客户端发出调用后&＃xff0c;必须等到服务对象完成处理并返回结果后才能继续执行&＃xff1b;&＃xff08;2&＃xff09;服务端和客户端强耦合&＃xff0c;后端一旦出现故障&＃xff0c;前台将会牵扯进来&＃xff1b;&＃xff08;3&＃xff09;客户的一次调用只能发送给单独目标对象。在这样的环境下&＃xff0c;面向消息的中间件就应运而生了。
1. 什么是消息中间件&＃xff1f;有什么特点&＃xff1f;
很容易理解&＃xff0c;消息中间件&＃xff0c;就是将程序从一个程序传送到另一个或者多个应用程序。突出的特点为&＃xff1a;
&＃xff08;1&＃xff09;消息异步传输&＃xff0c;降低多系统间的耦合度
&＃xff08;2&＃xff09;消息可靠接收&＃xff0c;使用事务&＃xff0c;确保接收方收到消息后才取消消息&＃xff0c;多个消息可以组成原子事务
2. 什么是JMS&＃xff1f;有什么优势特性&＃xff1f;
JMS定义了java中访问消息中间件的接口&＃xff01;优势特性&＃xff1a;
&＃xff08;1&＃xff09;可靠性机制&＃xff1a;只有被确认&＃xff0c;才能成功消费。消息会话机制分为两种&＃xff1a;一是事务性会话&＃xff0c;事务提交&＃xff0c;成功消费自动提交&＃xff1b;二是非事务性会话&＃xff0c;包含三种会话应答模式&＃xff1a;AUTO_ACKNOWLEDGE自动确认&＃xff0c;客户端发送和接收不需要额外操作&＃xff1b;CLIENT_ACKNOWLEDGE&＃xff0c;客户端接收消息后&＃xff0c;必须调用javax.jms.Message的acknowledge方法才能确认消息消费成功&＃xff1b;DUPS_OK_ACKNOWLEDGE允许副本确认模式&＃xff0c;接收方应用程序方法调用从处理消息处返回&＃xff0c;会话对象就会确认消息接收&＃xff0c;且允许重复确认。
&＃xff08;2&＃xff09;持久性机制&＃xff1a;如果为persistent&＃xff0c;即使jms provider挂了&＃xff0c;重启&＃xff0c;未被消费的消息任然存在&＃xff0c;且默认情况下就是持久化存储。如果为non_persistent,则不要求JMS provider持久保存消息。
&＃xff08;3&＃xff09;优先级机制&＃xff1a;10个&＃xff0c;从0到9&＃xff0c;默认为4&＃xff0c;但JMS Provider有时候并不会按照优先级顺序提交消息。
&＃xff08;4&＃xff09;消息过期机制&＃xff1a;可设置一定时间后自动过期&＃xff0c;只有在有效时间内&＃xff0c;消费者才可以消费消息。
&＃xff08;5&＃xff09;本地事务&＃xff1a;一组操作均完成后才能提交。
3. 常用的消息队列有哪几种&＃xff1f;各有什么优缺点&＃xff1f;
经常使用的JMS有ActiveMQ&＃xff0c;RabbitMQ&＃xff0c;RocketMQ&＃xff1b;
ActiveMQ是apache公司下成熟的消息中间件产品&＃xff0c;功能齐全被大多数公司引进&＃xff1b;社区活跃度高&＃xff0c;也成熟&＃xff0c;最重要的是支持的协议和java语言较多&＃xff0c;持久化方式多种多样&＃xff08;包括内存&＃xff0c;文件&＃xff0c;数据库&＃xff09;&＃xff1b;但是ActiveMq不适合上千队列的应用场景。
RabibitMQ是Erlang语言开发&＃xff0c;并发能力强&＃xff0c;处理性能好&＃xff0c;管理界面丰富&＃xff0c;在互联网公司也有大规模引用&＃xff0c;但它不支持事务&＃xff0c;集群无法做到动态扩展。
RocketMQ是Alibaba公司提供&＃xff0c;模型简单&＃xff0c;接口易用&＃xff0c;性能非常好&＃xff0c;可以大量堆积消息在boker中&＃xff0c;支持多种消费&＃xff0c;集群消费&＃xff1b;但是它内容较新&＃xff0c;没有实现JMS接口&＃xff0c;对已有系统无法兼容。在支持的协议上有自己定义的一套&＃xff0c;部分内容未公开。
京公网安备 11010802041100号