Biz-SIP业务中台案例实战（8）——模板XML格式转换器（velocity-xml）

2023-12-07 11:18
文章标签 xml 实战 模板 sip 业务 格式 案例 转换器 velocity biz

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

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

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

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

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

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

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

- id: velocity-xml-sinktype: resturl: http://bizsip-sample-sink/elocity-xml-sinkconverter:type: velocity-xmlpack-rules:- predicate: '#{#data[sex]=="0"}'rule: velocity-xml-sink/woman.vm- predicate: '#{#data[sex]=="1"}'rule: velocity-xml-sink/man.vm- predicate:rule: velocity-xml-sink/error.vmunpack-rules:connector:type: serviceclass-name: com.bizmda.bizsip.sample.sink.service.EchoConnectorService

可以看到velocity-xml-sink这个Sink服务，connector关联了能把请求报文直接原包响应返回的EchoConnectorService类。而格式转换器converter，则直接设置“type: velocity-xml”，表示采用基于velocity模板的XML格式转换器，作为当前Sink服务的格式转换器。
Sink服务的converter项下配置了pack-rules参数，表示会根据报文中条件来决定采用什么velocity模板，上面配置中，是根据报文中的sex域值来决定的。
相关打解包规则配置文件，配置如下：

velocity-xml-sink/woman.vm
<account><name>${data.accountName}</name><balance>${data.balance}</balance><no>${data.accountNo}</no><sex>女人</sex>
</account>velocity-xml-sink/man.vm
<account><name>${data.accountName}</name><balance>${data.balance}</balance><no>${data.accountNo}</no><sex>男人</sex>
</account>velocity-xml-sink/error.vm
<account><name>${data.accountName}</name><balance>${data.balance}</balance><no>${data.accountNo}</no><sex>不知道</sex>
</account>

这个Sink服务没有设置processor属性，即为缺省default类型，采用默认的缺省Sink服务流程来处理的，处理步骤依次为：

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

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

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

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

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

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

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

三、启动应用进行测试

启动SampleSinkApplication、SampleAppApplication应用，通过OpenAPI接口进行测试。
首先，请求报文中将sex域设置为"0"，应该会调用velocity-xml-sink/woman.vm模板：

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/sink/velocity-xml-sink" -X POST --data '{"accountName": "王五","sex": "0","accountNo":"005","balance":1}' http://localhost:8888/api|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/sink/velocity-xml-sink","traceId": "2146dd16d67e42c485e94678cfc13064","parentTraceId": null,"timestamp": 1647176026824,"data": {"account": {"no": "005","sex": "女人","balance": 100,"name": "王五"}}
}

EchoConnectorService打印日志：

收到报文:
====+ 01-02-03-04-05-06-07-08-09-10-11-12-13-14-15-16-17-18-19-20 + ====== ASCII  ====== +
0000: 3C 61 63 63 6F 75 6E 74 3E 0A 20 20 20 20 3C 6E 61 6D 65 3E | <account>.    <name> |
0020: E7 8E 8B E4 BA 94 3C 2F 6E 61 6D 65 3E 0A 20 20 20 20 3C 62 | 王.五.</name>.    <b |
0040: 61 6C 61 6E 63 65 3E 31 30 30 3C 2F 62 61 6C 61 6E 63 65 3E | alance>100</balance> |
0060: 0A 20 20 20 20 3C 6E 6F 3E 30 30 35 3C 2F 6E 6F 3E 0A 20 20 | .    <no>005</no>.   |
0080: 20 20 3C 73 65 78 3E E5 A5 B3 E4 BA BA 3C 2F 73 65 78 3E 0A |   <sex>女.人.</sex>. |
0100: 3C 2F 61 63 63 6F 75 6E 74 3E                               | </account>.......... |

