tencent cloud

消息队列 Pulsar 版

动态与公告
新功能发布记录
集群版本更新记录
产品公告
产品简介
TDMQ 产品系列介绍与选型
什么是消息队列 Pulsar 版
产品优势
应用场景
技术原理
产品系列
开源 Pulsar 版本支持说明
与开源 Pulsar 对比
高可用
配额与限制
基础概念
产品计费
计费概述
价格说明
计费示例
续费说明
查看消费明细
欠费说明
退费说明
快速入门
入门流程指引
准备工作
使用 SDK 收发普通消息
使用 SDK 收发高级特性消息
用户指南
使用流程指引
配置账号权限
新建集群
配置命名空间
配置 Topic
连接集群
管理集群
查询消息及轨迹
跨地域复制
查看监控和配置告警
实践教程
客户端使用实践
异常消费者隔离
限流机制说明
交易对账
消息幂等性
消息压缩
迁移指南
单写多读集群迁移方案
虚拟集群平滑迁移至专业集群
API 参考
API 概览
SDK 参考
SDK 概述
SDK 配置参数推荐
TCP 协议(Pulsar 社区版)
安全与合规
权限管理
删除保护
云 API 审计
常见问题
监控相关
客户端相关
服务协议
服务等级协议
TDMQ 政策
联系我们
词汇表

交易对账

PDF
聚焦模式
字号
最后更新时间: 2025-12-24 15:24:31

场景描述

对账是任何一个计费系统都需要的一个辅助系统。无论是对账作为支付的主路或是旁路系统,为了保证计费的准确性,都需要在支付过程中或支付完成之后进行对账。通过引入 TDMQ Pulsar 版,一方面保证了对账的时效性,另一方面也不会影响交易的关键路径。

遇到的问题

1. 系统解耦 交易涉及系统众多,系统之间需要解耦,避免互相影响。
2. 数据到达时间差 系统之间数据到达会有时间差,保证不同时间到达的数据能够聚合计算。
3. 数据一致性 保证数据不丢失,不会因为数据丢失造成对账结果异常。
4. 跨区域数据传输 系统部署分布在不同的地区,需要进行跨区域的数据传输。

部署架构图





问题解决

我们将根据上面提到的问题,使用 TDMQ Pulsar 版的解决方式。

1. 系统解耦问题

直观的看,为了实现各个系统之间的对账,我们可以直接将消息上报给对账系统,对账系统负责接受消息并进行对账处理。但是这里又面临一些问题,这里需要对接的系统很多,并且系统还会不断的增加。这样会花费大量的时间在系统之间的对接上,并且对现网的系统流程的侵入性就会非常大。显然,这样的设计是非常不合理的。我们通过 TDMQ Pulsar 版的引入,使得系统之间只需要和 MQ 进行统一对接,这样单个系统的问题也不会影响到其他服务。

2. 数据到达时间差问题

对账需要进行各个系统之间的数据聚合,要想进行实时的数据聚合,正常情况下数据到达的时间不会相差太大,但是因为系统之间的流程总是会有先后,当一个系统的数据延迟之后,为了能够实现数据的聚合,我们需要控制数据的读取速度,以免大量数据进入到对账系统中等待。通过 TDMQ Pulsar 版的暂时存储消息,使得同一时间的数据到达时间大致相同。

3. 数据一致性问题

TDMQ Pulsar 版提供高一致的可靠数据存储,保证数据不会丢失,同时提供高可用的服务,异常情况下能够快速自动修复。

4. 跨区域数据传输问题

TDMQ Pulsar 版提供两种方案来实现多个城市之间的数据复制,为业务层提供实时数据复制通道。
对于非常重要的数据需要满足跨城容灾级别的场景,可以支持多个区域之间进行强一致性的数据同步,使得消息的存储分布在不同的区域。
对于一些数据并不需要强一致要求的场景,TDMQ Pulsar 版提供多城市之间异步复制方案,来达到多地数据最终一致。
两种跨城同步方案的对比如下:
跨城方案
生产耗时
容灾性
存储成本
多城市强一致
多城市最终一致
通过引入 TDMQ Pulsar 版和实时计算的能力,我们将交易对账从按天的模式发展为实时对账的模式。更加快速的检测交易的准确性。

帮助和支持

本页内容是否解决了您的问题?

填写满意度调查问卷,共创更好文档体验。

文档反馈