RocketMq producer 在发送一条消息时候，从 producer --nameSrv -- Broker 中间经过了什么样子的数据交互。从NameSrv 中获取topic 配置的相关信息，比如 broker 地址，队列数 之类的。

RocketMQ是阿里出品的一款开源的消息中间件，让其声名大噪的就是它的事务消息的功能。在企业中，消息中间件选择使用RocketMQ的还是挺多的，这一系列的文章都是针对RocketMQ的，咱们先从RocketMQ的一些基本概念和环境的搭建开始聊起。Rock

然后执行‘start mqnamesrv.cmd’，启动NAMESERVER。成功后会弹出提示框，此框勿关闭。#set it false if you don‘t want use dashboard.default true. #set the mess

下载解压后配置一下系统RocketMQ环境变量，我们假设解压至C:\File\rocketmq：。我们再开一个cmd命令行，执行如下指令，切记不要关闭窗口：。下载的架包中已经提供了可视化界面的包，如果没有的话可以单独下载：

RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。发生异常的时候，需要注意的是发送的时候并不是catch所有的异常，只有内部异常才会catch住并重试。每次重试都会重新进行负载均衡，重新选择MessageQue

通过查看源码，消息消费的状态，有2种，一个是成功，一个是失败&稍后重试。在启动broker的过程中，可以观察到上图日志，你会发现RECONSUME_LATER的策略：如果消费失败，那么1S后再次消费，如果失败，那么5S后，再次消费，…直至2H后如果

创建存放压缩包的文件夹,上传压缩包到改文件夹下。按照命令执行就好了。runserver.sh文件修改,将第一行注释更改为。#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数。#删除文件的时间节点，默认凌晨4点

什么是消息队列？Broker与Namesrv的心跳机制：单个Broker跟所有Namesrv保持心跳请求，心跳间隔为30秒，心跳请求中包括当前Broker所有的Topic信息。假如某个Broker宕机，意味生产者最长需要30秒才能感知到。消费者启动时需要指

Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。同步和异步方式均需要Broker返回确认信息，单向发送不需要。代理服务器在RocketMQ系统中负责接

* Max re-consume times. -1 means 16 times.* If messages are re-consumed more than {@link #maxReconsumeTimes} before success, it'

rocketmq-client-4.5.2-sources.jar!* Means connect to private IDC cluster.LOCAL,* Means connect to Cloud service.CLOUD,rocketmq-c

rocketmq这么复杂的东西，没有运维工具可搞不定啊。哈哈，别急，官方提供了一个WEB项目，可以查看rocketmq数据和执行一些操作。下面是成功页面，cluster查询broker集群的tps和出队入队情况。connection查询生产则和消费者的连接

最近学习使用 rocketmq，需要搭建 rocketmq 服务端，本文主要记录 rocketmq 搭建过程以及这个过程踩到的一些坑。此外，由于 rocketmq 需要部署 broker 与 nameserver ，考虑到分开部署比较麻烦，这里将会使用 d

消息队列

用于异步处理，比如A服务做了什么事情，异步发送一个消息给其他B服务。用于削峰，有些服务(秒杀)，请求量很高，服务处理不过来，那么请求先放到消息队列里面，后面按照能力处理，相当于蓄水池。应用解耦、消息通讯等等总之MQ是可以存放消息并转发消息的中间件，场景取决

前言在之前的工作中，微服务框架使用的是springcloud，消息中间件使用的rocketmq，这段时间看到阿里出了spring cloud alibaba集成了rocketmq，出于好奇，写了个demo. 一些概念官方对 Spring Cloud Str

磁盘存储文件-rw-r--r-- 1 root root 0 Jan 18 11:54 abort. -rw-r--r-- 1 root root 4.0K Mar 14 17:39 checkpoint. drwxr-xr-x 2 root roo

为了方便大家选型，整理一份RocketMQ与Kafka的对比文档，文中如有错误之处，欢迎来函指正。同时同步Replication也比Kafka异步Replication更可靠，数据完全无单点。RocketMQ单机写入TPS单实例约7万条/秒，单机部署3个B

因为下载的rocket-console是Maven项目，所以并不能直接使用tomcat发布，需要先导入到eclipse中打包，然后发布war包

执行下边的命令或者执行install.bat对maven熟悉的一眼就知道是执行clean package install assembly等操作。