Apache RocketMQ™是一个开源的分布式消息传递和流数据平台。下面记录在CentOS 7 安装 RocketMQ 4.4 及相关的注意事项。
下载地址：https://www.oracle.com/java/technologies/javase/javase-jdk8-downloads.html
PS：终于安装成功了，2主2从。下一节说说细节和如何测试rocketmq。特别注意的是在broker的properties文件我都在源码上传的。但是里面有个属性一定要注意：默认不配置brokerIP1和brokerIP2时，都会根据当前网卡选择一个IP使用，当你的机器有多块网卡时，很有可能会有问题。brokerIP1一定要填写IP不要填写别名。否则java连接就会出现RemotingTooMuchRequestException: sendDefaultImpl call timeout；
修改nameserver和broker的启动参数,对于2c8g机器,nameserver建议1g,broker建议4g。
一、RocketMQ安装环境 64bit linux 64bit jdk1.8+ maven 3.2.x git（不一定需要） 本文安装环境为centos7.2、jdk1.8.0_144、maven-3.5.3，软件默认存放目录为/usr/local 二、安装RocketMQ的准备条件 1、安装jdk1.8 如果是采用centos7+，它默认已经安装jdk1.8了，这个步骤可以忽略 1.1 解压jdk包 tar xvf jdk-8u144-linux-x64.gz 1.2 设置环境变量 cd /etc v
RocketMQ 是一款分布式消息中间件，最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统，满足线上海量消息堆积的需求， 在 2016 年底捐赠给 Apache 开源基金会成为孵化项目，经过不到一年时间正式成为了 Apache 顶级项目。 早期阿里曾经基于 ActiveMQ 研发消息系统， 随着业务消息的规模增大，瓶颈逐渐显现，后来也考虑过Kafka，但因为在低延迟和高可靠性方面没有选择，最后才自主研发了 RocketMQ， 各方面的性能都比目前已有的消息队列要好，RocketMQ 和 Kafka 在概念和原理上都非常相似，所以也经常被拿来对比；RocketMQ 默认采用长轮询的拉模式， 单机支持千万级别的消息堆积，可以非常好的应用在海量消息系统中。 本文分为三部分，如下图所示：
包推荐使用 git 直接拉下来。没装 git 就 wget 去拉。需要 maven 来编译 rocketmq，实际上只要装好 maven 即可，其他不用操作 maven。
RocketMQ有一个对其扩展的开源项目 ocketmq-console ，如今也提交给了 Apache ，
自定义group id和artifact id，完成maven project的创建。
此命令为部署 Redis 集群，如果本地的 docker 没有 redis 的镜像，那么他会先自动下载再部署。
rocketmq是阿里巴巴开源的一款分布式的消息中间件，他源于jms规范但是不遵守jms规范。对于分布式只一点，如果你了用过其他mq并且了解过rocketmq，就知道rocketmq天生就是分布式的，可以说是broker、provider、consumer等各种分布式。
安装好maven后，修改conf目录下的settings.xml文件，配置用户名和密码，找到<server> </server>标签添加nexus私服的用户名跟密码
RocketMQ出了4的版本，而且本身这个mq有事务消息，在分布式的场景中有很好的启发性和作用，而且本身它也是阿里开源到apache的一个项目，从出身还是实力来说都很不错的。
一、RocketMQ基础知识介绍 Apache RocketMQ是阿里开源的一款高性能、高吞吐量、队列模型的消息中间件的分布式消息中间件。RocketMQ具有以下特点： 上图是一个典型的消息中间件收发
前言 本文笔者是一波三折啊，很多人像我一样第一次在springboot里搞rocketmq的，遇到各种麻烦，我也是一样，就比如：
目前很多互联网公司的系统都在朝着微服务化、分布式化系统的方向在演进，这带来了很多好处，也带来了一些棘手的问题，其中最棘手的莫过于数据一致性问题了。早期我们的软件功能都在一个进程中，数据的一致性可以通过数据库本地事务来加以控制。而在分布式架构下，原本比较完整的本地功能可能被拆分成了多个独立的服务进程。与之前相比，同样一笔业务订单此时可能会经历很多服务模块的处理，调用链路会变得很长，例如某电商平台，一笔购物订单可能会经过：商品中心、订单、支付、物流等多个服务的调用，而这可能还只是比较粗粒度的划分，某些比较大型的服务，如支付系统，可能本身又会按照分布式的架构拆分成多个微服务，所以整个业务的调用链路会变得更加冗长。 而这不可避免的就会产生数据不一致的问题，为了实现业务上的最终一致性，功能比较独立的系统，如订单系统与支付系统就会通过额外的业务逻辑设计来确保彼此之间的最终一致性，如订单系统会通过订单的支付状态来保持与支付系统的数据一致，而支付系统则会提供支付状态查询接口，或者实现最大可能的主动回调功能，来确保二者数据状态的最终一致。此外可能还会通过日终的订单对账来发现不一致的数据，并进行数据校正。 但是这些都只是业务逻辑上的手段，对于某些内部服务之间的调用，如果可以通过分布式事务解决方案来加以保证的话，其实是可以大大减少一些不必要的复杂业务逻辑的。实际上，目前市面上能够提供分布式事务解决方案、又比较成熟的开源技术框架比较少，而RocketMQ在4.3.0之后的版本提供了事务消息的功能，因为RocketMQ本身拥有比较多的生产实践的关系，所以这一功能备受关注，作者所在的公司也有一些实践。 以此为契机，为了给大家关于分布式事务一个比较清晰的认识，这里我打算以RocketMQ的事务消息功能为示例，来相对全面的总结下分布式事务的内容。本篇文章的主要内容，是先介绍如何搭建一套生产级的RocketMQ消息集群，以此准备下试验环境。在下一篇《【分布式事务】基于RocketMQ的分布式事务实现》会整体介绍下分布式事务的概念和原理，并做一些代码级的试验。
下载地址： https://github.com/apache/rocketmq-dashboard
早晨起来，听着杰伦的新歌《等你下课》，轻快的旋律，动听的曲调，让我回想18岁的我........
The following softwares are assumed installed:
在 47.xx.xx.xx 和 39.xx.xx.xx 上分别部署一个 Name Server 和 Broker 主节点，这里不搭建从节点。也就是官网介绍的 2m-noslave 构建模式。
本文不再赘述如何去fork代码，如何去git clone代码，笔者认为多数读者都会这些基本操作，如果正在阅读的您尚未掌握这些技巧，可以去查看一下其他博主的文章，正确把RocketMQ源码拉取到本地后再来阅读该文章。 Apache RocketMQ是一个基于Java语言开发的消息中间件，构建工具采用的是常用的maven，基本的代码结构如下图1-1所示：
Producer：消息生产者，负责产生消息，一般由业务系统负责产生消息 Consumer：消息消费者，负责消费消息，一般是后台系统负责异步消费 Push Consumer：Consumer的一种，需要向Consumer对象注册监听 Pull Consumer：Consumer的一 种，需要主动请求Broker拉取消息 Producer Group：生产者集合，一般用于发送一类消息 Consumer Group：消费者集合，一般用于接受一类消息进行消费 Broker：MQ消息服务（中转角色，用于消息存储与生产消费转发）
个人拉取的版本为 4.9.4，因为时效性未来版本有些代码可能会被改进，所以要注意版本问题。
最近溪源在学习dubbo的相关API机制实践，如：负载均衡、服务分组、本地存根等等…一方面是dubbo官网文档给出了详细的介绍和demo，另一方面由于自己时间方面原因(自己现在也需要学习各种技术栈)，没有整理相关实践总结。但是后面一定会整理出相关的实践总结。 今天主要给大家介绍一下rocketmq源码本地化构建，也是由于溪源项目中暂时未使用该技术栈，如果自己想要学习和精进，那只能阅读一下源码和了解相关机制啦！ 好啦好啦～不再絮叨啦，无实际作用，下面进入今天的正题。
文代码：https://gitee.com/hong99/spring/issues/I1N1DF
RocketMQ5.0中的几个角色NameServer、Broker 和 Proxy，它们的作用如下：
nohup: 在命令前面加nohup命令可以在退出shell之后继续执行当前运行的线程
在生产环境中为了保障集群无单点故障问题，保证高可用性，需要采用双主双从模式来构建RocketMQ集群。双主双从模式部署需要四台机器，两台机器分别部署Broker-Master & NameServer，另外两台机器分别部署Broker-Slave & NameServer。
一、首先准备linux环境 使用了两个虚拟机系统 版本为Centos 7 ip地址固定为192.168.194.128 192.168.194.129
RocketMQ主要有四大组成部分：NameServer、Broker、Producer、Consumer。
RocketMQ是一个轻量级、高可用、低延时的消息中间件，能实现消息的存储，消息的失败重试，批量消息处理，延时消息处理等特性，在各种消息中间件中表现优异。
以master01为例，首先停止所有rocketmq进程，然后删除日志和存储信息。所有服务器都执行该操作。
RocketMQ是阿里巴巴在2012年开源的分布式消息中间件，目前已经捐赠给Apache基金会，已经于2016年11月成为 Apache 孵化项目，相信RocketMQ的未来会发挥着越来越大的作用，将有更多的开发者因此受益。 本文仅对RocketMQ的简单实用做入门性介绍，不对RocketMQ的底层原理进行深入介绍，后续文章将对RocketMQ的原理做详细介绍。
我们知道，正常RocketMQ部署顺序：启动NameServer、启动Broker、启动生成、启动消费者、发送消息，消费消息。
进入bin目录，建议修改runbroker.sh和runserver.sh默认JVM的大小，防止内存不足启动失败。参考设置如下
单机版RocketMQ搭建详见：Centos7.6搭建RocketMQ4.8全纪录
下载 4.2.0 源代码版本地址：http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip
这是因为掌握了整体架构，可以让我们迅速了解各个方面的特性，并且可以方便我们后续快速定位功能模块对应的代码文件。话不多说，我们开始看RocketMQ目录结构。
在发送/接收消息之前，我们需要告诉客户端名称服务器的位置。RocketMQ 提供了多种方法来实现这一点。为简单起见，我们使用环境变量NAMESRV_ADDR
RocketMQ是由阿里捐赠给Apache的一款分布式、队列模型的开源消息中间件，经历了淘宝双十一的洗礼。
从今天起，开始Rocket MQ系列。这位MQ经过了双11这种变态级别冲击的洗礼，有稳定出色的表现，作为我们这样的技术人员很有必要研究一下它。
我们需要把RocketMQ运行起来,它包含两个组件，NameServer和Broker,把这两个组件运行起来就可以了，可以二进制运行，或者把源码拉下来运行，大家参考一下官方文档就可以运行起来了，这里我讲解一下拉取源码的方式运行。 先将distribution/conf目录，复制到源码的目录
“ RockeMQ是阿里巴巴自主研发的消息中间件，实现业务削峰，分布式事务等，已捐献给Apache，成为MQ家族的重要成员。”
安装条件 ---- 64位操作系统，建议使用 Linux / Unix / Mac; 64位JDK 1.8+; Maven 3.2.x 下载和构建 ---- 从 https://www.apache.
在开始分享 https://github.com/apache/rocketmq-spring 项目（RocketMQ 集成到 Spring Boot 中），我们先恶趣味的看一段历史：
MQ(Message Queue)是一种跨进程的通信机制，用于传递消息。通俗点说，就是一个先进先出的数
继我上一篇博客后 分布式消息队列RocketMQ学习教程① 上一篇博客最主要介绍了几种常用的MQ，所以本博客再简单介绍一下RocketMQ的原理和简单的例子，基于Java实现，希望可以帮助学习者
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
