在企业实践RocketMQ时基本上80%都是不消费问题，而由于消费进度问题导致不消费的问题又是最难确认的和排查的。RocketMQ的消费进度分为本地消费进度管理...

最近突然感觉：很多软件、硬件在设计上是有root reason的，不是by desgin如此，而是解决了那时、那个场景的那个需求。一旦了解后，就会感觉在和设计者...

说明proder发送异常，也有可能是消息过期了，因为rocketmq的消息默认保存72h，此时到producer端的日志进一步确认即可。

可以在 Rocket_HOME/distribution/target/apache-rocketmq 下执行 " sh bin/mqbroker -m " 来...

出现了重复消费的问题，同一个消息被重复消费了多次，导致了用户端收到了多条重复的消息，最终排查发现，是因为消费者在处理消息的方法onMessage中有异常没有捕获...

今天将一个SpringBoot项目的配置参数从原有的.yml文件迁移到Apollo后，启动报错“Bean method 'rocketMQTemplate' i...

假如 没有 Spring Boot Starter，我们有两种方式来创建 Spring Bean。

org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

RocketMQ 是一款高性能、可扩展的分布式消息中间件，目前已经成为各大互联网公司的主流解决方案之一。本文将介绍 RocketMQ 的底层实现原理，以及如何使...

set “JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%”

conf目录下新建一个配置文件conf/namesrv.properties，文件内容为：

创建Topic使用的命令 mqadmin updateTopic： .\mqadmin updateTopic Java HotSpot(TM) 64-Bit ...

首先在RocketMQ 官网下载二进制安装文件： http://rocketmq.apache.org/dowloading/releases/

以下全部操作在的目录在：/etc/rocketmq, 并且Namesrv、Broker、Dashboard在同一个机器上

RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。

宿主机需要远程访问虚拟机的rocketmq服务和web服务，需要开放相关的端口号，简单粗暴的方式是直接关闭防火墙

有位工作五年的小伙伴在面试的时候被问到RocketMQ的分布式事务实现原理。他说他只知道RocketMQ能够支持事务，但是没有了解过它的事务实现原理。

本文章我们将通过一些实际的案例，引出解决方案，并实际通过代码来实现。通过本节的学习，你可以确切的掌握实际编码能力。 本文选自北京大学出版社的《分布式中间件核心原...

集群模式下，每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列，所以它们才能针对对应的队列做循环拉取消息的处理，以下是消费者客户端和broker通...

master和slave都可以提供读服务，但是只有master允许做写入操作，slave仅从master同步数据并不断上报自己的同步进度（slave自己的物理m...