# 下游系统采用MQ的方式对接统一待办中心获取数据

来源快照：`result_data_new_260518.json`

- 来源 ID：`1181492207129796625`
- 模块：集成中心
- 目录：统一待办中心 - 配置示例
- space ID：`1158011075224911873`
- 原文链接：未提供
- 产品基线：未提供

## 正文

# 一、需求背景

已有功能可通过消息中心对接下游系统，现增加MQ方式。当对接下游系统时，可以通过对接MQ队列的方式获取流程数据信息：

【统一待办中心（生产者）】——【ECology的MQ通道】——【下游消费者A】

                                                                              |————【下游消费者B】

                                                                              |————【下游消费者C】

                                                                              |————【下游消费者D】

                                                                              |————【下游消费者E】

消息队列——统一待办中心将租户中上游系统调用数据同步到消息队列，下游系统可作为MQ消费者获取队列中数据

# 二、操作步骤：

## 1.消息队列

位置：统一待办中心集成-功能设置-消息队列设置

下游系统获取消息数据队列

队列名：weaver-intunifytodo-server-[租户key]-producer-[字符串]（以租户划分，租户与消息队列一一对应）

![](https://weapp.eteams.cn/papi/file/preview?fileId=1181492254344421376&type=redirect&customParam=%7B%22isExtDist%22%3Atrue%2C%22distributeId%22%3A%22%22%2C%22externalId%22%3A%22%22%2C%22appId%22%3A%22%22%7D)

 

消息队列开启后，下游系统可在对应mq中获取消息数据信息

![](https://weapp.eteams.cn/papi/file/preview?fileId=1181492258528763907&type=redirect&customParam=%7B%22isExtDist%22%3Atrue%2C%22distributeId%22%3A%22%22%2C%22externalId%22%3A%22%22%2C%22appId%22%3A%22%22%7D)

 

## 2.消息队列异常提醒

位置：统一待办中心集成-功能设置-消息队列设置

检测数据超过阈值[消息队列MQ数据超过10000条]未处理时，触发熔断机制。后续响应记录数据库iut_sys_queue_message，并触发异常提醒；

开启队列异常提醒，可指定人员（角色）提醒到对应IM/云桥/邮箱/短信

提醒标题：“统一审批中心消息队列预警提醒”

提醒内容：您当前使用的统一审中心消息队列(队列名称: #[queueName] )，因队列堆积数据已超过阈值，停止数据写入，请及时通知订阅方消费数据。”。#[queueName]为队列名称

![](https://weapp.eteams.cn/papi/file/preview?fileId=1181492254309294082&type=redirect&customParam=%7B%22isExtDist%22%3Atrue%2C%22distributeId%22%3A%22%22%2C%22externalId%22%3A%22%22%2C%22appId%22%3A%22%22%7D)

熔断恢复：

定时任务每5分钟执行一次已熔断队列检测，队列数据低于(阈值/2)时[响应MQ未处理数据低于5000条]，触发恢复机制

恢复机制触发后，iut_sys_queue_message中数据推送到对应响应队列中，并删除相关数据（delete=3）

 

## 3.开发相关

### 3.1下游系统对接MQ获取数据参数说明：

[ _https://weapp.eteams.cn/sp/ebdpage/view/freepass/1152863419640021002?id=1181387366910992408 &freepass_doc=1&space_id=1158011075224911873_](https://weapp.eteams.cn/sp/ebdpage/view/freepass/1152863419640021002?id=1181387366910992408&freepass_doc=1&space_id=1158011075224911873)

 

![](https://weapp.eteams.cn/papi/file/preview?fileId=1181492254238916609&type=redirect&customParam=%7B%22isExtDist%22%3Atrue%2C%22distributeId%22%3A%22%22%2C%22externalId%22%3A%22%22%2C%22appId%22%3A%22%22%7D)
