SpringBoot怎么使用RocketMQ

文章资讯 2020-07-19 14:19:10

SpringBoot怎么使用RocketMQ

SpringBoot如何优雅的使用RocketMQ
MQ,是一种跨进程的通信机制,用于上下游传递消息。在传统的互联网架构中通常使用MQ来对上下游来做解耦合。

举例:当A系统对B系统进行消息通讯,如A系统发布一条系统公告,B系统可以订阅该频道进行系统公告同步,整个过程中A系统并不关系B系统会不会同步,由订阅该频道的系统自行处理。

什么是RocketMQ?
官方说明:

随着使用越来越多的队列和虚拟主题,ActiveMQ IO模块遇到了瓶颈。我们尽力通过节流,断路器或降级来解决此问题,但效果不佳。因此,我们那时开始关注流行的消息传递解决方案Kafka。不幸的是,Kafka不能满足我们的要求,特别是在低延迟和高可靠性方面。

看到这里可以很清楚的知道RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。

具有以下特性:
支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型
能够保证严格的消息顺序,在一个队列中可靠的先进先出(FIFO)和严格的顺序传递
提供丰富的消息拉取模式,支持拉(pull)和推(push)两种消息模式
单一队列百万消息的堆积能力,亿级消息堆积能力
支持多种消息协议,如 JMS、MQTT 等
分布式高可用的部署架构,满足至少一次消息传递语义