AI 助理
备案控制台
开发者社区 阿里云开发者学堂 文章 正文

RocketMQ 环境搭建|学习笔记

2022-11-23 457
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
日志服务 SLS，月写入数据量 50GB 1个月
简介： 快速学习 RocketMQ 环境搭建

开发者学堂课程【全面讲解 Spring Cloud Alibaba 技术栈（知识精讲+项目实战）第四阶段：RocketMQ 环境搭建】学习笔记，与课程紧密联系，让用户快速学习知识。

课程地址：https://developer.aliyun.com/learning/course/686/detail/11903

RocketMQ 环境搭建

内容介绍：

一、RocketMQ 入门

二、RocketMQ 环境搭建


一、RocketMQ 入门

RocketMQ 是阿里巴巴开源的分布式消息中间件，现在是 Apache 的一个顶级项目。在阿里内部使用非常广泛，已经经过了"双11"这种万亿级的消息流转。


二、RocketMQ环境搭建

接下来我们先在 linux 平台下安装一个 RocketMQ 的服务（先准备好一台linux服务器）

1、环境准备

（1）下载 RocketMQ

http://rocketmg.apache.org/releasenotes/reease-notes-4.4.0/

访问官方地址，里面有最新的发行版4.6.0点进去，下面有下载地址源码包、二进制，可以根据自己的兴趣选择，如果想学习可以选源码包，为了安装服务用的是二进制包，这是最新的4.6.0的，课堂上使用的4.4.0。

image.png

image.png

切一下版本

image.png

（2）环境要求

①Linux64位操作系统

②64bitJDK1.8+

2、安装 RocketMQ

（1）上传文件到 Linux 系统

[root@heimarocketmq]#1s/usr/1ocal/src/

rocketmq-a11-4.1.0-bin-release.zip

（2）解压到安装目录

[root@heimasrc]#unziprocketmq-a11-4.4.0-bin-release.zip

[root@heimasrc]#mvrocketmg-a11-4.4.0-bin-release../rock

etmg

找到 usr-local-src 目录：

[root@heima~]#cd/usr/

bin/games/lib/libexec/sbin/src/

etc/include/lib64/local/share/tmp/

[root@heima~]#cd/usr/local/src/

[root@heimasrc]#clear

//包已经上传，解压缩

[root@heimasrc]#ls

rocketmq-all-4.4.0-bin-release.zip

[root@heimasrc]#unziprocketmq-all-4.4.0-bin-release.zip

creating:rocketmg-all-4.4.0-bin-release/cont/2m-2s-sync

inflating:rocketmq-all-4.4.0-bin-release/conf/2m-2s-sync/br

oker-b.properties

inflating:rocketmq-all-4.4.0-bin-release/conf/2m-2s-sync/br

oker-b-s.properties

inflating:rocketmq-all-4.4.0-bin-release/conf/2m-2s-sync/br

oker-a.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-sync/br

oker-a-s.properties

creating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-async/

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-async/b

roker-b.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-asvnc/b

roker-b-s.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-async/b

roker-a.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-2s-async/b

roker-a-s.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/logback

broker.xml

inflating:rocketmg-all-4.4.0-bin-release/conf/logbacktools.

xml

inflating:rocketmg-all-4.4.0-bin-release/conf/broker.conf

inflating:rocketmg-all-4.4.0-bin-release/conf/tools.yml

creating:rocketmg-all-4.4.0-bin-release/conf/2m-noslave/

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-noslave/br

oker-b.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-noslave/br

oker-trace.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/2m-noslave/br

oker-a.properties

inflating:rocketmg-all-4.4.0-bin-release/conf/plainacl.yml

inflating:rocketmq-all-4.4.0-bin-release/conf/logbacknames

rv.xml

[root@heimasrc]#

[root@heimasrc]#

[root@heimasrc]#ls

rocketmq-all-4.4.0-bin-releaserocketma-all-4.4.0-bin-releas

e.zip

[root@heimasrc]#mvrocketmq-all-4.4.0-bin-release/usr/loc

al/rocketmq

[root@heimasrc]#

[root@heimasrc]#clear

//切一下：

[root@heimasrc]#cd../

[rootdheimalocal]#pwd

/usr/local

[root@heimalocal]#ls

binetcgamesincludeliblib64libexecrocketmgsbinsharesrc

[root@heimalocal]#cdrocketmq/

