java - 如何使用 spring 集成轮询目录中的文件并将文件发送到消息队列

Question

我正在尝试开发一个应用程序，希望能够使用该应用程序将 zip 文件发送到在单独服务器上运行的消息队列。我已经使用 ActiveMQ 成功实现了消息传递位，并且队列已启动并监听服务器端的消息。我有一个类似的应用程序，它将 json 文件作为消息发送到队列，并且工作正常。我正在尝试根据前一个应用程序的实现方式来编写我的应用程序。

以下是我的 spring 集成配置的一部分:

<int-file:inbound-channel-adapter id="filesIn" directory="${harvest.directory}" filename-pattern="*.zip">
    <int:poller id="poller" fixed-rate="${harvest.pollRate}" max-messages-per-poll="${harvest.queueCapacity}" />
</int-file:inbound-channel-adapter>

<int:transformer id="copyFiles" input-channel="filesIn"
    output-channel="routingChannel" ref="transformationHandler" method="handleFile"/>

<int-jms:outbound-channel-adapter id="jmsOut" destination="requestQueue" channel="filesIn"/>
.
.
.
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${activemq.url}" />
</bean>
<bean id="requestQueue" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="myQueue"/>
</bean> 

正如你所看到的，有一个变压器。但就我而言，我没有什么可以改造的，如果可能的话，我很乐意放弃变压器。我只需要能够轮询目录中是否有 zip 文件，只要有，就将其发送到名为 myQueue 的队列。 。不幸的是，从 filesIn 接收文件的方法入站 channel 适配器并使用 jmsOut 发送到队列出站 channel 适配器似乎无法正常工作。

我不确定这是否是正确的方法或者是否可行。有人可以告诉我这里出了什么问题以及我应该做什么吗？

Answer 1

我知道您的问题是如何纯粹在 Spring 中执行此操作，但是您是否考虑过使用 Apache Camel ？

特别是File组件和 JMS (JMS/ActiveMQ) 组件之一。

它会为您进行轮询并且高度可配置。它也可以很好地与您在示例中使用的其他技术配合使用。该路由可以完全在 Spring 中配置。