消息订阅主题

变更记录

1 简介

1.1 功能介绍

用户可以根据实际的消息消费者角色来创建订阅主题，完成消息容器的建立。苍穹消息集成采用的是订阅（Subscribe）模式，该模式下消息的接收者之间的耦合关系变得松散，只需要根据消息的主题进行消息的订阅。

1.2 应用场景

启动方案可以配置消息订阅主题（队列名以主题编码命名），实现从MQ系统取数，完成数据集成任务。MQ作为消费者目前仅“消息驱动”类启动方案，以MQ队列作为数据来源。

注意：对于集成云来说消息队列属于外部数据源，不建议在集成云中将数据发布到队列，然后又用另一个方案进行消费同一个集成云发布的消息。

1.3 系统路径

【集成管理】→【消息集成】→【消息集成配置】→【订阅主题】

1.4 字段/按钮说明

字段说明：

按钮说明：

2 主要操作

2.1 新增消息订阅主题

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

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

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

步骤2：填写订阅主题基本信息

步骤3：设置“消息解析脚本”与“消息摘要模板”

订阅者IP:* 表示任意服务器均可订阅； xxx.xxx.xxx.xxx 表示指定IP地址服务器可以订阅； xxx.xxx.* 表示IP地址前缀匹配的服务器可以订阅； 如果需要设置多个IP地址模式，则以逗号（,）分隔。

注意：如果是开发环境自己调试，请设置指定IP,例如本地苍穹的服务器IP，否则可能会被其他苍穹系统订阅并消费。

启用消息订阅主题后，系统会为MQ生成对应的队列，可以在RabbitMQ的控制台查看队列信息。

启用消息订阅主题，kafka生成对应列队。可以通过命令行的方式查询kafka的队列信息。

windows版：在kafka安装目录下\bin\windows下，执行如下命令：

k