1. 概述

jpaas 使用 rocketmq 作为消息队列中间件，他的作用主要是流程异步消息，OFFICE文档异步转换，流程异步事件，日志等等。
本文重点为rocketmq的安装和配置，rabbitmq参考第 4 、5 点。

2.操作步骤

2.1. 安装rocketmq

文件路径在 jpaas\jpaas\metadata\software\下有rocketmq安装包、启动脚本、jar包

2.2 启动 mqbroker.cmd 和 mqnamesrv.cmd

broker 是MQ的消息中转角色,负责存储消息,转发消息;
namesrv 是在系统中是做命名服务，更新和发现 broker服务。

start mqnamesrv.cmd
//这里需要指定 autoCreateTopicEnable 为 true,表示允许自动创建队列
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

2.2.1 前提：rocketmq 功能已验证成功

2.3 rocketmq 的配置

rocketmq的配置分开在各个微服务当中配置了所以不需要再另行配置了。不过还是检查一下以下配置：

2.3.1 在 \jpaas\jpaas-service\jpaas-share 下，修改 pom.xml 文件

2.3.2 修改 NACOS 配置的 nacos-config-dev.properties 文件

2.3.3 rocketmq配置信息存于以下nacos配置文件中

2.3.3.1 配置文件 jpaas-bpm-dev.properties

2.3.3.2 配置文件 jpaas-user-dev.properties

2.3.3.3 配置文件 jpaas-system-dev.properties

# ROCKETMQ系统消息
spring.cloud.stream.bindings.output.destination=bpmmessage
spring.cloud.stream.bindings.output.group= bpmmessage-group
spring.cloud.stream.bindings.input.destination= bpmmessage
spring.cloud.stream.bindings.input.group= bpmmessage-group-consumer
# 邮件消息
spring.cloud.stream.bindings.mailOutput.destination=mail
spring.cloud.stream.bindings.mailOutput.group= mail-group
spring.cloud.stream.bindings.mailInput.destination= mail
spring.cloud.stream.bindings.mailInput.group= mail-group-consumer
# 流程异步事件
spring.cloud.stream.bindings.eventOutput.destination=event
spring.cloud.stream.bindings.eventOutput.group= event-group
spring.cloud.stream.bindings.eventInput.destination= event
spring.cloud.stream.bindings.eventInput.group= event-group-consumer
# 附件转换消息
spring.cloud.stream.bindings.fileOutput.destination=file
spring.cloud.stream.bindings.fileOutput.group= file-group
spring.cloud.stream.bindings.fileInput.destination= file
spring.cloud.stream.bindings.fileInput.group= file-group-consumer

2.4 rocketmq控制台运行

前提：已经启动 mqbroker.cmd 和 mqnamesrv.cmd
windows下，直接 双击运行run.bat 即可打开控制台。

3. 服务器上运行rocketmq

3.1 下载已编译的安装包

在官网下载 rocketmq-all-4.5.0-bin-release 已经编译过的安装包

启动生产者和消费者命令

nohup sh ./mqnamesrv &
nohup sh ./mqbroker -n localhost:9876 autoCreateTopicEnable=true  &

启动控制台管理界面

java -jar rocketmq-console-ng-1.0.0.jar --server.port=7777 --rocketmq.config.namesrvAddr=192.168.1.107:9876

指定服务控制台访问端口
部署rocketmq的服务器地址
服务默认端口9876

3.2 访问平台

输入 ip:port访问 管理界面

4. 安装rabbitmq

http://doc.redxun.cn/docs/jpaas//124

5. 切换rabbitmq

http://doc.redxun.cn/docs/jpaas//122