导入IDEA，可在命令行执行mvn compile一下，保证源码能够正确编译。本次我使用的master分支的版本-4.8.0。下面我们开始准备启动Namesrv。
案例ROCKETMQ版本 4.7 1. 设置环境变量ROCKETMQ_HOME为解压目录 2. 设置JAVA_HOME为JRE1.8版本路径 3. 修改nameserver java启动参数 %ROCKETMQ_HOME%\bin\runserver.cmd if not exist "%JAVA_HOME%\bin\java.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! & EXIT
个人拉取的版本为 4.9.4，因为时效性未来版本有些代码可能会被改进，所以要注意版本问题。
最开始的mqnamesrv.sh脚本获取环境变量的部分看不懂其实没啥影响，大略有个印象即可，当然可以截取部分的命令到Linux运行测试一下就明白了，比如准备环境变量等等，最后一句话比较关键。
假如你没有云主机也没搭建本地虚拟机，那么推荐使用VMware Workstation Player 来搭建自己的虚机，Virtual Box 也不错，这两款体积都比较小，适合个人开发。
Please set the ROCKETMQ_HOME variable in your environment!
最近有个项目需要基于docker部署一个rocketmq集群。本文主要记录笔者如何根据官方工具自己动手制作最新版本rockermq的docker镜像。所谓官方工具可以通过github网站检索，具体地址：
我们知道，正常RocketMQ部署顺序：启动NameServer、启动Broker、启动生成、启动消费者、发送消息，消费消息。
核心代码，如下： public static NamesrvController createNamesrvController(String[] args) throws IOException, JoranException { // 设置版本号为当前版本号 System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION)); //Package
继 [【RocketMq】NameServ启动脚本分析（Ver4.9.4）] 之后又来看看Broker的脚本。总体上来看大差不差，以阅读核心的配置部分调优为主。
最近在倒腾 RocketMQ 消息队列，小卷了下 RocketMQ 的源码，本篇会带着大家一起看下如何配置好调试源码的环境。
这是因为掌握了整体架构，可以让我们迅速了解各个方面的特性，并且可以方便我们后续快速定位功能模块对应的代码文件。话不多说，我们开始看RocketMQ目录结构。
本文不再赘述如何去fork代码，如何去git clone代码，笔者认为多数读者都会这些基本操作，如果正在阅读的您尚未掌握这些技巧，可以去查看一下其他博主的文章，正确把RocketMQ源码拉取到本地后再来阅读该文章。 Apache RocketMQ是一个基于Java语言开发的消息中间件，构建工具采用的是常用的maven，基本的代码结构如下图1-1所示：
mq有很多，近期买了《分布式消息中间件实践》这本书，学习关于mq的相关知识。mq大致有有4个功能：
进入rocket的github官方地址：https://github.com/apache/rocketmq 可以看到当前最新的 releases 版本是4.9.4，下载最新的源码包到本地。
NameServer是一个非常简单的Topic路由注册中心，其角色类似Dubbo中的zookeeper，支持Broker的动态注册与发现。主要包括两个功能：
进入runserver.sh 和 runbroker.sh，修改JAVA_HOME指定位置
我们熟知的几种常见的消息队列组件，比如Kafka，ActiveMQ，RabbitMQ等，都是一种基于主题的发布订阅机制，RocketMQ也正是基于这种机制实现的消息服务。消息生产者（Producer）将生产好的消息发布到某个主题，该主题下的消息在消息服务器（Broker）中进行传送或存储，由消费者（Consumer）进行订阅主题，从消息服务器中获取到消息后进行消费。消费者获取消息的方式通常有两种，一种是主动去消息服务器拉取消息（Pull Message），另外一种是由消息服务器推送消息（Push Message）给消费者。这种主题的发布订阅机制应用到分布式系统中，成功解耦了生产者和消费者。既然是分布式系统，那么常常存在分布式系统问题，比如某个消息服务器宕机了，生产者是如何感知这台消息服务器宕机了，从而避免将消息发送到这台消息服务器上，消费者是如何感知这台消息服务器宕机了，从而避免从这台消息服务器上拉取消息的呢？且这台宕机的消息服务器是如何从消息服务器实例列表中被剔除的呢？这一切都将归功于NameServer，它的诞生让动态感知、动态剔除、负载均衡成为可能。 图1-1是RocketMQ常见的物理部署图（图片来源：百度图库），采用的部署方式2m-2s（2Master，2Slave），本小节将根据此图阐述RocketMQ基本的流程原理，后面的小节将深入源码中，从源码中来验证基本流程原理。
docker compose 是 docker 的容器编排工具，它是基于 YAML 配置，YAML 是一种配置文件格式，支持传递环境变量，但是对于复杂的容器编排显得力不从心。
今天，带来一篇搭建RocketMQ单机环境的文章，为后面的分布式事务专栏做准备。RocketMQ是阿里巴巴开源的一款高性能分布式消息中间件，有关RocketMQ的详细讲解，后面会单独开设一个RocketMQ专栏。这里，先简单介绍一下搭建RocketMQ的单机环境，为分布式事务的介绍做准备。接下来，进入主题。
一次RPC变成两次RPC、内容存储和择机投递；基于消息的通信模式，从关注处理到关注通知。
本来是想写RocketMQ系列博文第一篇RocketMQ简介，大致内容包括介绍什么是RocketMQ以及教大家如何安装RocketMQ的。但是呢？有网友说，学习RocketMQ官网特别难。
「单Master模式」风险较大，「一旦Broker重启或者宕机时，会导致整个服务不可用」。不建议线上环境使用，可以用于本地测试。
本文尝试从Apache RocketMQ的简介、主要组件及其作用、3种部署模式、Controller集群模式工作流程、最佳实践等方面对其进行详细分析。希望对您有所帮助！
1.由于rocketmq需要依赖nameServer，类似于zookeeper。首先启动时，配置好NamesrvStartup的环境变量信息，也即rocketmq的ROCKEMQ_HOME与你的项目对应。接着就可以启动了。
发现公司这边的消息中间件采用了aliyun的RocketMQ服务，熟悉开源的同学都知道，RocketMQ是国内最早一批捐献Apache并成功毕业的项目。架构设计参考了kafka的模式，所以如果你了解kafka的架构，对于RocketMQ就可以轻车熟路了，虽然参考了kafka，但是RocketMQ也有很多的升级，比如Broker的注册和发现就采用了内部的NameServer，没有引入更多的第三方依赖，而且添加了诸如消息回溯、事务消息、延时消息等特色功能。由于之前没有接触过RocketMQ（之前一直用的kafka和RabbitMQ），准备研究一番，也为了后面集成spring boot metrics监控RocketMQ客户端信息做准备。研究一个开源项目，最好的方法就是Debug，所以记录下本地搭建RocketMq的调试环境过程
RocketMQ入门案例【面试+工作】 0 RocketMQ简介 0.1 介绍 RocketMQ是一个消息中间件。消息中间件中有两个角色：消息生产者和消息消费者。RocketMQ里同样有这两个概念，消息生产者负责创建消息并发送到RocketMQ服务器，RocketMQ服务器会将消息持久化到磁盘，消息消费者从RocketMQ服务器拉取消息并提交给应用消费。 0.2 特点 RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点： 支持严格的消息顺序 支持Topic与Queue两种模式 亿级消息堆积能
set “JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%”
RocketMQ在4.4.0版本开始支持ACL。ACL是access control list的简称，俗称访问控制列表。访问控制，基本上会涉及到用户、资源、权限、角色等概念，那在RocketMQ中上述会对应哪些对象呢？
这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。
在RocketMQ官网上找到下载RocketMQ4.8.0的链接，下载和解压RocketMQ：
RocketMQ是一个分布式消息队列系统，它最初由阿里巴巴开发并开源。RocketMQ具有高可靠性、高吞吐量、高扩展性和良好的可维护性等特点，被广泛应用于金融、电商、物流、游戏等领域。
一、安装与配置 1、下载 官网：http://rocketmq.apache.org/ 如：rocketmq-all-4.0.0-incubating-bin-release.zip 需要 64bit OS, Linux/Unix/Mac is recommended; 64bit JDK 1.7+; 2、复制到对应目录，linux中解压 复制rocketmq-all-4.0.0-incubating-bin-release.zip到 /opt/rocketmq mkdir /opt/rocketm
最近溪源在学习dubbo的相关API机制实践，如：负载均衡、服务分组、本地存根等等…一方面是dubbo官网文档给出了详细的介绍和demo，另一方面由于自己时间方面原因(自己现在也需要学习各种技术栈)，没有整理相关实践总结。但是后面一定会整理出相关的实践总结。 今天主要给大家介绍一下rocketmq源码本地化构建，也是由于溪源项目中暂时未使用该技术栈，如果自己想要学习和精进，那只能阅读一下源码和了解相关机制啦！ 好啦好啦～不再絮叨啦，无实际作用，下面进入今天的正题。
环境准备 准备两台服务器或者虚拟机 服务器一：192.***.*.31 服务器二：192.***.*.32 部署模式： 2M-2S-SYNC(两主两从同步写) 相关安装包存储路径：/root/svr/
昨天我们已经学习了RocketMQ的一些基本概念，架构设计和各个角色的功能。今天我们来聊聊RocketMQ的集群部署问题，关于RocketMQ的几种集群模式，你都知道吗，或者你们用的是哪一种集群模式呢？
RocketMQ 5.0.0 Namesrv是在4.9.X基础上添加了内嵌Controller实例的功能，其余功能差不多。
RocketMQ是阿里巴巴开源的一个消息中间件，在阿里内部历经了双十一等很多高并发场景的考验，能够处理亿万级别的消息。2016年开源后捐赠给Apache，现在是Apache的一个顶级项目。在阿里内部，RocketMQ 很好地服务了集团大大小小上千个应用，在每年的双十一当天，更有不可思议的万亿级消息通过 RocketMQ 流转。
由于 Local 模式下 Proxy 和 Broker 是同进程部署，Proxy本身无状态，因此主要的集群配置仍然以 Broker 为基础进行即可。
RocketMQ 是一款分布式消息中间件，最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统，满足线上海量消息堆积的需求， 在 2016 年底捐赠给 Apache 开源基金会成为孵化项目，经过不到一年时间正式成为了 Apache 顶级项目。 早期阿里曾经基于 ActiveMQ 研发消息系统， 随着业务消息的规模增大，瓶颈逐渐显现，后来也考虑过Kafka，但因为在低延迟和高可靠性方面没有选择，最后才自主研发了 RocketMQ， 各方面的性能都比目前已有的消息队列要好，RocketMQ 和 Kafka 在概念和原理上都非常相似，所以也经常被拿来对比；RocketMQ 默认采用长轮询的拉模式， 单机支持千万级别的消息堆积，可以非常好的应用在海量消息系统中。 本文分为三部分，如下图所示：
PS：终于安装成功了，2主2从。下一节说说细节和如何测试rocketmq。特别注意的是在broker的properties文件我都在源码上传的。但是里面有个属性一定要注意：默认不配置brokerIP1和brokerIP2时，都会根据当前网卡选择一个IP使用，当你的机器有多块网卡时，很有可能会有问题。brokerIP1一定要填写IP不要填写别名。否则java连接就会出现RemotingTooMuchRequestException: sendDefaultImpl call timeout；
进入bin目录，建议修改runbroker.sh和runserver.sh默认JVM的大小，防止内存不足启动失败。参考设置如下
这次我们来说说我们的RocketMQ的安装和参数配置，先来看一下我们RocketMQ的提出和应用场景吧。
单机模式, 即只有一个Broker, 如果Broker宕机了, 会导致RocketMQ服务不可用, 不推荐使用.
RocketMQ是阿里巴巴开源的分布式消息中间件。支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。它里面有几个区别于标准消息中件间的概念，如Group、Topic、Queue等。系统组成则由Producer、Consumer、Broker、NameServer等。
Producer：消息生产者，负责产生消息，一般由业务系统负责产生消息 Consumer：消息消费者，负责消费消息，一般是后台系统负责异步消费 Push Consumer：Consumer的一种，需要向Consumer对象注册监听 Pull Consumer：Consumer的一 种，需要主动请求Broker拉取消息 Producer Group：生产者集合，一般用于发送一类消息 Consumer Group：消费者集合，一般用于接受一类消息进行消费 Broker：MQ消息服务（中转角色，用于消息存储与生产消费转发）
参考：https://blog.csdn.net/syq8023/article/details/102795056https://www.cnblogs.com/coder-lzh/p/9006048.html
从官方仓库 https://github.com/apache/rocketmq clone或者download源码。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
