首页 > 系统服务 > 详细

Linux上安装rocketmq

时间:2020-10-02 23:10:27      阅读:78      评论:0      收藏:0      [点我收藏+]

1.将安装包上传到linux系统中

这里我在usr/local目录下新建了一个目录叫soft用来存放各种安装包

Rocketmq也上传到soft目录中. 技术分享图片

2. 解压安装包

[root@superj soft]# unzip rocketmq-all-4.4.0-bin-release.zip

技术分享图片

目录结构:

技术分享图片

技术分享图片

技术分享图片

技术分享图片

3.将rmq安装到指定文件夹

这里我在usr/local目录中新建一个文件夹 rocketmq

在local目录下,执行指令: mkdir rocketmq

回到刚刚rocketmq安装包所在目录(soft),将安装包剪切rocketmq目录中

技术分享图片

4.启动rocketmq

1)启动nameserver

1??启动NameServer

nohup sh bin/mqnamesrv &

2??查看启动日志

tail -f ~/logs/rocketmqlogs/namesrv.log

输入命令后,没反应?

配置jdk环境变量和rocketmq环境变量

①通过 vim ~/.bash_profile 命令打开 .bash_profile,如果没有该文件可以通过 touch ~/.bash_profile 命令创建.添加如下配置,其中 jdk 的位置填入第一步中你自己查找出的 jdk 的位置

export JAVA_HOME=/usr/local/ jdk1.8.0_171

使用 source ~/.bash_profile 命令使配置生效

②修改 RocketMQ 的 bin 目录下的 runserver.sh 和 runbroker.sh,将设置 JAVA_HOME 的第二三行注释掉,把第一行 JAVA_HOME 设置为jdk 的安装目录,如下所示

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME= /usr/local/jdk1.8.0_171

# [ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java

# [ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

RocketMQ默认的虚拟机内存较大,也可能造成启动失败,将虚拟内存调小一些

技术分享图片

配置mq的环境变量并使其生效

echo "ROCKETMQ_HOME=`pwd`" >> ~/.bash_profile

source ~/.bash_profile

再启动就成功了,日志如下 技术分享图片

通过jps命令可以查看当前有哪些进程

 技术分享图片

??Tips:

除了通过命令行查看日志,还可以通过notepad++ 安装插件也能连接linux服务器哦,连接上之后就能直接在里面查看日志了

技术分享图片技术分享图片

配置连接

技术分享图片

连接到远程

技术分享图片 

技术分享图片

2) 启动Broker

1??启动Broker

nohup sh bin/mqbroker -n localhost:9876 &

2??查看启动日志

tail -f ~/logs/rocketmqlogs/broker.log

技术分享图片

技术分享图片

技术分享图片

查看进程,都有,说明启动成功

技术分享图片

5.关闭rocketmq

1??关闭NameServer

sh bin/mqshutdown namesrv

2??关闭Broker

sh bin/mqshutdown broker

6.测试rocketmq

1)首先克隆一个进程,一个窗口用来发消息,一个窗口用来接收消息

这里用ftp工具,右键克隆一个新窗口

技术分享图片

技术分享图片

两个窗口都进入到rocketmq的bin目录内

技术分享图片

技术分享图片

2)发送消息

1??设置临时环境变量

export NAMESRV_ADDR=localhost:9876

2??使用安装包的Demo发送消息(如果bin目录下了,就去掉指令中的bin/)

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

技术分享图片

3)接收消息

1??设置环境变量

export NAMESRV_ADDR=localhost:9876

2??接收消息

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

技术分享图片

疑问???

为啥总有一个窗口报错 没配置jdk环境变量呢?

克隆的那一个发消息成功了,只能也用这同一个窗口尝试接消息,也成功了

Linux上安装rocketmq

原文:https://www.cnblogs.com/superjishere/p/13762607.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!