国涟建设集团有限公司网站宁波电子商务公司

使用mq优点

mq是一种常见的中间件，在项目中经常用到，它具有异步、解耦、削峰填谷的作用。

异步

比如下单流程，A服务—>B服务，总的耗时是A耗时时间+B耗时时间，而改为A—>mq---->B后，A发送mq后立刻返回，不需要等待B，A与B之间从同步改为了异步，当B是个外部服务且比较耗时时，可考虑。实践中，如果消息消费依赖事务提交，可使用TransactionSynchronizationManager，确保提交事务先于消费消息。

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {@Overridepublic void afterCommit() {//发送qm}});

解耦

还是上边的例子，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下的消息，会被所有的订阅者消费；
• 点对点：消息只会被一个消费者消费。

市面上常见mq对比

kafka、rabbitmq、rocketmq

• kafka会将数据写入磁盘缓存，所以存在丢失的情况，常用于日志，因为日志丢失一些也不会产生错误。
• rabbitmq，支持AMQP协议、JMS，每秒几万，支持消息确认、
• rocketmq，阿里出品的企业级mq中间价，经历了双11等电商大促，JMS，每秒十几万，想要的功能基本都支持，具体可参考Why choose RocketMQ