java开发之RocketMQ单机环境搭建
【40专题共319套视频课程】40专题Java互联网架构师从0到1架构演进（100万行代码实操）大量企业级项目实战课程学架构，从0到1晋升大厂P6/P7/P8百万年薪架构师以项目实战为驱动/分布式/高并发/微服务/性能优化视频教程
【40专题共319套技术包含】：从0到1架构演进（100万行代码实操）大量企业级项目实战课程学架构。软件设计，架构设计，亿级流量并发，建立架构思维，设计模式，算法精讲，源码剖析，云原生，微服务，线上故障解决，性能优化，领域驱动，分布式/高并发事务解决方案，高可用，分库分表，Web安全，物联网，游戏开发，大厂面试，Spring全家桶，数据库，中间件，JVM虚拟机，部署落地，内存分析，代码规范，编程思想，高效编程，线上故障解决，性能监控，中间件，负载均衡，金融架构，缓存架构，核心原理，服务器，网络编程，Java支付全家桶，小程序，微信生态，权限框架，CRM客户管理，全文检索，日志分析，验证码识别，滑块识别，音视频编程，直播系统 ，WebRTC流媒体，FFmpeg音视频，Web安全，漏洞分析，渗透测试，工作流，UML系统，物联网，智慧农业系统，计算机编程，内存知识，缓冲区溢出，面试高频真题，百万年薪职业规划，数据分析，大数据，区块链，PMP项目管理，IT项目经理，12306售票系统，商业级电商系统，电商秒杀系统，外卖项目，网约车项目，金融理财系统，微信点餐系统，在线协同办公项目，酒店管理系统，新闻博客管理系统，权限控制项目，在线教育系统，OA工作流系统，单节点系统，分布式系统，容器微服务，扩展性，复用性，架构师的36专项训练，架构师8大核心-SpringBoot，SpringCloudAlibaba，Spring5，SpringMVC，SpringAop，SpringSession，SpringSecurity，SpringData，JavaWeb，Mybatis，JDK，Dubbo3，DDD，Service Mesh，Istio，K8s，Devops，Docker，Jenkins，Kubeshere，Mysql，Oracle，Redis，Sharding-JDBC，ShardingSphere，Nginx，Tomcat，Netty，Nio，Shiro，SpringSecurity，CRM，Elastic Stack，，ElasticSearch，IDEA，Git，Maven，Activiti7，CPU Cache，Solr，SSO，CAS，OA，Ehcache，MemcachedMycat，Kafka，MyBatisPlus，Activemq，RabbitMQ，Zookeeper，JVM，WebFlux，GateWay，Linux，Shell，Nosql等技术视频课程。。。
40专题共319套资源介绍：
1、【40专题共319套包含】：全套完整高清，视频课程+配套源码和资料齐全，共319套完整系统学习的课程，冲击40~80万年薪；
2、【40专题共319套包含】：掌柜花了半年多时间+大量金钱整理出这个套餐，319套都是全网当下最高质量的课程，用户需求最多最火的课程；
3、知识也是需要投资的，有投入才会有产出（投入产出比是几百上千倍），如果有心的朋友会发现，身边投资知识的大都是技术经理或者架构师，工资一般相对于不投资的也要高出很多；
笔者单机环境搭建过程参照：Quick Start-github-alibaba/RocketMQ
本篇文章为Quick Start的解释和补充，为了您更好的理解，请参照Quick Start阅读
传送门：https://github.com/alibaba/RocketMQ/wiki/quick-start
作者：Nick
安装环境
您需要安装以下软件：
64位操作系统，最好有Linux / Unix / Mac;
Maven 3.x
Git
screen(方便后台运行服务，不安装也可以)
笔者环境：centos7 通过yum一键安装，首先保证联网，ping通
yum install git // 安装git yum install java //安装JDK // 安装maven，如果执行yum install apache‐maven提示报错，输入第一行命令‐wget wget http://repos.fedorapeople.org/repos/dchen/apache‐maven/epel‐apache‐maven.repo ‐O /etc/yum.repos.d/epel‐apache‐maven.repo yum ‐y install apache‐maven yum install screen // screen安装
yum默认安装的jdk是open jdk，经笔者测试open jdk同样可用，只要保证jdk唯一就行。
建议maven和jdk统一采用yum安装，因为maven依赖java环境，如果环境为oracle jdk而yum默认安装的
maven依赖的是open jdk，后面会遇到冲突问题。
screen的作用是方便后台运行namesrv或broker服务，其他文章里时常可以遇到 nohup 命令，或者 ./xx服务
& 都是类似的作用。
Clone & Build
打开终端，去某个有权限创建文件和文件夹的地方
1. git clone https://github.com/alibaba/RocketMQ.git
2. cd RocketMQ
3. bash install.sh
耐心等待，安装成功后可以看到devenv文件夹，内含所有必须的文件和库。其实这个文件是
/RocketMQ/target/alibaba-xxxx的快捷方式
环境变量
确保正确设置以下环境变量：JAVA_HOME
jdk环境会对安装造成很大影响，请保证单一jdk使用环境
现在设置ROCKETMQ_HOME环境变量：
cd devenv //进到devenv文件夹 echo "ROCKETMQ_HOME=`pwd`" >> ~/.bash_profile //将当前路径赋予全局常量写到.bash_profile中，方便后面 调用 使新环境变量生效： source ~/.bash_profile
启动RocketMQ name server和broker
在devenv目录下 cd bin
启动Name Server服务(前文比喻的信号塔)
screen bash mqnamesrv
或者在bin目录，直接使用 ./mqnamesrv &
如果您看到 The Name Server boot success. serializeType=JSON ，这意味着名称服务器成功启动。按 Ctrl +
A ，然后按 D 断开会话。
启动Broker服务
screen bash mqbroker ‐n localhost:9876
//‐n 是mqbroker服务一个可选参数，意为选择nameserver地址，此处默认本机ip，端口9876
如果看到如下输出：
broker[xxxxx-Lenovo，172.30.30.233:10911]启动成功。 serializeType = JSON和名称服务器是localhost：
9876
表示Broker成功启动，Broker默认的端口10911，可以在broker.properties中修改
您还可以检查日志文件以验证如下：
tail ‐f ~/logs/rocketmqlogs/broker.log
检查是否有类似于续集文本的心跳事件：
2016-xx-xx xx:xx:xx INFO BrokerControllerScheduledThread1 – 注册broker到名称服务器localhost：9876
OK
还可以输入命令 jps 查询当前java进程，此时应该可以看到NamesrvStartup,BrokerStartup，说明上述两个服务
成功启动了
Send & Receive Messages
在发送/接收消息之前，我们需要告诉客户端名称服务器所在的位置。为了简单起见，我们使用环境变量
NAMESRV_ADDR ，（producer/consumer初始化时会调用NAMESRV_ADDR，设置成环境变量或者代码里直接声明
都可以）
export NAMESRV_ADDR = localhost:9876
现在我们准备好发送/接收消息。
bash tools.sh com.alibaba.rocketmq.example.quickstart.Productcer
你会看到几百条消息被发送给broker。
要使用刚刚在上一步中发送的消息，
bash tools.sh com.alibaba.rocketmq.example.quickstart.Consumer
到此单机环境搭建成功，并成功启动了Producer和Consumer进行了消息收发的测试。
下面开始划重点
nameserver端口默认为9876
broker监听端口默认为10911
接着（一）RockeMQ初步认知中的介绍的四个角色，根据本章实践复习和补充下：
Producer：
一般由业务系统产生消息，通过topic来标示
存在Producer Group的概念（后文涉及）
Consumer：
有两种实现方式，一种push Consumer，第二种是 pull Consumer。
本章启动的示例Consumer为push consumer。在consumer对象注册一个listener接口，一接收到消息，
consumer对象立刻回调 Listener方法。
push Consumer和pull Consumer的区别简单理解：两者基本原理相同，push是封装好了，傻瓜调用。pull
需要自主实现，由应用控制。（深入研究后再行补充）
存在Consumer Group的概念（后文涉及）
Broker：
消息中转角色，负责存储消息，转发消息。
拥有Master、slave（主备）的概念，主备有同步复制、异步双写功能来保持数据同步（未深研）。标识：
Master的BrokerId 为 0 ，Slave的BrokerId 非0。
部署模式：
单Master无Slave（脆弱）
单Master多Slave（单点故障就瘫，开源版无主备切换功能）
多Master无Slave（无单点故障，线上生产常用模式）
多Master多Slave（无单点故障）
Broker 与 Name Server 集群中的所有节点建立长连接，定时（心跳）注册 Topic 信息到所有 Name
Server。
Name Server：
无状态节点，可集群部署，节点之间无任何信息同步（Broker与每个namesrv连接，可以保证信息同步性）
FAQ
1. 本地网络连接正常，（linux）联网失败，ping不通？
解决方案：修改 /etc/resolv.conf dns 文件 添加 nameserver 8.8.8.8 && 8.8.4.4
2. Directory ‘/var/run/screen’ must have mode 777，执行screen命令提示权限不足？
现象描述：
解决方案： chmod ‐R 777 /var/run/screen 赋予报错中的文件路径以777权限， ‐R 对其子文件也生效
3. 启动 mqnamesrv / mqbroker服务报错，显示内存不够，需大于2G？
现象描述：
“VM warning: INFO: OS::commit_memory(0x00000006c0000000, 2147483648, 0) faild; error=’Cannot
allocate memory’ (errno=12)”
解决方案：修改 /RocketMQ/devnev/bin/ 下的服务启动脚本 runserver.sh 、 runbroker.sh 中对于内存的
限制， 改成如下示例：
JAVA_OPT=”${JAVA_OPT} ‐server ‐Xms128m ‐Xmx128m ‐Xmn128m ‐XX:PermSize=128m ‐
XX:MaxPermSize=128m”
4. UseCMSComactAtFullCollection is deprecated and will likely be removed in a future
release.java.net.BindException: 地址正在使用？
问题原因：上述情况是系统存在多个Jdk同时使用导致的，如本文开头安装maven时讲到的冲突问题
解决方案：删除/停止多余jdk，保证系统使用唯一jdk源。
5. 启动Broker遇到提示cannot stat ‘/root/rmq_bk_gc.log’:No such file or directory：
cp:cannot stat ‘/root/rmq_bk_gc.log’:No such file or directory
OpenJDK 64‐Bit Server VM warning: Cannot open file /root/tmpfs/logs/gc.log due to No such
file or directory
解答：经测试，上叙情况不会影响Broker的正常启动，出现此提示请耐心等待Broker服务启动。如图所示：
6. 待补充，欢迎留言
常见问题FAQ
