《RocketMQ实战与原理解析》 前言 ​ 本章介绍在大流量场景下,提高 RocketMQ 集群吞吐量的一些方法,有些方法当服务器出异常时...

《RocketMQ实战与原理解析》 消息重复问题 ​ 对分布式消息队列来说，同时做到确保一定投递和不重复投递是很难的， 也就是所谓的“有且仅...

《RocketMQ实战与原理解析》 前言 ​ Broker 是 RocketMQ 的核心, 大部分“重量级”工作都是由 Broker 完成的...

《RocketMQ实战与原理解析》 OffsetStore 实际运行中的系统，难免会遇到重新消费某条消息、跳过一段时间内的消息等情况。这些异常情...

《RocketMQ实战与原理解析》 DefaultMQProducer 的使用 发送消息要经过五个步骤： 1）设置 Producer 的 Gro...

《RocketMQ实战与原理解析》 DefaultMQPushConsumer的使用 DefaultMQPushConsumer，由系统控制读取...

《RocketMQ实战与原理解析》 DefaultMQPullConsumer的使用 示例代码的处理逻辑是逐个读取某 Topic 下所有 Mes...

《RocketMQ实战与原理解析》 Maven依赖 发送消息 接收消息

系统要求 64bit 的 Linux、 Unix 或 Mac (Windows 也支持) 64bit JDK 1.8+; Maven 3.2.x...