RocketMQ Consumer 学习笔记

学习一下RocketMQ - 消费者的原理和使用?

消费模式
消息消费有两种模式:

1、并发消费
并发消费是默认的处理方法,一个消费者使用线程池技术,可以并发消费多条消息,提升机器的资源利用率。默认配置是 20 个线程,所以一台机器默认情况下,同一瞬间可以消费 20 个消息。关注公众后码猿技术专栏获取更多面试资源。
其中 ConsumeMessageConcurrentlyService 的构造函数如下:
public ConsumeMessageConcurrentlyService(DefaultMQPushConsumerImpl defaultMQPushConsumerImpl,
        MessageListenerConcurrently messageListener) {
        this.defaultMQPushConsumerImpl = defaultMQPushConsumerImpl;
        this.messageListener = messageListener;

RocketMQ Consumer 学习笔记最先出现在Python成神之路

版权声明:
作者:congcong
链接:https://www.techfm.club/p/7176.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>