linux下安装rocketmq

绝地灬酷狼 2023-06-07 08:08 12阅读 0赞

这里以在ubuntu18.04上安装为例，来说明安装单个实例rocketmq的过程和验证情况。

## 安装 ##

### 下载 ###

下载地址如下，选择想要下载的版本即可：  
[http://rocketmq.apache.org/release\_notes/][http_rocketmq.apache.org_release_notes]

### 解压 ###

在自己的环境安装目录下解压

$ unzip rocketmq-all-4.5.2-bin-release.zip

## 启动服务 ##

### 启动`namesrv` ###

`namesrv`的默认启动申请的jvm内存是信息如下：

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

可以根据实际环境进行调整，如果是在自己的开发本启动，不进行调整的话内存自然不够用。修改jvm配置

vim  bin/runserver.sh

启动`namesrv`服务：

$ nohup ./bin/mqnamesrv &
    $ tail  -f  ~/logs/rocketmqlogs/namesrv.log
    The Name Server boot success.

### 启动`broker` ###

`broker`的默认启动申请的jvm内存为8g，信息如下：

JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"

同样需要根据实际环境进行调整，修改jvm配置：

vim  bin/runbroker.sh

启动`broker`服务，并且指定`namesrv`服务：

$ nohup ./bin/mqbroker -n localhost:9876 &
    $ tail -f ~/logs/rocketmqlogs/broker.log
    The broker[cc-ubuntu, 192.168.1.4:10911] boot success.

启动成功后，便可以在日志文件中看到broker初始化配置信息的过程日志，同时还向`namesrv`中进行注册。

## 验证服务 ##

### 服务启动成功验证 ###

在启动的时候已用查看日志的方式进行了验证，但由于是java服务，除了可以通过启动日志来看服务是否启动成功外，亦可以查看java进程的方式来判断，如下所示：

$ jps -l
    14257 org.apache.rocketmq.namesrv.NamesrvStartup
    14548 org.apache.rocketmq.broker.BrokerStartup

### 服务可用验证 ###

设置临时的`namesrv`环境变量：

export NAMESRV_ADDR=localhost:9876

利用官方提供的工具发送消息和消费消息来验证，可以看到正常的完成消息发送和消息消费。

$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
     SendResult [sendStatus=SEND_OK, msgId= ...
    
     $ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
     ConsumeMessageThread_%d Receive New Messages: [MessageExt...

## web控制台安装 ##

下载rocketmq-externals:  
[https://github.com/apache/rocketmq-externals/][https_github.com_apache_rocketmq-externals]

然后进行解压，并且编译打包：

$ unzip rocketmq-externals-master.zip
    $ cd rocketmq-externals-master/rocketmq-console/
    $ mvn clean package -Dmaven.skip.test=true
    >>>
    [INFO] BUILD SUCCESS

拷贝jar包到合适的路径，启动程序（指定`namesrv`地址和服务端口）：

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

访问[http://localhost:19876/\#/][http_localhost_19876]即可看到控制台界面：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4ODUxNTAz_size_16_color_FFFFFF_t_70]

## 关闭服务 ##

### 关闭broker ###

$ ./bin/mqshutdown broker
    The mqbroker(3082) is running...
    Send shutdown request to mqbroker(3082) OK

### 关闭namesrv ###

$ ./bin/mqshutdown namesrv
    The mqnamesrv(3019) is running...
    Send shutdown request to mqnamesrv(3019) OK

[http_rocketmq.apache.org_release_notes]: http://rocketmq.apache.org/release_notes/
[https_github.com_apache_rocketmq-externals]: https://github.com/apache/rocketmq-externals/
[http_localhost_19876]: http://localhost:19876/#/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI4ODUxNTAz_size_16_color_FFFFFF_t_70]: /images/20230601/32bc5cda5b9d462f95f65ec0a6ddaa39.png