从一种消息格式转换为另一种格式

Question

这是我的要求。

我有一个客户端正在使用任何网络协议向某些软件服务提供商（ABC）发送特定的消息格式。

现在该客户正在切换软件服务提供商（XYZ），但不想更改其软件并希望继续发送 ABC 提供商的相同消息。

• 提供商 ABC 在某些古老的网络协议上使用某种基于位置的消息格式
• 提供商 XYZ 使用基于 HTTP(s) Web 服务的 XML，而不是 SOA 只是使用 XML 的简单 POST
• 某些值可以直接映射，而其他值必须重新计算或修改。例如，将客户的帐号从 ABC 提供商转换为 XYZ 提供商的帐号。这是用于请求和响应的。
• 过时的网络协议将在网络级别转换为 TCPI/IP，因此这不是问题。
• 客户期望实时响应。即：客户端发出请求，XYZ 执行任何操作并将响应返回给客户端。

因此，我需要创建某种隧道，接受 TCP/IP 将消息转换为 XML，将其通过 HTTP(s) POST 发送到 XYZ，获取 XML 响应，转换回基于位置，通过 TCPI/IP 回复给客户端。

这是 ESB 类型的事情吗？我应该编写某种 JAVA 服务器应用程序来执行此操作吗？

Answer 1

你有太多的选择。从 Python、Perl 开始......有一些库/模块为您提供 TCP/HTTP/telnet/... 支持。使用它你可以做到这一点。

ESB 对此可能有点大材小用，它是一个用于大型集成的大型框架，但是您可以编写 BC（绑定组件）并执行它。性能 我不确定 ESB 是否会像 .pl/.py 这样更原始的东西一样好

。简而言之，有太多的选择。您必须根据部署环境来接听呼叫。

例如，您说“有些值可以直接映射，而其他值必须重新计算或修改。例如将客户的帐号从 ABC 提供商转换为 XYZ 提供商的帐号。这是用于请求和响应。”，如果 ABC-A/c-num 到 XYZ-A/c-num 的映射只能通过远程 EJB 调用获得，那么您可能需要考虑在 J2EE 中编写整个内容。如果您“计算”需要一些特定的库，您也必须考虑到这一点...

希望这不会使您的问题变得更糟..:)

PS：您应该开始接受之前问题的答案。正如霍姆所说。

Answer 2

尝试过 Mule ESB，它的重量非常轻。我想说的甚至比它的一些竞争还要多。我喜欢它与 SOA 或肥皂没有特别的绑定。因此，您可以构建任何类型的端点，从普通的 TCP/IP、HTTP、文件、电子邮件到任何类型的端点，实际上它有十几个连接器，您甚至可以编写自己的连接器。我还喜欢这样一个事实：消息可以是任何内容。我可能是错的，但即使其他人声称他们有各种连接器和消息格式，他们似乎也有 SOAP 隐藏在引擎盖下的某个地方，这看起来很恶心哈哈，其他一些看起来不错，但文档很差。不喜欢某些基本 JDBC 功能仅在企业版中可用的事实。即：要从存储过程调用中获取输出参数，您需要企业版。

实际上，我可以选择任何允许我创建服务器来接收 HTTP 的服务器 API，然后编写代码来转换消息，打开与下一个服务的客户端连接，将其发送出去，接收响应，然后将其重新转换回来并返回给客户端。同时确保线程和队列在服务器内正常运行。也许我可以只使用 jetty 和 servlet，并在一个请求中完成所有操作。这是一个选项，但如果我必须切换到 TCP/IP，那么我只需稍微更改一下配置即可。等着看客户怎么说。

ESB 基本上就是粘合剂和管道。我所要做的就是编写三个自定义转换器类，因为我处理的消息是专有的银行格式，并且不完全映射到简单的 XSLT/XML 转换...以及大约 20 个 XML 标签将它们放在一起...

这就是我从 Mule 中获取它所需的全部内容（不包括构建我的数据源和 SQL 查询的标签）......

<flow name="myFlow">
    <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" />
    <object-to-string-transformer />
    <custom-transformer class="com.mycom.transformer.MyTransformer" />
    <enricher target="#[variable:client]">
        <jdbc:outbound-endpoint queryKey="getClientConfig" exchange-pattern="request-response" />
    </enricher>
    <custom-transformer class="com.MyCom.transformer.MyOtherTransformer" />
    <http:outbound-endpoint exchange-pattern="request-response" host="xxx.xxx.xxx.xxx" port="80" path="some path" method="POST"/>
    <custom-transformer class="com.MyCom.transformer.BackToOtherFormat" />
</flow>

所以基本上......
1-接收带有自定义消息的 HTTP(s)
2-解析消息以获取客户号码
3- 在数据库中查找客户编号以获取其他服务的客户编号...
4- 创建新消息
5- 送去其他服务
6-将响应转换回来
7-返回给客户

Answer 3

<flow name="FileTransferFlow1" doc:name="FileTransferFlow1">
    <file:inbound-endpoint path="C:\mule_projects\filetransfer\in" responseTimeout="10000" doc:name="IncomingFile"/>
    <http:outbound-endpoint exchange-pattern="request-response" host="localhost" port="8081" doc:name="HTTP" responseTransformer-refs="Java"/>
     <custom-transformer class="com.Transformer" doc:name="Java"/>
    <file:outbound-endpoint path="C:\mule_projects\filetransfer\out" responseTimeout="10000" doc:name="OutgoingFile"/>
</flow>