聊聊mq中消息消费的几种方式

mq系列文章

对mq了解不是不少的，能够看一下下面两篇文章:

1. 聊聊mq的使用场景
2. 聊聊业务系统中投递消息到mq的几种方式
3. 聊聊消息消费的几种方式
4. 如何确保消息至少消费一次
5. 如何保证消息消费的幂等性

本章内容

从消费者的角度出发，分析一下消息消费的两种方式：

1. push方式
2. pull方式

push方式

消息消费的过程：

1. mq接收到消息

2. mq主动将消息推送给消费者（消费者需提供一个消费接口）

mq属于主动方，消费者属于一种被动消费，一旦有消息到达mq，会触发mq推送机制，将消息推送给消费者，无论消费者处于何种状态。

优势：

1. 消费者代码较少：对于消费者来讲，只需提供一个消费接口给mq便可；mq将接收到的消息，随即推送到指定的消费接口

2. 消息实时性比较高：对于消费者来讲，消息一旦到达mq，mq会当即推送给消费者

缺点：

1.消费者属于被动方，消息量比较大时，对消费者性能要求比较高；若消费者机器资源有限，可能会致使压力过载，引起宕机的状况。

2.对消费者可用性要求比较高：当消费者不可用时，会致使很push失败，在mq方须要考虑至少推送成功一次，这块的设计下章节会作说明。

pull方式

消息消费的过程：

1.消费端采用轮询的方式，从mq服务中拉取消息进行消费

2.消费完成通知mq删除已消费成功的消息

3.继续拉取消息消费

对于消费者来讲，是主动方，能够采用线程池的方式，根据机器的性能来增长或缩小线程池的大小，控制拉取消息的速度，能够很好的控制自身的压力。

优势：

1.消费者能够根据本身的性能主动控制消息拉去的速度，控制本身的压力，不至于把本身弄跨

2.实时性相对于push方式会低一些

3.消费者属于主动方，控制权更大一些

缺点：

1.消费方须要实现消息拉取的代码

2.消费速度较慢时，可能致使mq中消息积压，消息消费延迟等

总结

1. 消费者性能较好，对实时性要求比较高的，能够采用push的方式

2. 消费者性能有限，建议采用pull的方式

3. 总体上来讲，主要在于消费者的性能，机器的性能若是没有问题，push和pull都是能够的

4. 你们有什么见解，能够留言一块儿讨论，但愿本文对你有所帮助