#
RocketMQ 是一款开源的消息中间件，采用Java实现，设计思想来自于Kafka（Scala实现）,在具体设计时体现了自己的选择和需求，具体差别可以看RocketMQ与Ka
前面我也跟大家讲述了 RocketMQ 读写分离的规则，但是你可能会问，主从服务器之间的消费进度是如何保持同步的？下面我来给大家解答一下。如果消费者消费模式不同，也会有不同的保存方式，消费者端的消息消
RocketMQ介绍概述Apache RocketMQ是一个具有低延迟、高性能和高可靠性、万亿级容量，同时具备灵活的、可伸缩性强的分布式消息流处理平台，它由四个部分组成:name servers, b
如果从gitub上下载源码需要maven编译比较麻烦，这里有现成的可以直接运行的：rocketMQ_4.1.0 编译好可以直接运行的版本：链接：https://pan.baidu.com/s/11MT
参考http://www.linuxidc.com/Linux/2015-10/124112.htm 192.168.1.201vi /usr/local/tomcat/webapps/appServ
一. 前言 RocketMQ支持消息消费失败后重新消费，具体代码如下： /* * Register callback to execute on arrival of messag
准备材料：Linux操作环境( 假设两台服务器ip为：192.168.74.130和192.168.74.131)；RocketMQJDK 1.8+分别修改两台服务RockerMQ的配置文件，路径为：
背景 公司很多业务在使用RocketMQ，前期业务量小，没啥问题，也没有太关注集群的可用性这块，所以全公司的业务公用一个集群，随之公司的业务量增加，业务对RocketMQ集群依赖越来越重，开始思考集群
微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。 前段时间有个朋友向我提了一个问题，他说在搭建 RocketMQ 集群过程中遇到了关于消费
