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

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

近期在研究各种消息队列方案，为了有一个直观的使用体验，我把Kafka，RocketMQ，RabbitMQ各自部署了一遍，并使用了最基本的生产与消费消息功能。在部署过程中也遇到一些问题，特此记录。本文只适用于没有使用过消息队列，还停留在安装部署阶段的新手用户

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

RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level ca

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

启动脚本的参数改下(虚拟机)1.vim runbroker.sh -server -Xms512m -Xmx512m -Xmn256m2. vim runserver.sh -server -Xms512m -Xmx512m -Xmn126m

本文主要介绍如何将 RocketMQ 集群从原先的主从同步升级到主从切换。首先先介绍与 DLedger 多副本即 RocketMQ 主从切换相关的核心配置属性，然后尝试搭建一个主从同步集群，再从原先的 RocketMQ 集群平滑升级到 DLedger 集群

打开CMD 进入安装 bin 目录下 执行start mqnamesrv.cmd 弹出如下窗口，切勿关闭，说明NAMESERVER 启动成功。#set it false if you don‘t want use dashboard.default tru

Cmd命令框执行进入至‘MQ文件夹\bin’下，然后执行‘start mqnamesrv.cmd’，启动NAMESERVER。成功后会弹出提示框，此框勿关闭。编译成功之后，Cmd进入‘target’文件夹，执行‘java -jar rocketmq-con

前言在分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间产品 RocketMQ 也顺利开源,得到大家的关注。概念MQ简介MQ,Message queue,消息队列，就是指保存消息的一个容器。MQ特

MQ组件是系统架构里必不可少的一门利器，设计层面可以降低系统耦合度，高并发场景又可以起到削峰填谷的作用，从单体应用到集群部署方案，再到现在的微服务架构，MQ凭借其优秀的性能和高可靠性，得到了广泛的认可。这个其实就是数据库事务与MQ消息的一致性问题，简单来讲

MQ组件是系统架构里必不可少的一门利器，设计层面可以降低系统耦合度，高并发场景又可以起到削峰填谷的作用，从单体应用到集群部署方案，再到现在的微服务架构，MQ凭借其优秀的性能和高可靠性，得到了广泛的认可。这个其实就是数据库事务与MQ消息的一致性问题，简单来讲

运行当前最新版本的RockitMQ，必须先安装64bit的JDK1.8或以上版本。bin目录下存放可运行的脚本。在动手开发之前，我们需要了解一下RocketMQ的基本结构。如上图所示，一个正常工作的RocketMQ包括四个部分。正式应用时通常采用集群部署。

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

RocketMQ 的核心，接收 Producer 发过来的消息、处理 Consumer 的消费消息请求、消息的持 久化存储、服务端过滤功能等 。类似微服务中注册中心的服务注册，发现，下线，上线的概念。消息的生成者，最常用的producer类就是Defaul

1.单个 Master 这种方式风险较大，一旦Broker 重启或者宕机时，会导致整个服务不可用，不建议线上环境使用。不需要人工干预。

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

4.比较友好的分布式特性；

分布式消息系统RocketMQ一、消息系统RocketMQ是阿里开源出来的一个消息系统，2011年Linkin开源了Kafka，淘宝中间件团队在对Kafka做过充分Review之后 ，由于kafka是用scala开发的，于是重新用Java语言编写了Rock