去哪儿网支付系统架构演进

   <p>去哪儿支付系统自2011年搭建以来，在五年的时间里逐渐从一个高耦合的单一系统发展为众多子系统组成的高并发、高可用、支持多种交易支付业务的分布式系统。业务从最初的非代收到现在多种非代收、代收场景的支持，B2B业务的从无到有，支付方式从单一网银支付到现在银行卡、拿去花、代金券、红包、立减、积分、趣游宝等多种的组合，订单从单笔支付到多个订单同时支付和多次付款。下面对整体的演变过程进行简单的介绍。</p>    <h2>1. 支付系统1.0</h2>    <p>新的业务系统初建时，业务逻辑相对简单，业务量也比较小，为了能够快速实现功能，发布上线，大多数团队都会把所有的逻辑都耦合在一个系统。这对于初期业务的快速迭代是有一定好处的。毫不例外，支付交易系统也采用了这样的方式。如下图所示。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/0e76db9f4b7d7cd5a583826c8e6d9e11.jpg"></p>    <p>一个支付系统不例外包括几个重要组成部分：收银台、交易、支付、网关、账务。</p>    <ul>     <li>收银台：用于展示支付详情、提供各种多样支付方式的选择</li>     <li>交易：收单规则和交易规则处理</li>     <li>支付：处理各种组合的支付方式，如银行卡、用户余额、信用付、拿去花、红包、代金券、立减、积分等</li>     <li>账务：用来记录所有交易、资金往来的明细，财务会计记账</li>     <li>网关：用于对接银行通道、第三方支付通道（微信、支付宝）</li>    </ul>    <p>在业务量不大的情况下，这样的系统结构没有问题。随着更多业务的接入，各种复杂的功能逻辑加入，系统处理起来有点吃力，主要表现以下几个方面：</p>    <ol>     <li>系统容灾能力：所有的功能都集中在一起，一但某个功能出问题，直接影响全局</li>     <li>系统扩容：在一个分布式系统中，决定系统性能的取决于最差的部分，整体扩容效果差</li>     <li>开发成本高：团队成员的增加，功能的复杂，多个项目并行时，开发效率极低</li>     <li>更多更复杂业务：结构不合理，不能满足业务发展需要</li>     <li>系统职责混乱：如收银台只是简单维护银行列表</li>    </ol>    <p>在这样的一些背景下，2.0系统应运而生。</p>    <h2>2. 支付系统2.0</h2>    <p>2.0时代是支付交易系统快速发展的一个重要时段。在此过程中，不仅要从系统架构上进行服务化的拆分，而且需要支持更复杂的业务。</p>    <h3>2.1 服务化拆分</h3>    <p>2.1.1  网关拆分</p>    <p>首先对相对比较独立的网关进行拆分，网关在整个支付系统中属于底层基础服务，是比较重要的基础设施。对外能够提供怎么样的支付交易服务，很多都取决于网关能力的建设。</p>    <p>网关有一些显著特征，它是一个可高度抽象的业务。对外可以抽象到支付、退款、查询这些标准的服务。因此优先将这部分拆分，一是为了能够更好的打好基础，二是其能够独立的发展，三是这部分也相对好实施。</p>    <p>网关的拆分路由系统起到至关重要的作用，对于多通道支付的支持和智能化选择发挥着巨大作用。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/3506c59915e928a3c88ad12b37dd4630.jpg"></p>    <p>2.1.2 账务系统的拆分</p>    <p>做交易支付业务，重要的一件事要记清楚账。记账可以很简单的记录来往流水，也可以更加专业的记财务会计账。在拆分前系统只是记录了交易流水，拆分后实现了更加专业和复杂的复式记账。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/d9f72b848d42472139af49e360f9d1cc.jpg"></p>    <p>新账务系统的一个简单流程图：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/22fafcf0bb9e1f9c97f5eb21f125d1af.jpg"></p>    <p>2.1.3 会员系统的独立</p>    <p>会员系统与交易系统本身只是一个依赖关系，在交易支付系统看来只是一个业务系统。比如会员充值业务可以看做是一笔支付交易。为了摆正各自角色，对于会员部分从原有系统中独立出来。这样一来各自定位更加清晰明了，也方便了各自独立发展。现在的会员系统不仅仅只有一个余额，而且引入实名服务、各种资产管理、交易管理等。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/18d8e7dcb4f59c8ba64b50f302e5599f.jpg"></p>    <p>2.1.4 基础服务的拆分</p>    <p>更多的系统拆分独立后，原有公用的某些功能会多次复制重复。为方便集中管理维护，通过对各系统公用逻辑更能的统一，提供集中的基础服务，如安全服务、加验签服务、通知服务、基础信息查询等，如下图中talos系统。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/e91b31cd7165a8c5e1d26bec30cdf1e1.jpg"></p>    <p>上述几个服务的拆分更多是为从业务方面或者技术驱动来考虑。而典型的交易支付过程是有一个时序过程的。比如下单->交易->收银台->支付->网关->银行。这样一个先后时序也是一个比较好的系统拆分方案。根据这样的一个时序，我们针对性的对每个阶段做了拆分（排除网关和银行部分），如下过程：</p>    <p>1、交易核心(Apollo)</p>    <p>关注于收单方式和交易类型。</p>    <p>收单方面系统已经支持单笔订单支付、批量订单支付。交易类型目前支持直接交易、担保交易、直接分账交易、担保分账交易、预授权交易等。在批量订单支付时各种交易类型可以进行混合。且分账交易同时支持多个账户。交易类型除了上面正向交易外，系统还支持很多后续流程交易、如预授权确认、预授权撤销、退款、担保撤销、二次分账交易等。</p>    <p>多种多样的交易源于各事业部业务的复杂性，比起标准化的支付系统，我们提提供了更多灵活方便的业务来支持。</p>    <p>2、支付核心(minos)</p>    <p>关注于支付方案的组合和执行。</p>    <p>支付方式：银行卡、支付宝、微信、拿去花、趣游宝、余额、积分、红包、代金券、会员红包、立减等多种方式支付。</p>    <p>支付组合：可以单一使用，也可以进行组合使用。组合场景区分资金类型，如银行卡、支付宝、微信每次只能选择一个，其它类资金可多个同时使用。</p>    <p>在有上面基础的支持下，对于同一批次交易订单可也进行多次的组合支付扣款，如酒店信用住付款、拿去花还款等业务场景。下图是支付核心（minos）在系统中的位置：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/eb3f5be011bf89d7d02a793b576613f9.jpg"></p>    <p>3、收银台</p>    <p>收银台直接面向用户，因此支付体验至关重要。据统计在支付环节放弃的订单占比还比较大。因此一个方便、简洁易用的收银台对于订单转换是有很大帮助的。目前系统支持的收银台主要有app(native)、app前置收银台、touch、PC预授权收银台、PC多单收银台、PC英文版收银台、PC标准收银台等。收银台在系统中的位置如下图所示。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/7c891fe66cd1f3ad716f9d2cde56238e.jpg"></p>    <p>无线端收银台：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/c7f4db5d83f2bb893aa03067d2af128f.jpg"></p>    <p>PC端收银台：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/13c5f1b85df6cb82daefe2c304376efc.jpg"></p>    <p>4、API接入层</p>    <p>交易系统更多的服务是通过后台接口来完成的，这部分占到整体系统很大的业务比重。如支付后期的资金流转、逆向操作退款等。但也有一些是用来查询一些交易订单相关性的信息。在此背景下，对于api接入层采用读写分离方式处理。如下图ares系统，将底层的各dubbo服务包装提供各种查询类服务。Odin系统是可读写，更多的关注跟核心业务相关的写，如解冻、退款、撤销等。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/84f38b1bacbc38de398a3823eb5009ed.jpg"></p>    <p>截止目前，整体系统的一个大体结构如下图所示：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/a4cc33c2539861023ef92be28c1abdd1.jpg"></p>    <h3>2.2 服务化拆分带来的挑战</h3>    <p>服务化拆分后，在系统结构上更加清晰了，但对于整体系统的开发管理和日常运营带来更大的挑战。比如下几个方面：</p>    <p>2.2.1 如何提高开发效率</p>    <p>系统拆分后主要提供dubbo服务和对外http(https)服务</p>    <p>1. 针对Dubbo服务的约定</p>    <ol>     <li>接口定义：粒度控制、边界控制。一个接口不能存在模棱两可的情况，只做其一</li>     <li>参数标准：复杂接口使用对象做参数(避免map)、统一父类、支持扩展属性透传、提供create/builder构造合法参数、使用枚举限制参数范围。有效避免调用端参数错传</li>     <li>返回值：统一QResponse封装、错误码管理(非数字形式含义明确、按业务区分避免重复等)</li>     <li>业务模板：定义标准业务处理流程、标准化异常处理</li>     <li>接口文档化：定义好接口后，通过注解动态生成接口文档</li>    </ol>    <p>2. 针对http服务的约定</p>    <p>a）接口参数：command、校验器、参数类型配置化。</p>    <p>command中定义接口信息，包括请求返回参数、每个参数的参数类型、参数的校验器、参数类型的校验器。校验器可以组合使用，也可以自定义实现扩展。如下示例：</p>    <pre>  Command定义：  <commands>        <command name="forex_queryExchangeRate">          <cnName>汇率查询接口</cnName>          <version>20150808</version>          <desc>查询本币和目标币种汇率</desc>          <request>              <param name="localCurrType" required="true">                  <validator id="CURID"/>              </param>              <param name="targetCurrType" required="true">                  <validator id="CURID"/>              </param>          </request>             <!-- 返回参数部分 -->          <response>              <param name="localCurrType">                  <cnName>本币</cnName>                  <required>true</required>              </param>              <param name="targetCurrType">                  <cnName>目标币种</cnName>                  <required>true</required>              </param>              <param name="sellingPrice">                  <cnName>卖出价</cnName>                  <required>true</required>              </param>              <param name="buyingPrice">                  <cnName>购买价</cnName>                  <required>true</required>              </param>              <param name="rateTime">                  <cnName>汇率时间</cnName>                  <required>true</required>              </param>          </response>  </command>     </commands>  校验器：  <validators>      <validator id="CURID" type="Regex">          <pattern>^[A-Z]{3}$</pattern>      </validator>  </validators>  参数类型：  <paramTypes>      <paramType name="merchantCode">          <cnName>商户号</cnName>          <desc>用来区分不同商户</desc>          <type>java.lang.String</type>          <example>testbgd</example>          <validator type="Regex">              <pattern>^[A-Za-z0-9]{1,20}$</pattern>          </validator>      </paramType>  </paramTypes></pre>    <p>b）并发控制</p>    <p>在某些操作场景下，对于并发写会有一些问题，此时可以通过依赖cache加锁来控制。比如通过在接口增加注解来启用。可以指定接口参数来作为锁的lockKey ，指定锁失效时间和重试次数，并指定异常时(lockGotExIgnore )的处理方案。</p>    <pre>  @RequestLock(lockKeyPrefix = "combdaikoupay:",                lockKey = "${parentMerchantCode}_${parentTradeNo}",              lockKeyParamMustExists = true,              lockKeyExpireSecs = 5,              lockUsedRetryTimes = 0,              lockUsedRetryLockIntervalMills = 500,              lockGotExIgnore = false)</pre>    <p>c）流量控制</p>    <p>流控目前分两种：qps、并行数。</p>    <p>qps分为节点、集群、接口节点、接口集群。通过对每秒中的请求计数进行控制，大于预设阀值(可动态调整)则拒绝访问同时减少计数，否则通过不减少计数。</p>    <p>行数主要是为了解决请求横跨多秒的情况。此时qps满足条件但整体的访问量在递增，对系统的吞吐量造成影响。大于预设阀值(可动态调整)则拒绝访问。每次请求结束减少计数</p>    <p>d）安全校验</p>    <p>接口权限：对接口的访问权限进行统一管理和验证，粒度控制到访问者、被访问系统、接口、版本号</p>    <p>接口签名：避免接口参数在传递过程中发生串改</p>    <p>e）统一监控</p>    <p>包括接口计数、响应时长和错误码统计三个维度</p>    <p>f）接口文档化</p>    <p>依赖前面command、校验器、参数类型配置进行解析生成</p>    <p>2.2.2  如何管理多个系统？</p>    <ol>     <li>接口监控模板化：http、Dubbo多系统统一模板，集中展示管理。</li>     <li>组件可监控化：Redis/Memcache、Mybatis 、Lock 、QMQ 、 EventBus 、DataSource 、JobScheduler</li>     <li>监控面板自动化生成：Python自动化生成脚本，新创建系统只需要提供系统名称和面板配置节点即可生成标准监控面板</li>     <li>系统硬件资源、tomcat、业务关键指标可视化监控</li>    </ol>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/ba5a16d8f7464c4b8cde873df93594a8.jpg"></p>    <p>2.2.3 如何高效日常运营？</p>    <p>对于各个场景的关键流程进行格式化日志输出,集中收集处理。如orderLog、userLog、cardLog、binlog、busilog、tracelog、pagelog...</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/90d9f990643b1ca6bf3de4e99b8e9375.jpg"></p>    <h3>2.3 服务化拆分过程中DB处理</h3>    <p>2.3.1 分表</p>    <p>随着业务量增加，单表数据量过大，操作压力大。因此分表势在必行。常用的分表策略如按照时间来分表，如月表，季表，按照某个key来hash分表，也可以将两种结合起来使用。分表的好处是可方便将历史数据进行迁移，减少在线数据量，分散单表压力。</p>    <p>2.3.2 分库、多实例</p>    <p>多库单实例，多业务单库。部分业务存在问题会影响全局，从而会拖垮整个集群。因此在业务系统拆分后，db的拆分也是重要的一个环节。举一个例支付库拆分的例子。支付交易的表都在同一个库中，由于磁盘容量问题和业务已经拆分，因此决定进行拆库。稳妥起见，我们采用保守方案，先对目前实例做一个从库，然后给需要拆分出来的库创建一个新的用户U，切换时先收回U的写权限，然后等待主从同步完成，，确定相关表没有写入后将U切到新的实例上。然后删除各自库中无关的表。</p>    <p>2.3.3 读写分离、读负载均衡</p>    <p>很多业务读多写少，使用MMM结构，基本上只有一台在工作，不仅资源闲置且不利于整体集群的稳定性。引入读写分离、读负责均衡策略。有效使用硬件资源，且降低每台服务器压力。</p>    <p>a）读写负载均衡</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/b78f9633113956af08f6e9db28595247.jpg"></p>    <p>b）多动态源</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/f5da0b47e6b8930a4f620d4d97959b9b.jpg"></p>    <p>c）多库动态源读负载均衡</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/f5da0b47e6b8930a4f620d4d97959b9b.jpg"></p>    <p>2.4 异步化使用</p>    <ol>     <li>servlet3异步：释放出http线程提高系统整体吞吐量，可隔离开不同业务的工作线程</li>     <li>qmq：使用最广泛也更灵活的异步</li>     <li>dubbo：对于服务提供者响应比较慢的情况</li>    </ol>    <p>servlet异步和qmq结合的场景如下图所示。流程为http服务接到组合扣款请求，然后向后端交易系统下单并发起扣款，此时http服务进入轮询等待，根据轮询间隔定时发起对放在cache中的扣款结果查询。交易系统则根据扣款规则以qmq的方式驱动扣款，直至走完所有流程为止(成功，失败，部分支付)。每次扣款结束将结果放入cache中供http服务查询。</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/ab4981120983afb1ccd434efd00e243e.jpg"></p>    <p>轮询式场景如上图中使用，关键在于确定轮询间隔</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/5d60f2c7dbc64981173a56ee79f637c3.jpg"></p>    <h3>2.5  监控&报警</h3>    <p>2.5.1 Java监控模块</p>    <p>嵌入在应用中，指标数据可灵活配置发送方式到多个地方。也支持api接口直接拉取数据</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/4a085293d02731faa0c7651166eb8af8.jpg"></p>    <p>2.5.2 离线监控框架</p>    <ol>     <li>python监控脚本框架,从db、java模块api、redis等获取数据，计算指标并发送</li>     <li>整体架构可插件化、有通用标准功能、也可定制化开发</li>     <li>指标可直接推送至watcher（dashboard）系统添加监控页</li>     <li>报警方式有mail、sms、qtalk</li>    </ol>    <p>python监控脚本框架主要包含四个重要组件：</p>    <ol>     <li>metric_manager：指标管理器</li>     <li>graphite_sender：指标推送</li>     <li>Dbpool：数据库链接池管理</li>     <li>Scheduler：调度器，定时执行指标数据获取</li>    </ol>    <p>2.5.3 数据流系统</p>    <p>采用xflume、kafka、storm、hdfs、hbase、redis、hive对业务日志、binlog等实时收集并处理。提供业务日志、订单生命周期日志、各种格式化日志的查询和一些监控指标的计算存储和报警。整体大致流程如下图所示：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/d661b7509682ac8adb6c92ea9f256939.jpg"></p>    <p>2.5.4 报警</p>    <p>业务和系统结构复杂后报警尤为重要。甄别哪些指标是必须报警的和报警阀值的确定是个很复杂的问题。一般有两种情况：一种是明确认为不能出现的，另一种是需要一定计算来决定是否要报警。当然有些基础层的服务出现问题，可能会导致连锁反应，那么如何甄别最直接的问题来报警，避免乱报影响判断是比较难的事情。目前针对这种情况系统会全报出来，然后人工基本判断下，比如接口响应慢报警，此时又出现了DB慢查询报警，那基本可以确认是DB的问题。</p>    <p>A、明确失败报警</p>    <p>日志NPE、业务FAIL、系统ERROR、Access (4xx\5xx)、接口异常、dubbo超时、fullgc、DB慢查询等</p>    <p>B、计算类报警</p>    <p>调用量特别小，波动明细，没有连续性，不具有对比性</p>    <p>期望值：如下图所示，当前值与期望值偏差加大</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/13d322e161d90d30096514fc8892d73d.png"></p>    <h2>3. 总结</h2>    <p>截止目前交易支付系统从收银台、交易、支付、网关、账务、基础服务、监控等各个模块的拆分并独立完善发展，针对高复杂业务和高并发访问的支撑相比以前强大很多。但还有很多不足的地方有待提高和完善。</p>    <p> </p>    <p> </p>    <p>来自：http://www.infoq.com/cn/articles/evolution-of-qunar-payment-system-architecture-</p>    <p> </p>