RocketMQ Consumer 学习笔记

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

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

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

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