问题标签 [spring-integration]

我正在尝试在客户端轮询数据库并通过 HTTP 将结果发送到收集数据的服务器。不幸的是，只有第一条消息被传递。我是弹簧集成的新手（1.0.3）

我的配置有什么问题？

客户端配置：

服务器配置：

编辑：每次我重新启动客户端时，服务器都会收到一条消息。

已解决：我不得不将 StorageService 的签名从

到

我正在开发一个 spring 集成项目（1.0.2）并且无法使 @Header 注释工作。

这是我的服务激活器：

这是错误消息：

我究竟做错了什么？

我正在尝试使用 spring 集成来解耦更长的运行操作，以更快地将响应返回给用户。

该请求在我们的数据库中创建了一个 gps 位置条目。我想做一个http请求，通过反向地理编码服务获取该gps位置的地址。这可能需要几秒钟，所以我想稍后/并行。

Spring Integration 对此非常有效，尽管我遇到的问题是，如果并行运行的服务要快，则在将位置条目保存在数据库中时会发生冲突。

是否有关于如何在 Spring Integration 中处理持久对象的最佳实践？我是否应该尝试锁定对象，直到处理主请求？

更新：

基本上我有两种方法来操作我的位置对象（伪 Java 代码）：

一个在 MVC 控制器调用的服务类中：

并且位于由附加到 locationChannel 的 ServiceActivator 调用的 Service 类中：

我实现了 Message 接口以包含一些与服务器端的 HeaderValueRouter 一起使用的标头。

在一个虚拟机中，这可以工作（使用两个端点之间的过滤器进行测试）。

但是，如果我通过 HttpOutboundGatway 发送消息，我的字段将被剥离（不包含在 HttpRequest 中）。因此，路由信息在服务器端丢失。

我不应该操纵标题吗？

编辑：

版本是 1.0.3

我的配置部分是：

我有一个带有以下方法签名的弹簧集成拆分器：

消息有效负载是 String[] 的 ArrayList。拆分器读取列表中的每一行，创建一个新消息，将有效负载设置为列表中的数据项，将 CorrelationId、SequenceNumber 和 SequenceSize 添加到标头，最后返回消息的 ArrayList。

问题是当每个单独的消息被发送到下一个通道时，CorrelationId、SequenceNumber 和 SequenceSize 都被新值覆盖。这是预期的行为还是我错过了什么？

下面的代码片段：

使用 Spring Integration 2.0 M6

我正在使用消息驱动通道适配器从 MQ 队列中读取消息，这在开发中运行良好。现在，为了准备第一个生产版本，我必须改为读取安全队列。

我需要做什么？

我想我需要确保将以下内容设置为系统属性，但是使用什么值？

我从 jndi 获得 connectionFactory，它具有 SSLCipherSuite 集。

我获得了一个明文密码和一个包含密钥库和信任库的 JKS 文件

接下来我需要做什么？

我正在使用 Spring Integrations 2.0.0 并尝试配置以下内容：

应用程序将对象放置在由 Spring 集成驱动的后端处理的 ActiveMQ JMS 队列上。发送应用程序正在等待临时响应队列上的回复，因为后端将响应放置在此特定队列中，仅供此应用程序使用。消息在后端被接收和处理，响应应该放在 JMS 请求消息（reply-to）中给出的临时响应队列中。在后端，消息在响应最终放入响应队列之前通过一系列服务运行。

问题：如何配置 SI 以将响应放置到临时队列？SI 有什么方法可以自动执行此操作，还是我需要使用 DestinationResolver 或类似的东西？我知道 jms-gateway 可能是解决此问题的正确解决方案，但无法完全弄清楚如何将其放置到位。有任何想法吗？

我发现这个序列在这里设置基本身份验证：

如何通过使用弹簧配置来实现这一点？背后的原因是，我需要为 spring-integration HttpOutboundGateway 启用身份验证。我在这个主题上找到的唯一一条信息是

• 问题是：如何进行弹簧配置？
• 其次，如何将 HttpClient 注入到 spring-integration 中？

我是 Spring 的初学者，我必须为学校做一个项目。我可以做什么样的项目，我可以使用 Spring Batch 和 Integration。我知道我可以将文件写入目录，写入、读取和修改逗号分隔的文件，但我无法想象可以结合这些技术的场景。

我正在尝试编写一些代码来读取电子邮件并提供宁静的网络服务。

我有一个简单的测试文件，可以从 gmail（通过 pop）读取消息。但是，似乎当我将 cxf-rf-frontend-jaxrs 添加到我的 pom.xml 时，它会停止该测试文件的工作。

有谁能解开这个？

谢谢，代码和内容如下。

错误是：

测试文件是 src/test/java/mail/GmailManualTester.java

pom.xml 是

编辑：从 ~/.m2/.../cxf-rt-frontend-jaxrs-2.3.0.pom 文件中获取所有依赖项，并将它们作为排除项放在我自己的 pom.xml 中。打开和关闭它们，直到我发现只有一个导致它：

如果我把它放到我的 pom 文件中，我可以检索消息。如果我将其注释掉，我会从上面得到错误。不过，现在仍需要进一步深入研究。排除这可能会破坏我的应用程序中的网络服务。