本文介绍如何在Linux环境下搭建Rocket MQ服务,内容包含安装需要的环境,安装步骤,启动服务,模拟消息发送和接收,停止服务以及在安装过程中遇到的问题。

还是老规矩,先跟着操作,操作完之后就基本都会了,如果还有疑问,请在留言区评论,我会及时回复

ps:文中插入了命令,某些地方排版看起来会比较乱,但是操作还是很方便的

 

依赖的环境

Rocket MQ安装需要依赖JDK1.8和maven

 

使用java -version命令可以测试是否安装了JDK并且可以查看JKD的版本,请确保JKD版本在1.8以上。如下,我的JDK版本是1.8.0_172

Linux下搭建Rocket MQ服务

 

使用mvn -v可以测试是否安装了maven,如下表示安装了maven

Linux下搭建Rocket MQ服务

 

安装步骤

下载压缩包wget https://github.com/apache/rocketmq/archive/rocketmq-all-4.4.0.tar.gz,出现下图内容说明下载成功

Linux下搭建Rocket MQ服务

 

将压缩包解压 tar -zxvf rocketmq-all-4.4.0.tar.gz

 

进入解压目录cd rocketmq-rocketmq-all-4.4.0/,执行命令进行编译 mvn -Prelease-all -DskipTests clean install -U,编译过程需要等一会,因为maven要下载相关依赖,出现下图内容说明编译成功

Linux下搭建Rocket MQ服务

 

启动

Rocket MQ包含namesrv和broker,需要依次启动

 

首先,进入启动目录, cd distribution/target/apache-rocketmq/bin

 

启动namesrv,nohup sh mqnamesrv > ../namesrv.log &,查看日志more ../namesrv.log,出现下图内容说明启动成功

Linux下搭建Rocket MQ服务

 

启动broker,nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > ../broker.log & ,查看日志 more ../broker.log ,出现下图内容说明启动成功

ps:启动broker时可能会报错,下文会讲如何解决

Linux下搭建Rocket MQ服务

 

启动broker时可能会报错内存不足,是因为broker默认配置的内存为8G,如果服务器的内存剩余不足8G就会报错。可以把broker的配置内存改小一点,在 rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin目录下分别修改runserver.sh 和 runbroker.sh文件,如下图

Linux下搭建Rocket MQ服务

 

模拟发送和接收

模拟之前需要先设置mq的环境变量,编辑profile文件 vi /etc/profile,添加环境变量

export NAMESRV_ADDR=localhost:9876,添加完成保存后执行 source /etc/profile使其生效

 

模拟发送,sh tools.sh org.apache.rocketmq.example.quickstart.Producer

 

模拟接收,sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

 

停止

停止broker,sh mqshutdown broker

 

停止namesrv,sh mqshutdown namesrv


扫码关注我的公众号

每天进步一点点,不负光阴,度几扶人

Linux下搭建Rocket MQ服务

 

相关文章:

  • 2021-04-20
  • 2021-09-02
  • 2021-11-10
  • 2021-07-21
猜你喜欢
  • 2021-09-19
  • 2021-10-13
  • 2022-01-18
  • 2021-07-11
  • 2021-06-01
  • 2021-11-27
  • 2021-08-14
相关资源
相似解决方案