Biz-SIP业务中台案例实战（6）——简单XML格式转换器（simple-xml）

本文主要是介绍Biz-SIP业务中台案例实战（6）——简单XML格式转换器（simple-xml），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

Biz-SIP业务中台支持多种报文类型的格式转换器，包括XML、JSON、定长、有分隔符、ISO-8583等报文类型的解包和打包，格式转换器可以在Source模块和Sink服务中进行配置和使用，实现打包（平台标准报文格式转换成外部报文格式）和解包（外部报文格式转换成平台标准报文格式）。
simple-xml类型的格式转换器，能支持快速、简单的XML消息适配，直接把Biz-SIP内部标准消息打包成外部的XML格式；同时也直接把外部的XML格式消息，快速直接解包成Biz-SIP内部标准消息。
本节案例中是在Sink服务模块中，配置simle-xml格式转换器，以实现简单XML报文类型（simple-xml）的打包和解包：
在这里插入图片描述

其中，App层是通过Sink透传App服务，直接让调用方通过OpenAPI接口调用Sink服务（simple-xml-sink），Sink服务会把平台内部标准格式（JSONObject对象，内部即JSON报文）进行打包，传给通讯连接器Connector，返回后再解包成平台内部标准格式，返回给调用方。

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

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

首先，我们需要为Sink服务配置一个通讯连接器Connector，为了简单起见，直接配置了一个Spring Service Connector，并绑定了直接把请求报文报包返回的档板类（EchoConnectorService.java）：

@Slf4j
@Service
public class EchoConnectorService implements ByteProcessInterface {@Overridepublic byte[] process(byte[] inMessage) throws BizException {log.debug("收到报文:\n{}", BizUtils.buildHexLog(inMessage));return inMessage;}
}

然后，在在Biz-SIP配置目录的sink.yml中，配置对应的Sink服务：

- id: simple-xml-sinktype: resturl: http://bizsip-sample-sink/simple-xml-sinkconverter:type: simple-xmlconnector:type: serviceclass-name: com.bizmda.bizsip.sample.sink.service.EchoConnectorService

可以看到simple-xml-sink这个Sink服务，connector关联了上面编写的EchoConnectorService类。而格式转换器converter，则直接设置“type: simple-xml”，表示采用简单XML格式转换器，作为当前Sink服务的格式转换器。
这个Sink服务没有设置processor属性，即为缺省default类型，采用默认的缺省Sink服务流程来处理的，处理步骤依次为：

调用格式转换器converter对传入报文进行打包；
对上步打包后的报文作为调用请求报文，调用通讯适配器connector进行处理，并收到并返回响应报文；
调用格式转换器converter对响应报文进行解包，并返回解包后的报文。

最后，还需要在SampleSinkApplication的应用配置文件application-local.yml中，在bizsip.sink-id配置项中，增加simple-xml-sink以便启动Sink服务：

bizsip:config-path: /var/bizsip/configsink-id: hello-sink,echo-sink,simple-xml-sink

二、App层App服务的开发和配置

对于Sink透传App服务，只需要在app.yml中配置即可：

- app-service-id: /sink/simple-xml-sinktype: sink-servicesink-id: simple-xml-sink

可以看到在app.yml中，配置了App服务“/sink/simple-xml-sink”，类型为Sink透传App服务（sink-service），透传调用的Sink服务为“simple-xml-sink”。

三、启动应用进行测试

启动SampleSinkApplication、SampleAppApplication应用，通过OpenAPI接口进行测试：

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/sink/simple-xml-sink" -X POST --data '{"accountName": "王五","balance": 500,"accountNo":"005"}' http://localhost:8888/api|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/sink/simple-xml-sink","traceId": "dcad86b3294b49f09a6a79f196929e7a","parentTraceId": null,"timestamp": 1647161094697,"data": {"accountName": "王五","balance": 500,"accountNo": "005"}
}

返回报文中看到data域中的值，已经解包成了平台内部标准报文。
EchoConnectorService类打印的消息：

收到报文:
====+ 01-02-03-04-05-06-07-08-09-10-11-12-13-14-15-16-17-18-19-20 + ====== ASCII  ====== +
0000: 3C 3F 78 6D 6C 20 76 65 72 73 69 6F 6E 3D 22 31 2E 30 22 20 | <?xml version="1.0"  |
0020: 65 6E 63 6F 64 69 6E 67 3D 22 55 54 46 2D 38 22 20 73 74 61 | encoding="UTF-8" sta |
0040: 6E 64 61 6C 6F 6E 65 3D 22 6E 6F 22 3F 3E 3C 72 6F 6F 74 3E | ndalone="no"?><root> |
0060: 3C 61 63 63 6F 75 6E 74 4E 61 6D 65 3E E7 8E 8B E4 BA 94 3C | <accountName>王.五.< |
0080: 2F 61 63 63 6F 75 6E 74 4E 61 6D 65 3E 3C 62 61 6C 61 6E 63 | /accountName><balanc |
0100: 65 3E 35 30 30 3C 2F 62 61 6C 61 6E 63 65 3E 3C 61 63 63 6F | e>500</balance><acco |
0120: 75 6E 74 4E 6F 3E 30 30 35 3C 2F 61 63 63 6F 75 6E 74 4E 6F | untNo>005</accountNo |
0140: 3E 3C 2F 72 6F 6F 74 3E                                     | ></root>............ |