变更记录

1 简介

1.1 功能介绍

用户可以根据实际生产者来创建发布主题，完成消息容器的建立。苍穹消息集成采用的是发布（Publish）模式，该模式下消息的发送者之间的耦合关系变得松散，只需要根据消息的主题进行消息的发布。

1.2 应用场景

启动方案通过配置消息发布主题，可以发送源单数据到MQ队列，其他系统就可以订阅和消费这些数据。

集成云支持订阅MQ队列，把消息推送到单据操作或者微服务方法上。

1.3 系统路径

【集成管理】→【消息集成】→【消息集成配置】→【发布主题】

1.4 字段/按钮说明

字段说明：

按钮说明：

2 主要操作

2.1 新增消息发布主题

步骤1：请在发布主题列表中选择“新增”消息发布主题

使用前提：业务方已经存在消费者队列，负责消费数据。

注意：新增是用于配置正常的新队列，如果导入的是启动方案，导入时会自动建立所需的没有关联消息服务器的“消息主题”，此处只需要修改消息主题的消息服务器即可。

步骤2：填写发布主题基本信息

步骤3：设置“消息格式化脚本”与“消息摘要模板”

注意：“消息摘要模板”最多支持存储100个字符。通过集成对象列表中的“字段编码”获取摘要信息，例如：#{$data.field_name}。 如果需要多个字段，可采用如下格式： #{$data.field1}，#{$data.field2} （其中“，”为分隔符，可自定义设置分隔符）。

举例：MQ作为生产者，将目标数据推送到消息队列。以供应商分类标准同步为例，当前苍穹作为触发点，将同步消息推送至MQ（启动方案的传输方式“目标数据推送方式”选择“消息队列”，选择之前配置好的消息发布主题）

2.2 RocketMQ延时发送设置

使用前提：新增消息发布主题时选择的队列服务器类型为外部RocketMQ。

操作步骤：在消息发布主题表单页面可以设置延时时间，设置延时时间以后，则发送到该队列服务器的消息将在延时时间后推送到对应的订阅主题。

2.3 RabbitMQ参数配置

使用前提：新增消息发布主题时选择的队列服务器类型为外部RabbitMQ。

操作步骤：新建消息发布主题，类型选择外部RabbitMQ，点击‘自定义参数配置项’展开参数配置表单，可以配置exchange和routingKey参数。

注：当参数不配置时，默认exchange是exchangeName，routingKey是routingKey。

当配置了该参数后，经由该主题发布的消息将发送到对应的exchange中，并根据该exchange的类型配routingKey投递到对应的队列中。

如：当exchange类型是Direct时，将会把消息投递到routingKey严格相同的队列中。

2.4 外部Kafka自定义参数配置

使用前提：新增消息发布主题时选择的队列服务器类型为外部Kafka。

操作步骤：新建消息发布主题，类型选择外部Kafka，点击‘自定义参数配置项’展开参数配置表单，可以配置参数。

注：参数配置后需要重连队列服务才能生效（队列服务-重连）。