(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210921245.2 (22)申请日 2022.08.02 (71)申请人 深圳市雁联计算系统有限公司 地址 518017 广东省深圳市福田区福保街 道市花路一号创凌通科技大厦B座15 楼 (72)发明人 杨瀚　李家菁　汪日清　刘湘璇　 杜晓雪　 (74)专利代理 机构 广州市华学知识产权代理有 限公司 4 4245 专利代理师 于波 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/215(2019.01) G06F 16/25(2019.01)G06F 16/28(2019.01) G06F 9/54(2006.01) G06Q 40/04(2012.01) (54)发明名称 一种基于Redis的对账方法及系统 (57)摘要 本发明公开了一种基于Redi s的对账方法及 系统， 该方法包括： 依托调度框架， 定时触发对账 任务初始化流程， 生成对账任务； 将对账任务写 入延迟队列， 定时拉取对账文件； 解析对账文件 并转换数据统一格式； 拉取、 清洗、 过滤系统交易 数据； 通过 Redis比对对账数据与系统交易数据， 得出交集与差集， 完成对账。 本发明基于分布式 调度框架和延 迟队列的消息处理机制， 具有开发 难度低、 代码入侵少 、 防止单点故障、 时效性更高 的优点， 防止重复轮询和扫描数据库给予系统及 数据库性能压力； 本发明还基于Redis的数据对 比， 与传统对账方式相比， 在数据量庞大时， 耗时 有明显的下降， 同时也减轻了数据库的压力， 减 少了部署成本 。 权利要求书2页 说明书8页 附图7页 CN 115145939 A 2022.10.04 CN 115145939 A 1.一种基于Redis的对账 方法， 其特 征在于， 包括以下步骤： 依托调度框架， 定时触发对账任务初始化流程， 根据各支付渠道对账文件配置模板生 成对账任务； 将对账任务写入延迟队列， 在 符合拉取规则时触发延迟队列发送对应支付渠道对账文 件拉取消息， 拉取对账文件； 配置各渠道所拉取的对账文件类型、 报文格式后， 将各渠道对账 数据转换为统一格式； 拉取与各渠道对账 数据对应的系统 交易数据， 并对系统 交易数据进行清洗过 滤； 将相应的渠道对账数据与系统交易数据按照Redis对比指定格式分别推送至Redis集 群两个集 合中， 然后对集 合进行对比并生成对账 结果。 2.根据权利 要求1所述的基于Redis的对账方法， 其特征在于， 所述拉取对账文件后， 还 包括将拉取的对账文件 存入MinIO， 具体包括： 计算所拉取对账文件MD5值， 并用MD5值作为Mi nIO对象名； 通过对象名调用Mi nIO封装方法对 对账文件进行查重； 如果已存在则直接返回对账文件拉取成功； 如果不存在则通过MinIO上传封装方法将 对账文件上传至MinIO指定对象桶存储， 对账文件上传成功后MinIO返回对象名， 然后 返回 对账文件拉取成功； 更新相关数据与Mi nIO对象名进行关联。 3.根据权利要求2所述的基于Redis的对账方法， 其特征在于， 所述将各渠道对账数据 转换为统一格式是通过文件解析引擎， 根据对 账文件渠道类型、 MinIO对象桶名、 MinIO对象 名进行对账 数据的解析及转换处 理。 4.根据权利要求3所述的基于Redis的对账方法， 其特征在于， 所述将各渠道对账数据 转换为统一格式具体包括： 文件解析引擎通过MinIO对象桶名、 MinIO对象名下载对应对账文件， 然后转换为文件 流推入文件解析引擎； 文件解析引擎判断文件是否为Txt文件， 如果 不是则将其 转为Txt； 文件统一为Txt后， 文件解析引擎获取对应渠道 的对账文件字段与统一格式字段的映 射关系； 引擎内部的解析工厂通过动态代理框架， 按照配置信 息与解析模版动态创建对应渠道 的解析实现类； 调用动态实现类对文件进行 逐行解析转换为统一格式。 5.根据权利要求 4所述的基于Redis的对账 方法， 其特 征在于， 所述方法还 包括： 如果当前解析模版不 适用于当前渠道， 则编写具体解析代码、 打包成Jar文件并上传； 文件解析引擎在解析时判断当前渠道是否存在 自定义实现方法， 若存在， 则通过自封 装类加载器将Jar文件中对应的Clas s文件加载进入系统； 通过动态 代理框架为 解析接口代理自定义实现方法完成文件解析操作。 6.根据权利要求1所述的基于Redis的对账方法， 其特征在于， 所述对集合进行对比并 生成对账 结果包括： 对两个集 合进行对比， 得 出交集， 并存 入Redis交集 集合中； 对两个集 合进行对比， 得 出差集， 并存 入Redis差集 集合中；权　利　要　求　书 1/2 页 2 CN 115145939 A 2获取Redis交集中的数据， 将对应数据的对账 数据更新 为对账完成； 获取Redis差集中的数据， 判断对应数据属于何种差异， 若是系 统能自行纠错的差异， 则系统自行纠错并将对应数据的对账 数据更新 为对账完成； 若不能进行自行纠错则将对应数据的对账数据更新为对账错误， 并写入对账差错表 中。 7.根据权利要求1所述的基于Redis的对账方法， 其特征在于， 所述拉取对账文件若拉 取失败， 则拉取消息回滚至延迟队列消息队列中， 延迟后再次触发。 8.根据权利要求1所述的基于Redis的对账方法， 其特征在于， 所述对集合进行对比并 生成对账结果后， 还包括出具对账结果报表： 统计各渠道对账数据、 差错数据， 处理数据并 生成报表。 9.根据权利 要求1至8任一项所述的基于Redis的对账方法， 其特征在于， 所述方法每个 步骤均设有相应的监控及事 件报警。 10.一种基于Redis的对账系统， 其特 征在于， 包括以下模块： 任务初始化模块： 用于定时触发对账任务初始化流程， 根据各支付渠道对账文件配置 模板生成对账任务； 第一获取模块： 用于根据延迟队列发送对应支付渠道对账文件拉取消息， 拉取对账文 件； 文件解析模块： 用于配置各渠道所拉取的对账文件类型、 报文格式， 将各渠道对账数据 转换为统一格式； 第二获取模块： 用于拉取与第一获取模块所拉取对账文件对应的系统交易数据， 并将 其清洗过 滤； 对账模块： 用于将第一获取模块和第二获取模块所获取的数据按照Redis对比指定格 式分别推送至Redis集群两个集 合中， 对集 合进行对比， 完成对账。权　利　要　求　书 2/2 页 3 CN 115145939 A 3