国泰君安期货：基于分布式架构的智能推送系统，满足单日亿级消息处理量

本文主要是介绍国泰君安期货：基于分布式架构的智能推送系统，满足单日亿级消息处理量，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

中国期货市场正经历着从量变到质变、加速提档的过程。近五年来，新增期权期货交易品种过百个，国际化品种大幅增加，市场交易规模迅速扩大。2022 年期货行业单边成交量约 70 亿手，为 2018 年的 2.5 倍，占全球总成交量的 8.07%。其中，国内商品期货与期权成交量为 66.16 亿手，占全球商品期货与期权总成交量 91.53 亿手的 72.3%。中国期货行业总资产、客户权益均比 5 年前翻了一番。

期货业态走向多元化，目前已形成包括期货经纪、投资咨询、资产管理、风险管理等在内的服务体系，尤其是期货资产管理、风险管理子公司两项创新业务的推出，令期货公司服务实体经济的手段得以丰富，发展之路渐行渐宽，前景光明。

2021 年，证监会发布《证券期货业科技发展“十四五”规划》，主要围绕“推进证券期货行业数字化转型发展” 与“数据让监管更加智慧”两大主线，旨在依托新一代信息技术，建设敏捷高效可复用的新一代数字技术基础设施，提升核心架构安全可控水平，为业务数字化创新提供高效的一体化服务支撑。

为适应国内外期货市场不断变化，及时满足和响应业务发展需求，国泰君安期货（以下简称“国君期货”）将金融科技上升为公司战略，加快公司数字化转型，推动公司业务模式、服务模式和工作模式的创新发展。

期货行业对于业务的连续性和低延时都有着较高的要求，无论是期货交易还是客户服务，现有的 IT 基础架构已无法满足不断变化的业务应用场景需求。如：量化交易、实时分析、精细化运营、消息推送、个性化服务等。

目前传统期货业 IT 架构面临着诸多问题和挑战。主要体现在以下几个方面：系统大多分散维护，烟囱式发展，导致统一架构规划困难，缺乏资源弹性管理基础；系统紧耦合，导致新功能开发周期长工作量大、业务故障恢复周期长；数据平台建设与业务发展存在鸿沟，业务和技术融合不畅；缺乏数据治理手段，数据孤岛问题日趋严峻。

针对上述挑战，国君期货近年来积极主动与国产厂商深度合作，针对服务器、数据库、操作系统、应用软件等产品进行技术研究，探索新一代业务系统向分布式架构转型。

在传统 IT 架构向国产分布式架构转型过程中，数据库架构的转型是十分关键的一环。国君期货原有的数据库多为集中式数据库。随着业务量的增加和交易方式的演变, 人均智能设备使用越来越多，期货业产生的数据量呈几何级增长。因此，对数据库的扩展性和处理能力提出了更高的要求，传统的单机和集中式数据库架构在应对海量数据并行处理中逐渐显露疲态与不足。

期货公司移动端线上零售业务的开展，需要通过消息通知等方式来主动触达客户，以促进用户留存和业务转化。以往，传统模式人工收集信息后依经验选择推送时机和目标用户，只能局限于粗放式小规模的推送运营，无法对场景和用户进行精细化识别，更无法完成个性化触达。智能推送系统通过对业务和用户数据的标准化治理以及下游规则引擎的搭建，实现了“搭积木”式的场景构建，当业务事件触发时，自动匹配用户准确发送消息，而无需人工进行干预。

国君期货智能推送系统单日数据增量已达亿级, 原基于 MySQL 的架构，已经无法满足实时写入、高并发查询、海量历史数据存储等业务需求。经过研究论证，国君期货将智能推送系统从旧的单体架构升级为可水平扩展的分布式架构，采用完全自研的国产原生分布式数据库 OceanBase+国产 ARM 服务器，替换掉原有的 MySQL 数据库+中高配 X86 服务器。

实现了垂直单体架构数据库向分布式数据库架构的平滑替换，采用分布式架构的智能推送系统，结合 OceanBase 分区级负载均衡能力, 使业务集群整体具备了高性能和高扩展性。在行情异动、账户风险率预警、持仓合约临近交割、异常交易预警等场景下充分发挥快速、精准的优势，显著提升用户体验，将业务部门从以往手工式通知联系客户的各种繁琐工作中解放出来。