Biz-SIP业务中台案例实战（3）——个性化的Source接入模块

本文主要是介绍Biz-SIP业务中台案例实战（3）——个性化的Source接入模块，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Biz-SIP金融级业务中台(http://bizsip.bizmda.com))是一套基于领域驱动设计（DDD），用于快速构建金融级云原生架构的服务整合中间件，包含了在金融场景里锤炼出来的最佳实践。

Biz-SIP业务中台在交易处理时，会先后涉及Source层、App层和Sink层的处理，其中，Source层的Source模块，对应于DDD架构中的适配层，主要是对接外部和系统内部其它系统的服务接入，主要功能有：
● 通讯协议的对接：服务接入模块（Source）负责外部调用方服务的通讯接入；
● 消息转换：把外部多种消息格式，转换成平台内部通用的JSON标准消息报文类型；
● 调用应用层的App服务进行服务编排。

对于外部服务接入，可以采用前面二节所提到的开放OpenAPI接口来接入，而本节介绍的，是个性化Source模块来对接外部个性化接口的接入：
在这里插入图片描述

具体代码和配置可以查看Biz-SIP源代码中的Sample相关测试案例（https://gitee.com/szhengye/biz-sip）

一、App服务和Sink服务的开发和配置

在上节的App服务调用Sink服务中，已经实现了Sink服务和App服务，不过是通过平台统一的开放OpenAPI接口来调用的：

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/bean/sample2" -X POST --data '{"accountNo":"003"}' http://localhost:8888/api|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/bean/sample2","traceId": "3cf20f08fe7f4d0d8c320ea14b61c98esh","parentTraceId": null,"timestamp": 1646564189216,"data": {"message": "hello!","accountNo": "003"}
}

二、个性化Source模块的开发

这里我们不用上面提到的OpenAPI接口来调用，而是另外写一个个性化的接口调用方式，为了简单起见，还是采用RESTful的接口。首先，我们需要编写一个RestController类来实现个性化接口：

@RestController
public class SampleSource1Controller {private BizMessageInterface appServiceClient = SourceClientFactory.getAppServiceClient(BizMessageInterface.class,"/bean/sample2");@PostMapping(value = "/source1", consumes = "application/json", produces = "application/json")public Object doService(@RequestBody String inMessage, HttpServletResponse response) throws BizException {JSONObject jsonObject = JSONUtil.parseObj(inMessage);return this.appServiceClient.call(jsonObject);}
}

在SampleSource1Controller类中，通过appServiceClient句柄，调用了"/bean/sample2"这个App服务。

三、启动应用进行测试

启动SampleSourceApplication应用，以及SampleSinkApplication和SampleAppApplication应用，通过向“/source1”发起请求，就可以接收到响应，返回的报文内容增加了message域：

$ curl -H "Content-Type:application/json" -X POST --data '{"accountNo":"003"}' http://localhost:8080/source1|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/bean/sample2","traceId": "c4d06665d3114668bddaca096ca6ebf9","parentTraceId": null,"timestamp": 1646564895713,"data": {"message": "hello!","accountNo": "003"}
}