[root@heimarocketmg]#ls

benchmarkbiniconflibLICENSENOTICEREADME.md[rootaheima

rocketmg]#cdin

-bash:cd:in:没有那个文件或目录

[rootheimarocketmg]#cdbin

[rootaheimabin]#ll

//有很多启动命令以及配置文件

[rootaheimarocketmg]#cdbin

[rootaheimabin]#ll

总用量120

image.png

//用启动命令把里面的服务启动起来

[root@heimabin]#clear

3、启动 RocketMQ

（1）切换到安装目录

[root@heimarocketmg]#1s

benchmarkbinconflibLICENSENOTICEREADME.md

（2）启动 NameServer

[root@heimarocketma]#nohup./bin/mgnamesrv&[1]1467

#只要进程不报错，就应该是启动成功了，可以查看一下日志

[root@heimarocketmg]#tail-f/root/logs/rocketmglogs/nam

esrv.1og

启动 RocketMQ 需要跑两个组件，第一个为 NameServer 第二个为 Broker，Rocket 运行必须的两个组件。

①启动 NameServer

nohup 的命令，server 让后台启动，如果没有报错基本上问题就不大，可以通过查看日志来看是否启动成功，日志在目录 log 下面的 rocking clocks 里面有 name server.log 就是目录，有 the name server boot success 说明启动成功。

image.png

[root@heimabin]#nohup./mqnamesrv&

[1]15861

[rootaheimabin]#nohup:忽略输入并把输出追加到"nohup.out

//根据端口netstat-an|grep9876也能证明启动成功

[root@heimabin]#netstat-angrep9876

tcp600:::9876:::*LISTEN

[root@heimabin]#

②启动 Broker

启动之前需要编辑配置文件，修改两个配置

第一个组件有 runserver.sh：

[root@heimabin]#netstat-angrep9876

tcp600:::9876:::*LISTEN

[root@heimabin]#vimrunserver.sh

image.png

image.png

image.png

里面有内存的限制，一开始需要内存比较大，服务器内存没有那么大，改成256兆，后面也改成256兆，再后面改成128兆，第一个文件修改完。

exportJAVAHOME

exportJAVA="$JAVAHOME/bin/java'

exportBASEDIR=$(dirname$0)/..

exportCLASSPATH=.:${BASEDIR}/conf:${CLASSPATH}

#======================================================

#JVMConfiguration

#======================================================

JAVAOPT="${JAVAOPT!-server-Xms156m-Xmx256m-Xmn128m

-XX:MetaspaceSize=128m-xx:MaxMetaspaceSize=320m"

JAVAOPT="${JAVAOPT}-XX:+UseConcMarkSweepGC-XX:+Use

CMSCompactAtFullCollection-XX:CMSInitiatina0ccupancyFrac

tion=70-XX:+CMSParallelRemarkEnabled-XX:SoftRefLRUPoli

cyMSPerMB=0XX:+CMSClassUnloadingEnabled-xX:Survivor

Ratio=8-XX:-UseParNewGC"

JAVAOPT="${JAVAOPT}-verbose:gc-Xloggc:/dev/shm/rmq

srvgc.log-XX:+PrintGCDetails"

JAVAOPT="${JAVAOPT}-XX:-0mitStackTraceInFastThrow’

JAVAOPT="${JAVAOPT!-XX:-UseLargePages"

JAVA-OPT="${JAVA-OPT}-Diava.ext.dirs=${

JAVAHOME}/ire/lib/ext:${BASEDIR}/lib"

#JAVAOPT="${JAVAOPT}-Xdebug-Xrunidwp:transport=dt

socket,address=9555,server=y,suspend=n"

JAVAOPT="${JAVAOPT}${JAVAOPTEXT}"

JAVAOPT="${JAVAOPT}-cp${CLASSPATH}”

//修改第二个为runbroker.sh

[root@heimabin]#netstat-angrep9876

tcp600:::9876:::*LISTEN

[root@heimabin]#vimrunserver.sh

[root@heimabin]#vimrunbroker.sh

image.png

image.png

image.png

同样需要修改配置，调整一下改成256兆、256兆、128兆保存：

[-e"$JAVAHOME/bin/java"]&&JAVAHOME=$HOME/jdk/java!

[-e"$JAVAHOME/bin/java"]&&JAVAHOME=/usr/java

[!-e"$JAVA_HOME/bin/java"]&&errorexit"Pleasesetthe

JAVA_HOMEvariableinyourenvironment,Weneedjava(x64)!"

exportJAVA_HOME

exportJAVA="$JAVAHOME/bin/java'

exportBASEDIR=$(dirname$0)/..

exportCLASSPATH=.:${BASEDIR}/conf:${CLASSPATH}

#======================================================

#JVMConfiguration

#======================================================

JAVAOPT="${JAVAOPT!-server-Xms256m-Xmx256m-Xmn128m"

JAVAOPT="${JAVAOPT}-XX:+UseG1GC-XX:G1HeapReaionSize=16m

-XX:G1ReservePercent=25-XX:InitiatingHeap0ccupan

cyPercent=30-XX:SoftRefLRUPolicyMSPerMB=0"

JAVAOPT="${JAVAOPT}-verbose:gc-Xloggc:/dev/shm/magc

&p.log-xx:+PrintGCDetails-Xx:+PrintGCDateStamps--XX:+

PrintGCApplicationStoppedTime-XX:+PrintAdaptiveSizePolicy"

JAVAOPT="${JAVAOPT}-XX:+UseGCLogFileRotation-XX:

NumberOfGCLogFiles=5-XX:GCLogFileSize=30m"

启动 broker，nphup.MQ 不 rock./mabroker，需要指定 name server 的地址localhost：9876，然后后台运行，同样可以查看日志里面的输出，速度目录下面的 logs/rocketmqlogs/broker.log

[root@heimabin]#netstat-angrep9876

tcp600:::9876：：：*LISTEN

[root@heimabin]#vimrunserver.sh

[rootaheimabin]#vimrunbroker.sh

[root@heimabin]#nohup./mgbroker-nlocalhost:9876&

[2]16486

[root@heimabin]#nohup:忽略输入并把输出追加到"nohup.out'

[rootaheimabin]#

[rootaheimabin]#

[rootaheimabin]#tail-f~/logs/rocketmglogs/broker.log

只要能看里面有 starch，服务启动成功的标识 goodsuccess 启动成功就可以。

[rootaheimabin]#nohup./mgbroker-nlocalhost:9876&

[2]16486

[root@heimabin]#nohup:忽略输入并把输出追加到"nohup.out'

[root@heimabin]#

[rootaheimabin]#

[root@heimabin]#tail-f~/logs/rocketmglogs/broker.log

2020-01-0712:01:14WARNmain-Loaddefaultdiscardmessaae

hookservice:DefaultTransactionalMessageCheckListener

2020-01-0712:01:14INFOmain-Thebrokerdosenotenableacl

2020-01-0712:01:14INFOFileWatchService-FileWatchService

servicestarted

2020-01-0712:01:14INFOPullRequestHoldService-Pull

RequestHoldServiceservicestarted

2020-01-0712:01:15INFObrokerOutApithread1-register

brokertonameserverlocalhosts98760K

2020-01-0712:01:15INFOmain-Starttransactionservice!

2020-01-0712:01:15INFOmain-Thebroker[heima

192.168.109.131:10911]bootsuccess.serializeType=JSONand

nameserverislocalhost:9876

2020-01-0712:01:24INFOBrokerControllerScheduledThreadl-

dispatchbehindcommitlog0bytes

2020-01-0712:01:24INFOBrokerControllerScheduledThreadl-

Slavefallbehindmaster:0bytes

2020-01-0712:01:25INFObrokerOutApithread_2-register

brokertonameserverlocalhost;

98760K

^C

[root@heimabin]#

[root@heimabin]#

[root@heimabin]#clear

整个组建起来以后整个RocketMQ已经可以使用。

4、测试 RocketMQ

官方给了两个测试文件，只需要通过这两个脚本从一端发送另一端接收就可以，可以测一下MQ现在跑起来，只要通过一个脚本从左边向 MQ 发东西，右边通过一个脚本从 MQ 里面接东西，只要能发成功，并且能接到就证明 MQ 能够正常工作。

image.png

（1）测试消息发送

[rootGheimarocketmg]#exportNAMESRV_ADDR=1oca1host:9876

[root@heimarocketmq]#bin/tools.shorg.apache.rocketmq.

example.quickstart.Producer

（2）测试消息接收

[root@heimarocketmq]#exportNAMESRV_ADDR=1oca1host:9876

