Apache RocketMQ 消息队列部署与可视化界面安装

1、介绍

Apache RocketMQ是一个分布式、队列模型的消息中间件，具备低延迟、高性能和高可靠、万亿级容量和灵活的可扩展性。核心组件由四部分组成：Name Servers，Brokers，Producer 和 Consumer；它们中的每个均可以水平扩展，而没有单一的故障节点。

1. NameServer：是一个几乎无状态的节点，可集群部署，节点之间无任何信息同步
2. Broker：部署相对复杂，Broker分为Master与Slave，一个Master能够对应多个Slaver，可是一个Slaver只能对应一个Master，Master与Slaver的对应关系经过指定相同的BrokerName，不一样的BrokerId来定义，BrokerId为0表示Master，非0表示Slaver。Master能够部署多个。每一个Broker与NameServer集群中的全部节点创建长链接，定时注册Topic信息到全部的NameServer
3. Producer：与NameServer集群中的其中一个节点（随机选择）创建长链接，按期从NameServer取Topic路由信息，并向提供Topic服务的Master创建长链接，且定时向Master发送心跳。Produce彻底无状态，可集群部署
4. Consumer：与NameServer集群中的其中一个节点（随机选择）创建长链接，按期从NameServer取Topic路由信息，并向提供Topic服务的Master、Slaver创建长链接，且定时向Master、Slaver发送心跳。Consumer便可从Master订阅消息，也能够从Slave订阅消息，订阅规则由Broker配置决定

 

2、MQ安装部署

2.1. 下载

直接找最新版下载后解压 rocketmq.apache.org/release_not…

 

2.2. 修改配置

修改 conf/broker.conf 添加如下配置

brokerIP1：配置broker所在服务器的ip地址，以便Name Server链接

  修改 runserver.sh 和 runbroker.sh (可不改) 由于rocketMQ默认的启动参数内存占用很是大，若是环境没有这么多内存就必需修改JAVA_OPT参数

• runserver.sh

  

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
复制代码

• runbroker.sh

  

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
复制代码

 

2.3. 运行Name Server

nohup sh bin/mqnamesrv &
复制代码

查看运行日志：tail -f ~/logs/rocketmqlogs/namesrv.log

 

2.4. 运行Broker

nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
复制代码

经过-c参数指定配置文件 查看运行日志：tail -f ~/logs/rocketmqlogs/broker.log

 

2.5. 中止服务的方式

若是须要中止RocketMQ的服务，在生产环境不建议直接用kill，应该使用如下命令

sh bin/mqshutdown broker

sh bin/mqshutdown namesrv
复制代码

 

3、安装可视化管理界面

• 下载 github.com/apache/rock…
• 编译

mvn clean package -Dmaven.test.skip=true
复制代码

• 运行

nohup java -jar \
    -Drocketmq.config.namesrvAddr=192.168.28.130:9876 \
    -Drocketmq.config.isVIPChannel=false \
    rocketmq-console-ng-1.0.0.jar &
复制代码

• 访问 http://192.168.28.130:8080/

  

 

4、常见异常处理

4.1. MQClientException: No route info of this topic, TopicTest1

4.1.1. 异常说明

在客户端的 Producer 运行起来准备发送消息时抛异常为 “ No route info of this topic ” 异常产生的缘由多是：

1. Broker 禁止自动建立 Topic，且用户没有经过手工方式建立 Topic
2. Broker 没有正确链接到 Name Server
3. Producer 没有正确链接到 Name Server

 

4.1.2. 解决办法

• 排查1：Broker 禁止自动建立 Topic，且用户没有经过手工方式建立 Topic
  • 能够在rocketmq所在目录下执行 " sh bin/mqbroker -m " 来查看 broker 的配置参数
  • 以下所示，autoCreateTopicEnable=true 证实是没有问题的

    

 

• 排查2：Broker 没有正确链接到 Name Server 经过查看broker的日志 tail -f ~/logs/rocketmqlogs/broker.log 看看有没有错误信息

 

• 排查3：Producer 没有正确链接到 Name Server
  1. 检查程序链接 Name Server 的地址有没有错
  2. 若是在云服务器上，检查安全组的配置9876端口有没有开发
  3. 看看有没有打开防火墙，有的话设置防火墙开放9876端口 bash [root@zlt rocketmq-all-4.5.0-bin-release]# firewall-cmd --zone=public --list-ports 8090/tcp 80/tcp 8080/tcp [root@zlt rocketmq-all-4.5.0-bin-release]# firewall-cmd --zone=public --add-port=9876/tcp --permanent success [root@zlt rocketmq-all-4.5.0-bin-release]# firewall-cmd --reload success [root@zlt rocketmq-all-4.5.0-bin-release]# firewall-cmd --zone=public --list-ports 9876/tcp 8090/tcp 80/tcp 8080/tcp

 

4.2. RemotingTooMuchRequestException: sendDefaultImpl call timeout

4.2.1. 异常说明

• 在客户端的 Producer 运行起来准备发送消息时抛异常以下
• 一般由于Name Server链接不上Broker

  

 

4.2.2. 解决办法

检查 rocketmq-console 的集群页签，broker 的地址是否正确

broker地址的配置方式请参考 安装部署 中提到的步骤：

1. 修改 broker.conf 的配置，添加 brokerIP1 参数
2. 启动 broker 时加上 -c 参数指定配置文件

 

4.3. 消费/查看不了死信队列topic的消息

4.3.1. 异常说明

死信队列默认的 perm 值为2没有查看权限  

4.3.2. 解决办法

在控制台把队列的 perm 改成6就能够了 **主题点击 TOPIC配置 **

修改perm

 

推荐阅读

• 日志排查问题困难？分布式日志链路跟踪来帮你
• zuul集成Sentinel最新的网关流控组件
• 阿里注册中心Nacos生产部署方案
• Spring Boot自定义配置项在IDE里面实现自动提示
• Spring Cloud Zuul的动态路由怎样作？集成Nacos实现很简单
• Spring Cloud开发人员如何解决服务冲突和实例乱窜？
• Spring Cloud同步场景分布式事务怎样作？试试Seata

  扫码关注有惊喜！