其次，请求报文中将sex域设置为"1"，应该会调用velocity-xml-sink/man.vm模板：

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/sink/velocity-xml-sink" -X POST --data '{"accountName": "王五","sex": "1","accountNo":"005","balance":10}' http://localhost:8888/api|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/sink/velocity-xml-sink","traceId": "8061430704b24a86953e9c8a26d1d7a4","parentTraceId": null,"timestamp": 1647176026930,"data": {"account": {"no": "005","sex": "男人","balance": 1000,"name": "王五"}}
}

EchoConnectorService打印日志：

收到报文:
====+ 01-02-03-04-05-06-07-08-09-10-11-12-13-14-15-16-17-18-19-20 + ====== ASCII  ====== +
0000: 3C 61 63 63 6F 75 6E 74 3E 0A 20 20 20 20 3C 6E 61 6D 65 3E | <account>.    <name> |
0020: E7 8E 8B E4 BA 94 3C 2F 6E 61 6D 65 3E 0A 20 20 20 20 3C 62 | 王.五.</name>.    <b |
0040: 61 6C 61 6E 63 65 3E 31 30 30 30 3C 2F 62 61 6C 61 6E 63 65 | alance>1000</balance |
0060: 3E 0A 20 20 20 20 3C 6E 6F 3E 30 30 35 3C 2F 6E 6F 3E 0A 20 | >.    <no>005</no>.  |
0080: 20 20 20 3C 73 65 78 3E E5 A5 B3 E4 BA BA 3C 2F 73 65 78 3E |    <sex>女.人.</sex> |
0100: 0A 3C 2F 61 63 63 6F 75 6E 74 3E                            | .</account>......... |

最后，请求报文中将sex域设置为"2"，应该会调用velocity-json-sink/error.vm模板：

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/sink/velocity-xml-sink" -X POST --data '{"accountName": "王五","sex": "2","accountNo":"005","balance":10}' http://localhost:8888/api|jq{"code": 0,"message": "success","extMessage": null,"appServiceId": "/sink/velocity-xml-sink","traceId": "f778623432584b15878038e7db1d2bce","parentTraceId": null,"timestamp": 1647176027027,"data": {"account": {"no": "005","sex": "不知道","balance": 1000,"name": "王五"}}
}

EchoConnectorService打印日志：

收到报文:
====+ 01-02-03-04-05-06-07-08-09-10-11-12-13-14-15-16-17-18-19-20 + ====== ASCII  ====== +
0000: 3C 61 63 63 6F 75 6E 74 3E 0A 20 20 20 20 3C 6E 61 6D 65 3E | <account>.    <name> |
0020: E7 8E 8B E4 BA 94 3C 2F 6E 61 6D 65 3E 0A 20 20 20 20 3C 62 | 王.五.</name>.    <b |
0040: 61 6C 61 6E 63 65 3E 31 30 30 30 3C 2F 62 61 6C 61 6E 63 65 | alance>1000</balance |
0060: 3E 0A 20 20 20 20 3C 6E 6F 3E 30 30 35 3C 2F 6E 6F 3E 0A 20 | >.    <no>005</no>.  |
0080: 20 20 20 3C 73 65 78 3E E4 B8 8D E7 9F A5 E9 81 93 3C 2F 73 |    <sex>不.知.道.</s |
0100: 65 78 3E 0A 3C 2F 61 63 63 6F 75 6E 74 3E 0A                | ex>.</account>...... |

Biz-SIP网站：http://bizsip.bizmda.com
Gitee代码库：https://gitee.com/szhengye/biz-sip

这篇关于Biz-SIP业务中台案例实战（8）——模板XML格式转换器（velocity-xml）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/465651。

相关文章

网页解析 lxml 库--实战

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库，完全使用 Python 语言编写，它对 XPath表达式提供了良好的支 持，因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块，该模块专门用来解析 HTML/XML 文档，下面来介绍一下 lxml 库
阅读更多...
Hadoop企业开发案例调优场景

Hadoop企业开发案例调优场景

