博时基金基于RocketMQ的互联网开放平台Matrix架构实践

随着近两年业绩的抢眼，公募基金迎来了乘风破浪式的发展，截至 2021 年 1 月底，资产管理规模已破 20 万亿，创下了历史新高。

在中国新经济高质量及科技创新发展的背景下，众多金融类的互联网平台与基金公司展开合作，互联网金融科技与传统金融业务的融合，促使传统金融公司的信息技术系统更加开放。

据此，2020 年，博时基金互联网金融部启动了互联网开放平台 Matrix 的建设工作。

博时基金互联网开放平台 Matrix

建设背景与目标

1、传统金融架构遇到的问题与挑战

传统的金融系统架构受到了互联网化的挑战，主要表现在以下几个方面：

1) 互联网入口缺乏管控

有多个团队提供不同形式的互联网服务，接口协议和权限管控方式不一致。当服务和接口越来越多时，API 管控能力不足的问题将会突显。

2) 系统较为封闭，开放能力不足

传统基金行业系统生态较为封闭，与合作伙伴开放生态的能力有待提升。

3) 金融场景化封装能力不足

传统基金行业系统普遍依赖于底层数据库提供的 ACID 特性实现事务一致性。微服务化之后，这套机制对金融场景化的产品包装能力显得捉襟见肘。

2、系统建设目标

1）多渠道统一安全接入

为自有系统与运营厂商提供标准化统一接入，实现内外部 API 统一的管控。

Matrix 开放给经过博时互联网平台资质认证后的第三方平台使用，需要根据第三方平台识别的不同身份，进行接口级别权限管控。

2）提供开放能力

搭建开放平台，与合作伙伴共建开放生态。在得到 Matrix 平台的授权后，第三方平台开发者可以通过调用博时基金互联网开放平台的接口能力，为第三方平台提供基金产品信息查询、注册开户、积分兑换、基金申赎、资产查询、联合登录等全方位服务；第三方平台可以根据自身实际情况自由选择或组合 APP 、微信公众号、微信小程序、H5 等前端方式对接。

3）封装基金行业特色功能

应用层实现分布式事务框架以保证整体事务的一致性。基于此，封装优惠购、投资陪伴等复杂的金融场景化功能，让开发者专注于业务开发，提升客户的投资体验。

建设思路

1、总体架构

1）互联网架构图

基于 Spring Cloud 微服务套件和 RocketMQ 消息中间件，搭建的企业级云原生架构。

2、关键组件

1）API 网关

API 网关是微服务架构重要组件之一，是服务唯一入口。API 网关封装内部系统架构，横向抽离通用功能，如：权限校验、熔断限流、负载均衡等。通过 API 网关可以把内部 API 统一管控起来。

目前博时基金的互联网业务接入入口主要分为3类：

• 面向自营业务的博时基金移动端 APP 和 H5 。

• 面向合作伙伴的 OpenAPI 。即作为开放平台的入口，服务的 OpenAPI 会提供有条件的访问限制（时间、流量、频率），需要考虑流量控制、安全认证、接口授权方面的管理。

• 面向企业内部管理系统的 API ，提供企业内部系统访问。

Matrix 的 API 网关基于 Spring Cloud Gateway 构建，SCG 内置的 Route、Predicate 和 Filter 模块可以方便扩展出路由转发、统一鉴权等跨横切面的功能。基于内外部网络隔离的需求，我们独立部署了两套网关，其中 Kylin 网关提供互联网接入。Phoenix 网关用于域内系统接入，提供域账户的访问权限控制。

2）认证中心

为了保护 OpenAPI 的安全，避免恶意访问、未授权访问、黑客攻击等导致的安全隐患，开放平台需要增加授权认证模块。同时，在博时的内部的应用系统之间，也有单点登录的需求。统一的认证中心是微服务架构的必备组件。

Matrix 基于 OAuth2 协议构建了统一认证中心，实现用户、应用、接口的统一认证和鉴权。OAuth2 核心思路是通过各类认证手段认证用户身份，并颁发 Token ，使得第三方应用可以使用该令牌在限定时间、限定范围访问指定资源。Matrix 支持 OAuth2 的 Authorization Code 、Resource Owner Credentials 和 Client Credentials 三种授权类型，根据不同的应用场景，采用不同的授权类型颁发 Token ，为开放平台的安全保驾护航。

3）RocketMQ 消息中间件

技术选型

在技术选型过程中，我们主要考虑以下几点：首先必须是国产化的产品，其次是比较流行并且社区活跃度高的开源产品。另外，重点关注的 MQ 特性：

• 消息可靠传递，即确保不丢消息。

• 分布式事务，需要支持分布式事务，降低业务的复杂性。

• 性能，我们的场景主要是在线的金融类业务，需要 MQ 具备支持金融级的低延迟特性。

最后，从架构演进的角度来考虑，需要无缝对接我们的混合云架构，最终我们选择了 RocketMQ。

RocketMQ 是阿里巴巴自主研发及双 11 交易核心链路消息产品，提供金融级高可靠消息服务。在开源方面，开源 RocketMQ 已经完成了云原生技术栈的集成，包括Knative 中的事件源，Prometheus 的 Exporter，K8s 的 Operator 等；也支持了微服务框架 SpringCloud 以及函数计算框架 OpenWhisk ；同时开发了很多 Connector 作为 Sink 或者 Source 去连接了 ELK、Flume、Flink、Hadoop 等大数据和数据分析领域的优秀开源产品。

在 Matrix 开放平台，RocketMQ 主要有三类应用场景。

1) 用于金融产品的场景化包装

业务场景：

典型的业务场景如优惠购，基民通过优惠购功能申购基金，可将交易费率降为0。简单来说就是先购买博时货币基金，再通过快速转购的方式买入目标基金，豁免相关转换费率。

实现原理：

Matrix 基于 RocketMQ 的事务消息搭建了一个高可靠、高可用的事务消息平台---事务中心，涉及业务流程如下：

第一阶段是 Prepare ，即业务系统将 RocketMQ 的半事务消息发送到事务中心，事务中心不做发布，等待二次确认。Prepare 完成之后，业务系统执行主事务，即购买货币基金，成功后 commit 到事务中心，由事务中心投递消息到从事务。如果主事务失败，就投递 rollback 给事务中心。

反查机制：

由于网络抖动、业务系统重启等原因，可能导致事务消息的二次确认丢失。此时需要依赖反查机制恢复整个分布式事务的上下文。RocketMQ 提供的 Message Status Check 机制正是为解决分布式事务中的超时问题而设计的。事务中心的反查机制流程主要是，先检查事务中心的内部状态，再通过反查接口检查本地事务的执行结果，恢复事务上下文后，正常推进后续的流程。