linux安装rocketMq,测试消息发送和接收

1.安装jdk1.8

2.配置jdk环境：

让配置生效：

source /etc/profile

3.检测java环境是否配置成功  java -version  或 javac   ,如果出现权限问题，修改权限：chmod +x /usr/java/jdk1.8.0_161/bin/javac

4.上传rocketmq压缩包

5.因为rocketmq初始化配置占用内存比较大，需要在解压后的bin目录下面，修改内存大小 ，修改了这个三个大小

vim runbroker.sh

 

在brocket.conf配置文件中加入ip地址

 

nameserver启动命令：
nohup sh bin/mqnamesrv 1>/dev/null 2>&1 &
broker启动命令：
nohup sh bin/mqbroker -n localhost:9876 1>/dev/null 2>&1 &

 

broker停止命令：
./bin/mqshutdown broker
nameserver停止命令：
./bin/mqshutdown namesrv

 

6.在bin目录下执行：

生产者发送消息：
export NAMESRV_ADDR=127.0.0.1:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

消费者接受消息：
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer