RocketMQ单机版安装启动

待我称王封你为后i 2022-12-29 11:29 220阅读 0赞

**目录**

RocketMQ服务端安装启动

源代码编译安装

启动mqnamesrv

修改mqnamesrv启动脚本JVM参数

启动mqnamesrv脚本

查看mqnamesrv启动后信息

启动mqbroker

修改mqbroker配置文件

修改mqbroker启动脚本JVM参数

启动mqbroker脚本

查看mqbroker启动信息

RocketMQ客户端安装启动

客户端代码编译打包

客户端启动

--------------------

RocketMQ前身叫做MetaQ,在MeataQ发布3.0版本的时候改名为RocketMQ，使用Java进行开发。

**这篇文章不做过多介绍，主要记录安装过程步骤。****下载地址** [https://rocketmq.apache.org/docs/quick-start/][https_rocketmq.apache.org_docs_quick-start]

可以下载二进制直接使用，也可以下载源码使用maven进行自行编译后使用。本文章使用4.5.1版本安装 [https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-source-release.zip][https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.5.1_rocketmq-all-4.5.1-source-release.zip]

# RocketMQ服务端安装启动 #

### 源代码编译安装 ###

编译需要maven环境

unzip rocketmq-all-4.5.1-source-release.zip 
    cd rocketmq-all-4.5.1/
    chmod -R 777 *
    mv rocketmq-all-4.5.1 apache-rocketmq
    cd apache-rocketmq 
    mvn -Prelease-all -DskipTests clean install -U

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70][]

** 切换到编译好的安装目录下**

cd /opt/apache-rocketmq/distribution/target/rocketmq-4.5.1/rocketmq-4.5.1

## 启动mqnamesrv ##

### 修改mqnamesrv启动脚本JVM参数 ###

把jvm参数设置小一些

vi bin/runserver.sh

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 1][]

### 启动mqnamesrv脚本 ###

nohup sh bin/mqnamesrv &

>  \[root@localhost apache-rocketmq\]\# cd /opt/apache-rocketmq/distribution/target/rocketmq-4.5.1/rocketmq-4.5.1  
> \[root@localhost rocketmq-4.5.1\]\# sh 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  
> ^C\[root@localhost rocketmq-4.5.1\]\# cd /opt/apache-rocketmq/distribution/target/rocketmq-4.5.1/rocketmq-4.5.1  
> \[root@localhost rocketmq-4.5.1\]\# nohup sh bin/mqnamesrv &  
> \[root@localhost rocketmq-4.5.1\]\# jps  
> 75524 Jps  
> 74857 NamesrvStartup

### 查看mqnamesrv启动后信息 ###

sh ./bin/mqnamesrv -p

> \[root@localhost rocketmq-4.5.1\]\# sh ./bin/mqnamesrv -p  
> 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.  
> 21:41:55.847 \[main\] INFO  RocketmqNamesrvConsole - rocketmqHome=/opt/apache-rocketmq/distribution/target/rocketmq-4.5.1/rocketmq-4.5.1  
> 21:41:55.848 \[main\] INFO  RocketmqNamesrvConsole - kvConfigPath=/root/namesrv/kvConfig.json  
> 21:41:55.848 \[main\] INFO  RocketmqNamesrvConsole - configStorePath=/root/namesrv/namesrv.properties  
> 21:41:55.848 \[main\] INFO  RocketmqNamesrvConsole - productEnvName=center  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - clusterTest=false  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - orderMessageEnable=false  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - listenPort=9876  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverWorkerThreads=8  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverCallbackExecutorThreads=0  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverSelectorThreads=3  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverOnewaySemaphoreValue=256  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverAsyncSemaphoreValue=64  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverChannelMaxIdleTimeSeconds=120  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverSocketSndBufSize=65535  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverSocketRcvBufSize=65535  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - serverPooledByteBufAllocatorEnable=true  
> 21:41:55.849 \[main\] INFO  RocketmqNamesrvConsole - useEpollNativeSelector=false

## 启动mqbroker ##

### 修改mqbroker配置文件 ###

在broker.conf 配置文件后追加 **brokerIp1 = 192.168.170.129**

vi conf/broker.conf

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 2][]

###  修改mqbroker启动脚本JVM参数 ###

vi bin/runbroker.sh

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 3][]

### 启动mqbroker脚本 ###

**注意ip地址和端口，虚拟机会有多网卡问题导致ip不一致**

nohup sh bin/mqbroker -n localhost:9876 -c ./conf/broker.conf  &

###  查看mqbroker启动信息 ###

sh ./bin/mqbroker -m

# RocketMQ客户端安装启动 #

### 客户端代码编译打包 ###

下载 [https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console][https_github.com_apache_rocketmq-externals_tree_master_rocketmq-console] 解压源代码，maven编译打包

mvn clean package -DskipTests

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 4][]

### 客户端启动  ###

**切换到target目录下启动rocketmq-console-ng-1.0.1.jar包**

nohup  java -jar rocketmq-console-ng-1.0.1.jar --server.port=8876 --rocketmq.config.namesrvAddr=192.168.170.129:9876 &

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 5][]

[https_rocketmq.apache.org_docs_quick-start]: https://rocketmq.apache.org/docs/quick-start/
[https_www.apache.org_dyn_closer.cgi_path_rocketmq_4.5.1_rocketmq-all-4.5.1-source-release.zip]: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-source-release.zip
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70]: /images/20221120/a15b787f86514f578cc5523c6510caf6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201222144929675.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201222145243284.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201222145351425.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz,size_16,color_FFFFFF,t_70
[https_github.com_apache_rocketmq-externals_tree_master_rocketmq-console]: https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20201222152858944.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20201222153957295.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5NTY5MTgz,size_16,color_FFFFFF,t_70