[root@heimarocketmg]#bin/toels.shorg.apache.rocketm

g.example.quickstart.Consumer

测试再开一个客户端：

image.png

Lastlogin：TueJan711：53：542020from192.168.1

[root@heima~]#clear

切到/usr/local/rocketmq 安装目录 bin 下面：

[root@heima~]#cd/usr/local/rocketmq/bbenchmark/bin/

[root@heima~]#cd/usr/local/rocketmq/bin/

[root@heima~]#clear

两边都到 bin 目录下，任务为从左边利用脚本发，从右边利用脚本收。

①发先声明一个 NameServer 地址，接下来通过脚本发送。

[root@heimabin]#exportNAMESRVADDR=localhost:9876

[rootaheimabin]#bin/tools.shora.apache.rocketma.example.

quickstart.Producer-bash:bin/tools.sh:没有那个文件或目录

[root@heimabin]#./tools.shorg.apache.rocketmq.example.

quickstart.Producer

OpenJDK64-BitServerVMwarning:ignoringoption

PermSize=128m;supportwasremovedin8.0

OpenJDK64-BitServerVMwarning:ignoringoption

MaxPermSize=128m;supportwasremovedin8.0

12:03:32.934[main]DEBUGi.n.u.i.l.InternalLoggerFactory

-UsingSLF4]asthedefaultloggingframework

//已经开始发送

SendResult[sendStatus=SENDOK，msgId=COA86D8342841D4

4BCFA217CA9BC03E6，offsetMsgId=COA86D8300002A9FO0000

0000002BD4A，messageQueue=MessageQueue[topic=TopicTest，

brokerName=heima,queueId=2],queueOffset=249]

SendResult[sendStatus=SENDOK.msaId=C0A86D8342841D44

BCFA217CA9BE03E7，offsetMsaId=C0A86D8300002A9F0000000

00002BDFE,messageQueue=MessageQueue[topic=TopicTest，

brokerName=heima,queueId=3],queueOffset=249]

12:03:38.138[NettyClientSelector1]INFORocketmqRemoting

-closeChannel:closetheconnectiontoremote

address[127.0.0.1:9876]result:true

12:03:38.139[NettyClientSelector1]INFORocketmaRemotina

-closeChannel:closetheconnectiontoremote

address[192.168.109.131:10909]result:true

12:03:38.155[NettyClientSelector1]INFORocketmgRemoting-

closeChannel:closetheconnectionre

moteaddress[192.168.109.131:10911]result:true

[root@heimabin]#

[root@heimabin]#

[root@heimabin]#

[root@heimabin]#

[rootaheimabin]#

[root@heimabin]#

[root@heimabin]#

//发送完成

②启动接收脚本，接收后要去声明 NameServer 的地址。

[root@heimabin]#exportNAMESRVADDR=localhost:9876

[root@heimabin]#./tools.shorg.apache.rocketmq.example.

quickstart.Consumer

OpenJDK64-BitServerVMwarning:ignoringoption

PermSize=128m;supportwasremovedin8.0

OpenJDK64-BitServerVMwarning:ignoringoption

MaxPermSize=128m;supportwasremovedin8.0

12:04:09.231[main]DEBUGi.n.u.i.l.InternalLoggerFactory-

UsingSLF4]asthedefaultloggingframewdrk

ConsumerStarted.

//已经可以接到消息，接处于监听状态

image.png

再来发一次，已经接收到。

image.png

证明 RocketMQ 是正常可运行的。

5、关闭 RocketMQ

[root@heimarocketmg]#bin/mgshutdownbroker

[root@heimarocketmq]#bin/mqshutdownnamesrv

两个命令停止 block、namesrv 的。

