# 上游系统采用MQ的方式对接统一待办中心推送数据

来源快照：`result_data_new_260518.json`

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

## 正文

# 一、需求背景

当第三方系统的流程数据并发量太大时，可以通过对接MQ队列的方式调用统一待办接口

请求过程：

【业务系统A】——【ECology的MQ队列】——【统一待办中心】

【业务系统B】—|

响应过程：

【统一待办中心（发送响应）】——【ECology的MQ队列A】——【业务系统A】

                                                 |—【ECology的MQ队列B】——【业务系统B】

请求队列——处理所有上游系统需要入库的数据

响应队列——将数据处理的结果反馈给上游系统，告知失败的原因或者成功的结果。

# 二、操作步骤

## 1\. 请求队列

请求队列：处理所有上游系统需要入库的数据

上游系统：生成流程数据队列

队列名：weaver-intunifytodo-server-receive-producer-queue（固定队列，队列唯一）

消费者：以租户划分，每个租户生成相应单一消费者

![](https://weapp.eteams.cn/papi/file/preview?fileId=1181492503364050944&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\. 响应队列

响应队列：将数据处理的结果反馈给上游系统，告知失败的原因或者成功的结果

配置信息：统一待办中心集成-应用系统-基础设置-消息队列设置

![](https://weapp.eteams.cn/papi/file/preview?fileId=1203663846172835855&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)

启用后自动生成队列名，队列名格式：

weaver-intunifytodo-server-[租户key]-[异构系统标识]-producer-[字符串]

上游系统根据队列名获取接口响应队列

说明：只有使用了请求队列，响应队列开启后才生效

## 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)
