04、RocketMQ实战:RocketMQ单机安装及启动

本文详细介绍了Apache RocketMQ在Linux系统上的完整安装、配置与启动流程,包括环境准备、内存参数调优、NameServer与Broker的启动、消息发送接收测试以及服务关闭,适合需要快速部署RocketMQ的开发者。

1 准备工作

软硬件需求

系统要求是64位的,JDK要求是1.8及其以上版本的。
 

下载RocketMQ安装包

 
 
将下载的安装包上传到Linux。
 
解压。  

2、修改初始内存

修改runserver.sh

使用vim命令打开bin/runserver.sh文件。现将这些值修改为如下:
 

修改runbroker.sh

使用vim命令打开bin/runbroker.sh文件。现将这些值修改为如下:
 

3、启动

启动NameServer

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log

 

启动broker

nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log

 

4、发送/接收消息测试

发送消息

export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息

sh bin/tools.sh org.apache.rocketmq.example.1 quickstart.Consumer

5、关闭Server

无论是关闭name server还是broker,都是使用bin/mqshutdown命令。

[root@mqOS rocketmq]# sh bin/mqshutdown broker
The mqbroker(1740) is running…
Send shutdown request to mqbroker(1740) OK
[root@mqOS rocketmq]# sh bin/mqshutdown namesrv
The mqnamesrv(1692) is running…
Send shutdown request to mqnamesrv(1692) OK
[2]+ 退出 143 nohup sh bin/mqbroker -n localhost:9876

版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: