问题标签 [enterprise-integration]

我是 Spring Integration 和 EIP 的新手。

我试图解决自己，但它不会在我的脑海中出现正确的解决方案。

这是我需要的流程示例。

1. 客户端向 SI 发送 Json 数据。
2. HTTP 入站网关将 Json 数据作为有效负载。
3. 此 Json 数据将用于两个单独的 HTTP 出站。但是第二个出站呼叫是在第一个呼叫出站呼叫的响应之后进行的。
4. 将结果回复到第 0 步（HTTP 入站网关上的回复通道）

我正在考虑使用 publishSubscribeChannel 或 RecipientListRouter 将相同的消息发送到单独的调用。但在这种情况下，它需要在特定时间执行第二个 http outbound。据我了解，这应该是第 4 步回复的一项交易。

或者...

是否可以在第一次调用后的第二次调用中保留消息实例（来自 http 入站网关的 JSON 数据）。

请给我一些想法，如果您有示例代码，那一定很棒。目前我正在编写 JAVA 配置样式，但也欢迎 XML 示例。

更新问题

我正在尝试添加网桥和 executorChannel。

这是我的代码，几乎没有按我预期的那样工作。

1. 我想第二个出站处理程序（httpPMGateway）使用来自 aIncomingGateway 的消息（因此使用 publishSubscribeChannel），但是在 httpJ3Gateway 出站处理程序之后，它使用来自 httpJ3Gateway 的消息。我将路由与来自 httpJ3Gateway 的响应消息一起使用。（好的-> httpPMgateway，默认-> backAChannel）

2. 我想从 j3ValidationFlow 或广播流的末尾向 aIncomingGateway 发送响应消息。但是 aIncomingGateway 在发送之前就已经收到了回复消息。这是日志消息。

2017-05-16 11:17:09.061 WARN 11488 --- [pool-1-thread-1] cMessagingTemplate$TemporaryReplyChannel ：收到回复消息，但接收线程已经收到回复：

这是代码部分：

请帮我想出一个主意。
我提前表示感谢。谢谢你在这个愚蠢的问题上帮助我。

我试图了解更多关于Apache Camel、 Mule ESB 、 JBoss ESB]...以及一般来说ESB。我可以在 Apache Camel 中找到几个 ESB 特性。那么，我可以像 ESB 一样使用 Apache Camel 还是 Apache ServiceMix 是最合适的？

作为一个无关紧要的、自以为是的观点，我发现 apache camel 文档过于冒昧地假设读者已经有骆驼的背景。

通常来说，Web 服务提供者是生产者，而它所生产的服务的客户端是消费者。

让我们看一下http://camel.apache.org/pojo-produce.html。

也就是说，有两种不同的方式可以向 Camel Endpoint 发送消息。

是不是在说

• 嘿，我是一个端点，这是我的 uri 和一个模板来打我，所以打我

• 或者，嗯……在晴朗的蓝天下某处有一个带有这个 uri 的端点，这是我想我会用的模板

？？？

同样是@Produce，和ProducerTemplate

• 指定我是一个会被击中的端点？
• 或指定我要打的制作人的模板？

同样，@Consume，

• 我是否指定我是消费者？
• 或者我正在指定如何消费？

顺便说一句，@Produce(uri) 或 EndpointInjection (uri) 中的 uri

• 我要发送到这个 uri 吗？
• 或在此 uri 下接收？

WRT http://camel.apache.org/rest.html。

1. 客户端是否使用此组件设置端点以到达现有服务器？

   • 如果是这样，这是否意味着骆驼为我提供了不止一种方法？我应该改用 http 组件.to("http://endpointuri")吗？
   • 客户端使用rest组件比http组件有什么优势？

   或者

2. 服务提供者用来设置服务提供者？？

   • 如果是这样，这是否意味着骆驼为我提供了不止一种方法？请参阅http://camel.apache.org/rest-dsl.html。
   • 客户端使用rest组件比http-dsl有什么优势？

