MQ那点事（一）消息队列的用途、优缺点、技术选型

1.为什么使用消息队列&＃xff1f;

&＃xff08;1&＃xff09;解耦&＃xff1a;可以在多个系统之间进行解耦&＃xff0c;将原本通过网络之间的调用的方式改为使用MQ进行消息的异步通讯&＃xff0c;只要该操作不是需要同步的&＃xff0c;就可以改为使用MQ进行不同系统之间的联系&＃xff0c;这样项目之间不会存在耦合&＃xff0c;系统之间不会产生太大的影响&＃xff0c;就算一个系统挂了&＃xff0c;也只是消息挤压在MQ里面没人进行消费而已&＃xff0c;不会对其他的系统产生影响。

&＃xff08;2&＃xff09;异步&＃xff1a;加入一个操作设计到好几个步骤&＃xff0c;这些步骤之间不需要同步完成&＃xff0c;比如客户去创建了一个订单&＃xff0c;还要去客户轨迹系统添加一条轨迹、去库存系统更新库存、去客户系统修改客户的状态等等。这样如果这个系统都直接进行调用&＃xff0c;那么将会产生大量的时间&＃xff0c;这样对于客户是无法接收的&＃xff1b;并且像添加客户轨迹这种操作是不需要去同步操作的&＃xff0c;如果使用MQ将客户创建订单时&＃xff0c;将后面的轨迹、库存、状态等信息的更新全都放到MQ里面然后去异步操作&＃xff0c;这样就可加快系统的访问速度&＃xff0c;提供更好的客户体验。

&＃xff08;3&＃xff09;削峰&＃xff1a;一个系统访问流量有高峰时期&＃xff0c;也有低峰时期&＃xff0c;比如说&＃xff0c;中午整点有一个抢购活动等等。比如系统平时流量并不高&＃xff0c;一秒钟只有100多个并发请求&＃xff0c;系统处理没有任何压力&＃xff0c;一切风平浪静&＃xff0c;到了某个抢购活动时间&＃xff0c;系统并发访问了剧增&＃xff0c;比如达到了每秒5000个并发请求&＃xff0c;而我们的系统每秒只能处理2000个请求&＃xff0c;那么由于流量太大&＃xff0c;我们的系统、数据库可能就会崩溃。这时如果使用MQ进行流量削峰&＃xff0c;将用户的大量消息直接放到MQ里面&＃xff0c;然后我们的系统去按自己的最大消费能力去消费这些消息&＃xff0c;就可以保证系统的稳定&＃xff0c;只是可能要跟进业务逻辑&＃xff0c;给用户返回特定页面或者稍后通过其他方式通知其结果。

2.消息队列有什么优点和缺点&＃xff1f;

优点&＃xff1a;1、对结构复杂、设计系统多的操作进行解耦操作&＃xff0c;降低系统的操作复杂度、降低系统的维护成本。
   2、对一个可以进行异步操作的一些系统操作进行异步&＃xff0c;减小操作的响应时间&＃xff0c;提供更好的用户体验。
   3、可对高流量进行削峰&＃xff0c;保证系统的平稳运行。
缺点&＃xff1a;1、系统可用性降低。比如在系统中引入MQ&＃xff0c;那么万一MQ挂了怎么办呢&＃xff1f;一般而言&＃xff0c;引入的外部依赖越多&＃xff0c;系统越
    脆弱&＃xff0c;每一个依赖出问题都会导致整个系统的崩溃。
   2、系统复杂度提高。需要考虑MQ的各种情况&＃xff0c;比如&＃xff1a;消息的重复消费、消息丢失、保证消费顺序等等…
   3、数据一致性问题。比如A系统已经给客户返回操作成功&＃xff0c;这时候操作BC都成功了&＃xff0c;操作D却失败了&＃xff0c;导致数据不
    一致。

3.kafka、activemq、rabbitmq、rocketmq都有什么优点和缺点啊&＃xff1f;

综上所述&＃xff0c;总结如下&＃xff1a;
一般业务系统要引入MQ&＃xff0c;最早大家都用ActiveMQ&＃xff0c;但现在用的不多了。没有经过大规模吞吐场景的验证&＃xff0c;社区也不活跃&＃xff0c;不推荐再使用。
后来大家开始用rabbitMQ&＃xff0c;但是它是使用erlang语言开发的&＃xff0c;如果不精通erlang&＃xff0c;对公司而言&＃xff0c;几乎处于不可控的状态&＃xff0c;单其是开源的&＃xff0c;社区活跃度高&＃xff0c;拥有比较稳定的支持。
现在越来越多的公司开始使用RocketMQ&＃xff0c;但是要小心被抛弃的风险。如果公司有实力自己去维护开发&＃xff0c;推荐使用。否则还是选择RabbitMQ。
如果实在大数据的实时计算、日志采集等领域&＃xff0c;用kafka是业界标准。
所以&＃xff0c;对于中小型公司&＃xff0c;技术实力一般的&＃xff0c;应该用rabbitmq&＃xff0c;对于大公司&＃xff0c;基础架构研发能力强大的&＃xff0c;推荐使用RocketMQ。