rocketMQ环境普通搭建及测试

 

Producer
消息生产者，负责产生消息，一般由业务系统负责产生消息。

Consumer
消息费者，负责消费消息，一般是后台系统负责异步消费。

NameServer
集群架构中的组织协调员，收集broker的工作情况，不负责消息的处理

Broker(topic存在其中)
是RocketMQ的核心负责消息的发送、接收、高可用等（真正干活的）需要定时发送自身情况到NameServer，默认10秒发送一次，超时2分钟会认为该broker失效。

Topic（其中有多个队列）
不同类型的消息以不同的Topic名称进行区分，如User、Order等是逻辑概念

-----------------------------------------------------------------------------------------------------------------------------------

准备rocketMQ安装包rocketmq-all-4.3.2-bin-release.zip

下载地址：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.3.2/rocketmq-all-4.3.2-bin-release.zip

上传到服务器上面 并进行解压

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

修改配置文件

进入到刚刚解压文件夹的bin目录下面

cd /usr/local/rocketmq-all-4.3.2-bin-release/bin/

编辑文件

vim runbroker.sh
vim runserver.sh

修改如下

修改完成保存

 

设置环境变量

export NAMESRV_ADDR=127.0.0.1:9876

创建文件broker.conf

vim /usr/local/rocketmq-all-4.3.2-bin-release/tempconfig/broker.conf -p

向文件中写入

brokerIP1=192.168.142.128
namesrvAddr=192.168.142.128:9876
brokerName=broker_haoke_im

启动mqnamesrv（bin目录下）

./mqnamesrv

启动mqbroker （bin目录下）

# 注意填写自己的ip
# ./mqbroker -n 192.168.142.128:9876
#通过配置文件进行启动，-c 后面指定broker.cong的位置
./mqbroker -c ../tempconfig/broker.conf

 

-----------------------------------------------------------------------------------------------------------------------------------

测试

# bin目录下执行
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

测试发送消息

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