Jdk安装参考jdk与nginx安装文档

Rocketmq安装

1.下载

安装包

官网传送门：

http://rocketmq.apache.org/dowloading/releases/

2. 配置rocketmq

上传rocketmq安装包到自己目录

解压rocketmq压缩包

unzip rocketmq-all-4.8.0-bin-release.zip

配置rocketmq环境变量

执行命令打开配置文件profile

vim /etc/profile

这里需要配置两个标签rocket和path

export rocketmq=/usr/local/soft/rocketmq-all-4.8.0-bin/rocketmq-all-4.8.0-bin-release/

export PATH=$PATH:$rocketmq/bin

在这里插入图片描述

rocket：对应的是你rocket的目录，有些人这里会不太理解，什么是rocket的目录，说白了就是rocket数据包的根目录可以这么理解吧，通俗的讲就是当前目录下一层就是你目录下的所有文件了，拷贝那一层就行了。

3.启动RocketMQ

修改启动内存大小

接下来我们启动一下刚才编译的RocketMQ.在启动之前我们需要修改一下RocketMQ启动的内存大小（如果你的系统内存比较大的话，请忽略）。我们进入rocketmq解压包的bin目录下，在终端中输入以下命令修改mqnamesrv的内存大小

接下来修改broker的内存大小：命令为 vi runbroker.sh

启动mqnameserver

进入rocket的bin目录执行命令命令：nohup sh mqnamesrv &&表示后台启动，不能少

可以通过jps命令查看namesrv是否启动

也可以通过日志查看

启动broker

进入rocket的bin目录执行命令命令：nohup sh mqbroker -n localhost:9876 &&表示后台启动，不能少

可以通过jps命令查看broker是否启动

4.命令行发送和接收消息

进入到rocketmq目录：

发送消息

export NAMESRV_ADDR=localhost:9876

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

接收消息

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

关闭rocketmq命令

第一次直接粗暴的方式

直接执行命令：

ps -ef | grep java 找到rocket相关进程的端口号，然后进行kill

命令： kill -9 端口号

rocket本身关闭命令

进入到rocketmq的bin目录

关闭namesrv

执行命令：sh mqshutdown namesrv

关闭broker

执行命令：sh mqshutdown broker

最后在执行jps查看当前java进程类

成功！！！