RocketMQ 消费者
本文分析 DefaultMQPushConsumer，异步发送消息，多线程消费的情形。 DefaultMQPushConsumerImpl MQClientInstance 一个客户端进程只有一个 MQClientInstance 实例 MQClientAPIImpl 和 netty ...
原文：RocketMQ读书笔记3——消费者
不同类型的消费者 DefaultMQPushConsumer 由系统控制读取操作，收到消息后自动调用传入的处理方法来处理。 DefaultMQPullConsumer 读取操作中的大部分功能由使用者自动控制。 DefaultMQPushConsumer的使用 特点 .系统收到消息后自动调用处理方法来处理消息，自动保存Offset。 .加入的新的DefaultMQPushConsumer会自动做负 ...
2018-11-29 23:28 0 1056 推荐指数：
相关推荐
RocketMQ消费者实践
最近工作中用到了RocketMQ，现记录下，如何正确实现消费~ 消费者需要注意的问题 防止重复消费 如何快速消费 消费失败如何处理 Consumer具体实现 防止重复消费 重复消费会造成数据不一致等问题。所以，消费者要做到消费幂 ...
RocketMQ读书笔记4——NameServer(MQ的协调者)
【NameServer简述】 对于一个消息队列集群来说，系统由很多机器组成，每个机器的角色、IP地址都不相同，而且这些信息是变动的（如在某些情况下，会有新的Producer或Consumer加入 ...
RocketMQ读书笔记7——吞吐量优先的场景
【Broker端进行消息过滤】 在Broker端进行消息过滤，可以减少无效消息发送到Consumer，少占用网络宽带从而提高吞吐量。 【过滤方式1——通过Tag过滤】 [ 关于Tag和Ke ...