[WIP]业务中台如何实现业务的结果通知

2023-07-31 23:14 由 buguge 发表于 #软件设计

绞尽脑汁生产中...

如下RPC通信场景：业务线向交易中台发起交易。当交易完成后，zhongtai-trans要将交易结果通知给业务线。

那么，在程序实现上，zhongtai-trans如何通知业务线呢？

这个问题暂且不表。我们先来看跨企业通信的业务回调通知。这里，我们以企业对接微信支付来举例。用户在企业的网站上扫描微信支付二维码进行支付。微信支付完成后，腾讯会以HTTP的形式主动回调企业方API，将支付结果通知给企业系统。

微信官网明确了支付通知的参数。企业收到通知请求后，根据请求参数进行自己的逻辑处理。也就是说，腾讯作为通知请求方，定义了统一的通知参数，一视同仁，不管你是企业A的系统，还是企业B的系统，腾讯不会以某个企业的意志而改变。

我们继续来看企业应用内部服务间的业务回调。举一反三，也应按照跨企业见的业务回调通知这样来设计。即，zhongtai-trans定义统一的TransNotifyDTO，封装交易通知数据。各业务线服务内对接收到的TransNotifyDTO对象进行判断处理，或转换为自己的内部对象来进行逻辑处理。

话虽如此，在实现方面，这会遇到一个问题。我们使用dubbo作为RPC框架。dubbo规定了provider服务和consumer服务都依赖由provider提供的rpcapi。按照上面的设计，由于zhongtai-trans要调用各业务线的rpcapi，而TransNotifyDTO由zhongtai-trans-rpcapi定义，这就出现各业务线的rpcapi要依赖zhongtai-trans-rpcapi。不得不说，rpcapi之间存在jar包依赖是一个败笔。下图直观的看出来（实线代表jar包依赖）。

那么，如何搞定这个败笔呢？一个为所有rpcapi所共用的基础module发挥作用了，这里我命名为base-rpcapistyle。base-rpcapi的作用：定义rpcapi的通用部分，如rpcapi的返回值模型Result<T>，共同的枚举，共同的dto对象。本案中的TransNotifyDTO就要放在base-rpcapistyle里。

如此清新，到这里，是时候可以贴出来示意代码了。

1）产品线rpcapi，以BizA为例

    /**
     * 接收来自zhongtai-trans的回调通知
     * @param transNotifyDTO
     * @return
     */
    Result<Void> notifyPayResult(TransNotifyDTO transNotifyDTO);

2）zhongtai-trans里通知业务线代码

    /**
     * 交易完成，回调通知业务线
     * @param transOrder
     */
    public void notifyPayResultToBiz(TransOrder transOrder) {
        Assert.isTrue(TransPayStatusEnum.isFinal(transOrder.getPayStatus()));
        TransNotifyDTO transNotifyDTO = new TransNotifyDTO();
        transNotifyDTO.setOrderNo(transOrder.getOrderNo())
                .setPayStatus(transOrder.getPayStatus())
                .setPayTime(transOrder.getPayTime())
                .setTransAmount(transOrder.getTransAmount())
                .setStatusDesc(transOrder.getTransMsg());
        Result<Void> result = null;
        switch (transOrder.getBiz()) {
            case BizA:
                result = bizAApi.notifyPayResult(transNotifyDTO);
                break;
            case BizB:
                result = bizBApi.notifyPayResult(transNotifyDTO);
                break;
            case BizC:
                result = bizCApi.notifyPayResult(transNotifyDTO);
                break;
        }
        log.info("通知业务线完成，响应结果={}", result);
    }

【EOF】

热门相关：倾心之恋：总裁的妻子闺范闺范后福拒嫁豪门，前妻太抢手