问题标签 [spring-integration]

Spring集成和JBoss jBPM有什么区别？

谢谢你。

Technologies Involved

• Mule
• Apache CXF

Given

A simple POJO (controversial acronym, but let's say a smart POJO):

Need to Achieve

Expose SmartPojo as a Webservice without touching the code ( without: changing SmartPojo, changing SmartPojoInterface, adding a new interface, any JAX-WS annotations, etc ). The goal is to use Mule configuration only.

I can easily do it with Spring Integration, and would appreciate any input on how to achieve it with Mule. ( It seems that "cxf:inbound-endpoint" needs to be configured with "method-entry-point-resolver" + providing my WSDL in some way.. or another direction? )

Thank you

我有一个工作流程，我想看起来像这样：

那是：

• 请求进来并进入 FIFO 队列
• 然后相同的工作人员从队列中提取任务
• 在任何给定时间，任何工人只能完成一项任务
• 当一个工作人员空闲并且持有队列非空时，工作人员应该立即拿起另一个任务
• 任务完成后，工作人员将结果放在Response Channel

我知道 Spring Integration 中有QueueChannels，但是这些通道需要轮询（这似乎不是最理想的）。特别是，如果工人可以很忙，我希望工人很忙。

此外，我考虑过完全避免排队，只是让所有工作人员循环执行任务，但最好有一条等待线，因为某些任务可能比其他任务完成得更快。此外，我想了解剩余多少工作（我可以从队列中获得）以及取消所有或特定工作的能力。

如何在避免轮询的同时实现此消息队列/工作分配模式？

编辑：看来我正在寻找Message Dispatcher 模式——如何使用 Spring/Spring 集成来实现它？

我正在尝试将队列连接到 a 的前面MessageChannel，并且我需要以编程方式执行此操作，以便可以在运行时完成以响应osgi:listener被触发。到目前为止，我有：

浏览各种相关课程，我想出了：

但我无法将它们放在一起。我错过了什么？

我有以下方法，并希望避免显式显示 JAXBElement<> 语法。是否有某种注释可以让该方法看起来接受原始 MessageResponse 对象，但实际上与下面所示的工作方式相同？我不确定这有多清楚，所以我会这样说：我正在寻找一些语法糖 :)

此配置工作正常，但应该每 15 秒轮询一次的入站通道适配器正在连续运行。有谁知道我做错了什么？

对于以下场景，我正在寻找您关于最佳实践的建议和技巧：

在分布式（主要基于 Java）系统中：

• 许多（不同的）客户端应用程序（网络应用程序、命令行工具、REST API）
• 中央 JMS 消息代理（目前支持使用 ActiveMQ）
• 多个独立处理节点（在多台远程机器上运行，计算 JMS 消息有效负载指定的不同类型的昂贵操作）

如何最好地应用Spring Integration框架提供的 JMS 支持来将客户端与工作节点分离？在阅读参考文档和一些最初的实验时，看起来 JMS 入站适配器的配置本质上需要使用订阅者，而在解耦场景中不存在订阅者。

小注：应该通过 JMS 文本消息进行通信（使用 JSON 数据结构以实现未来的可扩展性）。

我正在考虑对spring-integration的消息序列化支持。这对于实现保证交付的各种线路级传输非常有用，而且还允许与其他消息传递系统（例如通过 AMQP）进行互操作。

出现的基本问题是，在其有效负载和标头中包含 Java 对象的消息应转换为byte[]和/或写入流。Java 自己的序列化显然不会削减它，因为它不可互操作。我的偏好是创建一个接口，允许用户为参与序列化的所有对象实现所需的逻辑。

这意味着我不想要求客户端开发人员生成他的域代码，而是为需要它的对象定义一个序列化程序。接口将类似于：

这是一个明智的想法吗？完美的界面会是什么样子？是否有一种标准的可互操作方式来序列化在这种情况下有意义的对象？

作为一名经验丰富的 Spring 用户，我假设 Spring Integration 在最近需要一些 (JMS) 消息传递功能的项目中最有意义（更多详细信息）。在使用 Spring Integration 工作了几天之后，考虑到您必须配置的通道数量来实现一些请求-响应（侦听不同的 JMS 队列）通信，它仍然感觉有很多配置开销。

因此，我一直在寻找一些背景信息 Camel 与 Spring Integration 的不同之处，但似乎那里的信息非常空闲，我发现：

• http://java.dzone.com/articles/spring-integration-and-apache（从 2009 年 12 月开始，在 Spring Integration 与 Camel 中实现真实世界的集成场景之间进行了非常中性的比较）
• http://hillert.blogspot.com/2009/10/apache-camel-alternatives.html（Camel与其他解决方案的比较，2009 年 10 月）
• http://raibledesigns.com/rd/entry/taking_apache_camel_for_a（Matt Raible，2008 年 10 月）

问题是：你在使用一个堆栈而不是另一个堆栈方面有什么经验？在 Spring Integration 缺乏支持的情况下，您会在哪些情况下推荐 Camel？您在哪里看到每种方法的优缺点？来自实际项目的任何建议都将受到高度赞赏。

我有这个：

而且我认为我正在配置的是一个异步队列。我希望能够将消息放到它上面，然后让另一个线程拾取它们并稍后处理。但是，目前它似乎以同步的方式进行。

我做错了吗（显然是的），但想知道我在这个配置中是否缺少一些东西，或者我是否只是有错误的方法？

干杯