1 还是 2？供客户端或服务器使用？像往常一样，骆驼文档具有未指定的间接性。

我需要实现以下架构：

1. 我有必须使用 JMS 发送到系统（某些外部应用程序）的数据。

2. 根据您需要仅发送到必要系统的数据（例如，如果系统数量为 4，那么您可以从 1 发送到 4 ）

3. 需要等待消息发送到的系统的响应，在收到所有响应后，需要处理接收到的数据（或至少处理一次超时）

4. 相关 ID 包含在传出和传入 JMS 消息的标头中

5. 每个新的此类进程都可以异步并行启动

现在我只在 Spring JMS 的帮助下实现了它。我手动同步线程，也手动管理线程池。

有关发送消息的系统的相关 ID 和信息被存储为状态，并在接收到新消息等后更新它。

但我想简化逻辑并使用 Spring 集成 Java DSL、Scatter 聚集模式（这只是我的情况）和其他有用的 Spring 特性。

你能帮我展示一个如何在 Spring-integration/IntregrationFlow 的帮助下实现这种架构的例子吗？

我必须创建响应客户端请求的 tcp 服务器，并以固定频率将事件发送给客户端。Tcp 服务器代码：

当我的服务器必须从客户端向 msg 发送响应时，将调用 EchoService bean 代码

我还有另一个 MessageService bean，它以固定频率发送 Hi 消息。我想将此 bean 集成到我的服务器，以便我可以向客户端发送“Hi”消息

我无法决定如何将 MessageService bean“hi”msg 与 tcp 服务器集成以发送 TCP 客户端。PS：- 我是骆驼的新手。

What is the difference between

and

我是 Dell Boomi 的新手，现在我进入了新开发人员证书路径 1。在执行用户定义的地图功能时，我收到一条错误消息，例如测试执行潜在客户跟踪完成时出现错误。嵌入式消息：输入值“潜在客户”不是数字;java.lang.NumberFormatException

我刚刚开始使用使用 Apache Camel 2.15.3 的应用程序。我是 Camel 的新手，我正在尝试了解消息是如何发送的以及路由中组件之间的外观。

应用程序中的路由是使用 spring 扩展 xml 设置的。以下是其中一条路线的外观示例。

首先是一个简短的术语问题：这个例子中的中间 bean 叫什么？端点？成分？或者是其他东西？现在我称它们为组件。

我现在的主要困惑是要了解什么是输入，什么是从一个组件传递到下一个组件。在这种情况下，所有组件都是具有一个公共方法的 javabean。该方法有时具有 void 返回类型，有时返回一些对象。例如String，List，一个camel Message-object，一个不实现任何camel接口的项目自定义对象。有时返回类与以下 bean 的参数匹配，有时则不匹配。

我不明白返回和输入到组件的限制是什么，并且能够读取和预测消息在 bean 中的样子。

我已经阅读了 Camel 网站上的一些文档，但我的谷歌搜索并没有发现任何有用的信息。

是否有人对要搜索的内容有解释或提示，或者有指向某个地方的链接来解释正在发生的事情？

我正在构建一个使用 EDI X12 格式与不同企业对话的应用程序。我们使用 BizTalk 本地设置执行此操作，但遇到了一些问题，因此我们决定迁移到 Azure Logic 应用程序。

我已经设置了一个集成帐户并将所有合作伙伴、协议、模式和地图上传到其中。我还创建了一个逻辑应用程序，其中包含：

1. 请求触发器 - 将 xml 发布到此端点
2. XML 变换 - 基于地图进行变换
3. 转换为 EDI - ?? 这是我缺少的部分
4. 发送 EDI 作为响应

基本上，我想传入 XML 并将其转换为 EDI 文件。我尝试了各种 X12 连接器（编码、解码），但它们没有将其转换为 EDI。

我真的可以使用一些帮助。