目录
MQ优点
异步
解耦
削峰填谷
mq的缺点
MQ常见的几种模式
Kafka、ActiveMQ、RabbitMQ、RocketMQ 区别
MQ优点
mq是一种常见的中间件,在项目中经常用到,它具有异步、解耦、削峰填谷的作用。
异步
比如下单流程,A服务—>B服务,总的耗时是A耗时时间+B耗时时间,而改为A—>mq---->B后,A发送mq后立刻返回,不需要等待B,A与B之间从同步改为了异步,当B是个外部服务且比较耗时时,可考虑。实践中,如果消息消费依赖事务提交,可使用TransactionSynchronizationManager,确保提交事务先于消费消息。
解耦
还是上边的例子,A服务中硬编码调用B服务,如果还有其他,C服务、D服务等,都要硬编码,代码耦合。使用mq后,A只管发送mq,其他消费者订阅就可以了,A不需要知道B、C、D的存在,如果后边再加入E、F,A服务也不需要改代码。比如订单支付后,要更改积分、更改库存、更改物流状态,那么就可以使用消息的发布-订阅模式,达到解耦。
削峰填谷
大体看了下,常见的mq实现,rabbitmq、kafak、rocketmq至少支持1w/s+的tps,但数据库就没有这么大的处理能力了,还是下单流程,订单数据可以先存到mq中,立刻返回,可以慢慢消费消息落到数据库。
mq的缺点
mq引入后,会有以下缺点。
- 新引入了中间件,增加了运维负担
- 生产者确保消费发送到mq server
- mq server确保消费者收到
- 消费者重复消费
- 系统可用性降低
- 系统复杂度提高
- 一致性问题
MQ常见的几种模式
- 发布/订阅:同一个topic下的消息,会被所有的订阅者消费
- 点对点:消息只会被一个消费者消费
Kafka、ActiveMQ、RabbitMQ、RocketMQ 区别
# 1.ActiveMQ
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。它是一个完全支持JMS规范的的消息中间件。丰富的API,多种集群架构模式让ActiveMQ在业界成为老牌的消息中间件,在中小型企业颇受欢迎!
# 2.Kafka
Kafka是LinkedIn开源的分布式发布-订阅消息系统,目前归属于Apache顶级项目。Kafka主要特点是基于Pull的模式来处理消息消费,
追求高吞吐量,一开始的目的就是用于日志收集和传输。0.8版本开始支持复制,不支持事务,对消息的重复、丢失、错误没有严格要求,
适合产生大量数据的互联网服务的数据收集业务。
# 3.RocketMQ
RocketMQ是阿里开源的消息中间件,它是纯Java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。RocketMQ思路起
源于Kafka,但并不是Kafka的一个Copy,它对消息的可靠传输及事务性做了优化,目前在阿里集团被广泛应用于交易、充值、流计算、消
息推送、日志流式处理、binglog分发等场景。
# 4.RabbitMQ
RabbitMQ是使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由(包括点对点和
发布/订阅)、可靠性、安全。AMQP协议更多用在企业系统内对数据一致性、稳定性和可靠性要求很高的场景,对性能和吞吐量的要求还在
其次。