Ich bin neu in Spring-Integration und ich versuche, POC mit Spring-Integration FTP-Dateiadapter zu tun, um Dateien von FTP-Speicherort zu lesen. Wenn ich meine Anwendung auf zwei Tomcat-Instanzen bereitgestellt habe, sehe ich, dass beide Instanzen Dateien vom FTP-Speicherort herunterladen.Spring Integration FTP-Dateiadapter auf mehreren Instanzen Verarbeitung von Duplikaten
Ich benutze virtuellen FTP-Server (Xlight) auf meinem Computer ausgeführt. Als ich die Dateien zum ersten Mal in das Remote-Verzeichnis kopiert habe, haben beide Instanzen Dateien heruntergeladen, aber wenn ich wieder einige Dateien in den Remote-Ordner kopiere, hat eine der Instanzen keine neu hinzugefügten Dateien ausgewählt. Eines der Dinge, die ich auch erreichen möchte, wenn meine Anwendung auf mehreren Instanzen bereitgestellt wird, möchte sicherstellen, dass eine Datei nur einmal verarbeitet wird.
Bitte schlagen Sie vor, was ich vermisse.
Unten ist meine Konfigurationsdatei:
<bean id="ftpSessionFactory" class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
<property name="host" value="${ftp.host}"/>
<property name="port" value="${ftp.port}"/>
<property name="username" value="${ftp.username}"/>
<property name="password" value="${ftp.password}"/>
<!-- whether server should connect to client's port or client should connect server port for initiating file transfer -->
<!-- <property name="clientMode" value="${ftp.clientMode}"/> -->
<!-- different file types involve ASCII , EBCDIC , BINARY (default) -->
<!-- <property name="fileType" value="${ftp.fileType}"/> -->
<!-- <property name="bufferSize" value="${ftp.bufferSize}"/> -->
</bean>
<int-ftp:inbound-channel-adapter id="ftpInbound" channel="ftpInboundChannel" session-factory="ftpSessionFactory" charset="UTF-8" auto-create-local-directory="true" delete-remote-files="false" remote-directory="/SpringFtpOutbound/remote" remote-file-separator="/" preserve-timestamp="false" temporary-file-suffix=".writing" local-filter="myFilter" local-directory="/work/SpringFtpInbound_2">
<int:poller fixed-rate="2000" max-messages-per-poll="1"/>
</int-ftp:inbound-channel-adapter>
<bean id="myFilter" class="org.springframework.integration.file.filters.CompositeFileListFilter">
<constructor-arg>
<list>
<bean class="org.springframework.integration.file.filters.FileSystemPersistentAcceptOnceFileListFilter">
<constructor-arg name="store" ref="metadataStore"/>
<constructor-arg value="*.*"/>
</bean>
<bean class="org.springframework.integration.file.filters.SimplePatternFileListFilter">
<constructor-arg value="*.xml" />
</bean>
</list>
</constructor-arg>
</bean>
<bean id="redisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" p:use-pool="true" p:host-name="localhost" p:port="6379" />
<bean name="metadataStore" class="org.springframework.integration.redis.metadata.RedisMetadataStore">
<constructor-arg name="connectionFactory" ref="redisConnectionFactory"/>
</bean>
<int-file:file-to-string-transformer id="myFileToStringTransfromer" input-channel="ftpInboundChannel" output-channel="transformChannel" />
<int-xml:xpath-splitter id="ftpFileSplitter" input-channel="transformChannel" output-channel="xpathSplitterChannel">
<int-xml:xpath-expression expression="/bancsRequest/input"/>
</int-xml:xpath-splitter>
<int:transformer id="myCustomTransformer" ref="myTransformerBean" input-channel="xpathSplitterChannel" method="transform" output-channel="ftpOutboundChannel">
</int:transformer>
<bean id="myTransformerBean" class="com.ntrs.geh.ftp.file.poc.transformer.MyXmlPayloadTransformer"/>
<int-jms:outbound-channel-adapter id="outboundChannelAdapter" channel="ftpOutboundChannel" jms-template="ftpOutQueueJmsTemplate" >
</int-jms:outbound-channel-adapter>