window安装rocketmq(代码片段)

转载：https://www.cnblogs.com/fanshuyao/p/14760546.html

一，下载

地址：http://rocketmq.apache.org/release_notes/release-notes-4.3.0/

 二，系统变量

系统变量

ROCKETMQ_HOME
C:\\rocketmq-all-4.3.0-bin-release

NAMESRV_ADDR
localhost:9876

PATH属性增加：

%ROCKETMQ_HOME%\\\\bin

（C:\\rocketmq-all-4.3.0-bin-release）路径千万不能有空格！

三，启动

3、RocketMQ修改日志文件目录
（这步可以省略，默认是在用户的目录是，但为了方便，修改日志存放目录）：
进入目录：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\conf

修改3个xml文件（请先备份）：

logback_namesrv.xml
logback_broker.xml
logback_tools.xml

将所有$user.home/logs，替换成：D:/0soft/rocketmq-all-4.8.0/logs，具体目录自己定义。

最后生成的日志文件在下面的目录：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\logs\\\\rocketmqlogs

4、RocketMQ修改内存参数，默认的内存太大（记得先备份相应的文件）
进入目录：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\bin

修改：runserver.cmd（记得先备份文件）：
将：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

修改成：

set "JAVA_OPT=%JAVA_OPT% -server -Xms128m -Xmx256m -Xmn64m -XX:MetaspaceSize=32m -XX:MaxMetaspaceSize=64m"

修改：runbroker.cmd（记得先备份文件）：
将：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"
set "JAVA_OPT=%JAVA_OPT% -XX:MaxDirectMemorySize=15g"

修改成：

set "JAVA_OPT=%JAVA_OPT% -server -Xms128m -Xmx128m -Xmn64m"
set "JAVA_OPT=%JAVA_OPT% -XX:MaxDirectMemorySize=1g"

5、RocketMQ启动Name Server：
打开一个新的cmd命令窗口，并进入到bin目录：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\bin>mqnamesrv

或者（前提是配置Path路径）：

mqnamesrv

启动结果：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\bin>mqnamesrv
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON

6、RocketMQ启动：Broker
打开一个新的cmd命令窗口，并进入到bin目录：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\bin>mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

或者（前提是配置Path路径）：

mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

启动结果：

D:\\\\0soft\\\\rocketmq-all-4.8.0\\\\bin>mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
The broker[XXZX-liqiongy-10, 168.168.2.120:10911] boot success. serializeType=JSON and name server is localhost:9876

7、RocketMQ测试发送消息：

打开一个新的命令窗口，输入下面的命令：

tools.cmd org.apache.rocketmq.example.quickstart.Producer

运行结果：
C:\\\\Users\\\\liqiongy>tools.cmd org.apache.rocketmq.example.quickstart.Producer
14:52:04.556 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.

SendResult [sendStatus=SEND_OK, msgId=7F00000126B80D71636136B05B2003E6, offsetMsgId=A8A8027800002A9F00000000000316F4, messageQueue=MessageQueue [topic=TopicTest, brokerName=XXZX-liqiongy-10, queueId=3], queueOffset=249]
SendResult [sendStatus=SEND_OK, msgId=7F00000126B80D71636136B05B2103E7, offsetMsgId=A8A8027800002A9F00000000000317BF, messageQueue=MessageQueue [topic=TopicTest, brokerName=XXZX-liqiongy-10, queueId=0], queueOffset=249]

14:52:07.337 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[168.168.2.120:10911] result: true
14:52:07.338 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[127.0.0.1:9876] result: true

8、RocketMQ测试接收消息：

打开一个新的命令窗口，输入下面的命令：

tools.cmd org.apache.rocketmq.example.quickstart.Consumer

运行结果：
C:\\\\Users\\\\liqiongy>tools.cmd org.apache.rocketmq.example.quickstart.Consumer
14:54:08.623 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
Consumer Started.

ConsumeMessageThread_3 Receive New Messages: [MessageExt [brokerName=XXZX-liqiongy-10, queueId=3, storeSize=201, queueOffset=1, sysFlag=0, bornTimestamp=1620715925363, bornHost=/168.168.2.120:60949, storeTimestamp=1620715925364, storeHost=/168.168.2.120:10911, msgId=A8A8027800002A9F00000000000004B6, commitLogOffset=1206, bodyCRC=1307562618, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Messagetopic=\\'TopicTest\\', flag=0, properties=MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1620716049251, UNIQ_KEY=7F00000126B80D71636136B053730006, CLUSTER=DefaultCluster, WAIT=true, TAGS=TagA, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 54], transactionId=\\'null\\']]
ConsumeMessageThread_20 Receive New Messages: [MessageExt [brokerName=XXZX-liqiongy-10, queueId=1, storeSize=201, queueOffset=2, sysFlag=0, bornTimestamp=1620715925368, bornHost=/168.168.2.120:60949, storeTimestamp=1620715925369, storeHost=/168.168.2.120:10911, msgId=A8A8027800002A9F0000000000000648, commitLogOffset=1608, bodyCRC=710410109, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Messagetopic=\\'TopicTest\\', flag=0, properties=MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1620716049253, UNIQ_KEY=7F00000126B80D71636136B053780008, CLUSTER=DefaultCluster, WAIT=true, TAGS=TagA, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 56], transactionId=\\'null\\']]

9、RocketMQ关闭Servers：

开发环境，可以直接关闭cmd命令窗口
但生产环境不要这样做，而是要打开一个新的命令窗口，分别执行下面的命令：
先关闭broker，再关闭name server

mqshutdown.cmd broker
mqshutdown.cmd namesrv

官方文档见：

https://rocketmq.apache.org/docs/quick-start/