最近因为一些信创问题，要将RabbitMQ替换为RocketMQ，因此在此分享一些RocketMQ在Centos7系统上单机部署相关过程。
优缺点
RocketMQ的优点：
性能优越：RocketMQ在处理大量消息时，性能优于RabbitMQ。当面临每秒数万到数十万条消息的处理需求时，RocketMQ能够提供更好的性能。
灵活的路由配置：RocketMQ在生产者和队列之间增加了一个Exchange模块，根据配置的路由规则将生产者发出的消息分发到不同的队列中，这提供了更大的灵活性。
对在线业务的响应时延做了很多优化：RocketMQ对在线业务的响应时延做了很多优化，大多数情况下可以做到毫秒级响应。
中文社区活跃：对于中文用户来说，RocketMQ的中文社区比较活跃，源代码易读，方便二次开发。
RocketMQ的缺点：
大量消息堆积时，会导致性能急剧下降。
和其它两种消息队列产品相比，性能是最差的。因此，如果业务对性能要求特别高，就不要选用RocketMQ。
Java开发，虽然学习成本相对较低，但仍然需要学习相关的开发技术。
单机部署
一、部署RocketMQ
- 部署JDK
这里不详细描述了，网上很多 - 下载依赖
wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip
cd ./rocketmq-all-4.9.4-bin-release/
- 修改环境变量
vim /etc/profile
# 在末尾加入下面配置 路径和自己解压的mq路径一直
export ROCKETMQ_HOME=/home/rocketmq-all-4.9.4-bin-release
# 使环境变量生效
source /etc/profile
- 启动服务nameserver
## 启动
nohup sh bin/mqnamesrv &
## 关闭
sh bin/mqshutdown namesrv
- 指定NameServer地址
vim /etc/profile
# 在末尾加入下面配置 有多个时以分号隔开，这个是集群时使用的 mq端口默认是9876
# 192.168.141.101是服务器地址
export NAMESRV_ADDR=192.168.141.101:9876
# 使环境变量生效
source /etc/profile
- 修改broker.conf
重要，核心配置，以后关于mq服务的配置都在这里
vi ./conf/broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
# 这个就是第三三步配置的export NAMESRV_ADDR=192.168.141.101:9876 多个以分号分割
namesrvAddr=192.168.2.172:9092
#如果是多网卡的机器，比如云服务器，那么需要在broker.conf中增加brokerIP1属性，
#指定所在机器的外网网卡地址
brokerIP1=192.168.2.172
#对外服务的监听端口
listenPort=10911
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
traceTopicEnable=true
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
- 启动broker
进入bin目录
注意 -c 请加上，不加后面客户端使用时可能会出问题
#启动
nohup sh bin/mqbroker -c conf/broker.conf &
# 关闭
sh bin/mqshutdown broker
- 测试服务
jps
# 测试发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 测试接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
二、部署搭建可视化dashboard
-
克隆https://github.com/apache/rocketmq-dashboard/tree/release-1.0.0的代码
-
修改yml中nameServer地址
-
然后运行或者打包后运行，在浏览器中直接访问该服务地址
三、修改nameserver端口号
启动nameserver，出现以下问题时是端口被占用
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:134)
at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:562)
at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1334)
at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:506)
修改端口号方法如下：
cd ./conf
## 创建文件
vi namesrv.properties
# 输入下面内容
listenPort=9092 #输入这一行
# 使用配置重新启动
nohup sh bin/mqnamesrv -c ./conf/namesrv.properties &