文章标签：
云消息队列 MQ
日志服务
Java
Shell
消息中间件
Linux
双11
RocketMQ
Apache
Spring
数据格式
XML
关键词：
云消息队列 MQ学习笔记
消息队列RocketMQ版环境搭建
消息队列RocketMQ版学习笔记
相关实践学习
消息队列RocketMQ版：基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能，涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
云课程笔记
目录
相关文章
橙子先生
|
5月前
|
消息中间件 存储 算法
RocketMQ学习笔记
RocketMQ学习笔记
橙子先生
145 0
fensnote
|
5月前
|
传感器 网络协议 中间件
Mqtt学习笔记--交叉编译移植（1）
Mqtt学习笔记--交叉编译移植（1）
fensnote
103 0
叫我默语
|
消息中间件 存储 缓存
RibbitMQ学习笔记之MQ练习（三）
RibbitMQ学习笔记之MQ练习
叫我默语
46 0
myysophia
|
消息中间件 网络协议 数据中心
RabbmitMQ学习笔记-RabbitMQ集群架构模式
RabbmitMQ学习笔记-RabbitMQ集群架构模式
myysophia
77 0
myysophia
|
消息中间件 Java
RabbmitMQ学习笔记-RabbitMQ与SpringBoot2.0整合实战
在使用 RabbitMQ 的时候，作为消息发送方希望杜绝任何消息丢失或者投递失败场景。RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式。
myysophia
113 0
叫我默语
|
消息中间件 中间件
RibbitMQ学习笔记之MQ发布确认
RibbitMQ学习笔记之MQ发布确认
叫我默语
52 0
叫我默语
|
消息中间件 网络协议
RibbitMQ学习笔记之MQ练习（二）
RibbitMQ学习笔记之MQ练习
叫我默语
33 0
叫我默语
|
消息中间件 网络协议 Java
RibbitMQ学习笔记之MQ练习（一）
RibbitMQ学习笔记之MQ练习
叫我默语
72 0
叫我默语
|
消息中间件 存储 网络协议
RibbitMQ学习笔记之MQ 的相关概念
RibbitMQ学习笔记之MQ 的相关概念
叫我默语
78 0
唐城子
|
消息中间件 监控 Java
重大发现！消息中间件——RocketMQ（一） 环境搭建（完整版）上
重大发现！消息中间件——RocketMQ（一） 环境搭建（完整版）上
唐城子
297 3
重大发现！消息中间件——RocketMQ（一） 环境搭建（完整版）上

阿里云开发者学堂

热门文章

最新文章

  • 1
    RabbitMQ如何保证消息不被重复消费（幂等性问题详解）
  • 2
    python rabbitmq send messages
  • 3
    小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发，聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(上)
  • 4
    消息队列：解耦、异步、削峰，现有MQ对比以及新手入门该如何选择MQ?
  • 5
    RabbitMQ(从安装到使用)
  • 6
    HTTP 与 MQTT：为您的 IoT 项目选择最佳协议
  • 7
    Qt开发技术：mqtt介绍、QtMqtt编译和开发环境搭建
  • 8
    RabbitMQ 清除全部队列及消息
  • 9
    MQTT协议
  • 10
    消息中间件的技术选型心得－RabbitMQ、ActiveMQ和ZeroMQ
  • 1
    消息队列RocketMQ版：基础消息收发功能体验
    182
  • 2
    消息中间件第八讲：消息队列 RocketMQ 版实战、集群及原理
    289
  • 3
    消息队列RocketMQ版：消费异常运维排查体验
    902
  • 4
    消息队列RocketMQ版：定时消息通知功能体验
    656
  • 5
    消息队列RocketMQ版：基础消息收发功能体验
    518
  • 6
    【名师代练】带你玩转 RocketMQ，角逐「RocketMQ 首席评测官」
    374
  • 7
    聊聊RocketMQ名字服务
    125
  • 8
    微服务 RocketMQ-延时消息 消息过滤 管控台搜索问题
    127
  • 9
    RocketMQ-消息消费模式 顺序消费
    209
  • 10
    消息中间件-RocketMQ入门 消息发送的三种方式
    160

    • 相关课程

    更多
  • 消息队列 RocketMQ 消息集成
  • 消息队列 MNS 入门课程
  • RocketMQ知识精讲与项目实战（第一阶段）
  • RocketMQ知识精讲与项目实战（第二阶段）
  • RocketMQ知识精讲与项目实战（第三阶段）
  • 微服务实战-RocketMQ Binder

    • 相关电子书

    更多
  • RocketMQ Client-GO 介绍
  • RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

    • 相关实验场景

    更多
  • 快速体验云消息队列RocketMQ版
  • 快速入门轻量消息队列（原MNS）
  • 快速学会使用云消息队列RabbitMQ版
  • 消息队列RocketMQ版：消费异常运维排查体验
  • 消息队列RocketMQ版：定时消息通知功能体验
  • 消息队列RocketMQ版：基础消息收发功能体验
    • 下一篇
    阿里云对象存储OSS怎么收费？包年包月和按量付费价格表