需求 （1）需求：从1G数据中，统计每个单词出现次数。服务器3台，每台配置4G内存，4核CPU，4线程。 （2）需求分析： 1G / 128m = 8个MapTask；1个ReduceTask；1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务（4    3    3） HDFS参数调优 （1）修改：hadoop-env.sh export HDFS_NAMENOD
阅读更多...
性能分析之MySQL索引实战案例

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题，本文将一起从代码层去分析为什么没有建立索引？ 开源ERP项目地址：https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置
阅读更多...
深入探索协同过滤：从原理到推荐模块案例

深入探索协同过滤：从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤（UserCF）2. 基于物品的协同过滤（ItemCF）3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代，推荐系统成为连接用户与内容的桥梁。本文聚焦于
阅读更多...
poj3468(线段树成段更新模板题)

poj3468(线段树成段更新模板题)

题意：包括两个操作：1、将[a.b]上的数字加上v；2、查询区间[a,b]上的和 下面的介绍是下解题思路： 首先介绍  lazy－tag思想：用一个变量记录每一个线段树节点的变化值，当这部分线段的一致性被破坏我们就将这个变化值传递给子区间，大大增加了线段树的效率。 比如现在需要对[a,b]区间值进行加c操作，那么就从根节点[1,n]开始调用update函数进行操作，如果刚好执行到一个子节点，
阅读更多...
C++11第三弹：lambda表达式 | 新的类功能 | 模板的可变参数

C++11第三弹：lambda表达式 | 新的类功能 | 模板的可变参数

🌈个人主页： 南桥几晴秋 🌈C++专栏： 南桥谈C++ 🌈C语言专栏： C语言学习系列 🌈Linux学习专栏： 南桥谈Linux 🌈数据结构学习专栏： 数据结构杂谈 🌈数据库学习专栏： 南桥谈MySQL 🌈Qt学习专栏： 南桥谈Qt 🌈菜鸡代码练习： 练习随想记录 🌈git学习： 南桥谈Git 🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈�
阅读更多...
C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

哈喽，你好啊，我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记，这是第6篇； 接下来实现实时显示当前选中红球数量，蓝球数量； 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时，在对应的位置显示实时已选择的红球、蓝球的数量； 02 标签名称 分别设置Label标签名称为：lblRedCount、lblBlueCount
阅读更多...
poj 1258 Agri-Net（最小生成树模板代码）

poj 1258 Agri-Net（最小生成树模板代码）

感觉用这题来当模板更适合。 题意就是给你邻接矩阵求最小生成树啦。~ prim代码：效率很高。172k...0ms。 #include<stdio.h>#include<algorithm>using namespace std;const int MaxN = 101;const int INF = 0x3f3f3f3f;int g[MaxN][MaxN];int n
阅读更多...
【区块链 + 人才服务】可信教育区块链治理系统 | FISCO BCOS应用案例

【区块链 + 人才服务】可信教育区块链治理系统 | FISCO BCOS应用案例

伴随着区块链技术的不断完善，其在教育信息化中的应用也在持续发展。利用区块链数据共识、不可篡改的特性， 将与教育相关的数据要素在区块链上进行存证确权，在确保数据可信的前提下，促进教育的公平、透明、开放，为教育教学质量提升赋能，实现教育数据的安全共享、高等教育体系的智慧治理。 可信教育区块链治理系统的顶层治理架构由教育部、高校、企业、学生等多方角色共同参与建设、维护，支撑教育资源共享、教学质量评估、
阅读更多...
业务中14个需要进行A/B测试的时刻[信息图]

业务中14个需要进行A/B测试的时刻[信息图]

在本指南中，我们将全面了解有关 A/B测试 的所有内容。 我们将介绍不同类型的A/B测试，如何有效地规划和启动测试，如何评估测试是否成功，您应该关注哪些指标，多年来我们发现的常见错误等等。 什么是A/B测试？ A/B测试（有时称为“分割测试”）是一种实验类型，其中您创建两种或多种内容变体——如登录页面、电子邮件或广告——并将它们显示给不同的受众群体，以查看哪一种效果最好。 本质上，A/B测
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2