4

私は春の統合に取り組んできました<int-ftp:outbound-gateway>,私はリモートサーバーからファイルをダウンロードすることができましftp-outbound-gatewayたその時点から実行せずにファイル システムがハングアップします。システムを続行したいです。リモートフォルダにファイルが含まれているかどうか、

これがftpダウンロードの私の構成です

 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:int="http://www.springframework.org/schema/integration"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:int-ftp="http://www.springframework.org/schema/integration/ftp"
       xsi:schemaLocation="http://www.springframework.org/schema/integration/ftp
        http://www.springframework.org/schema/integration/ftp/spring-integration-ftp.xsd
        http://www.springframework.org/schema/integration
        http://www.springframework.org/schema/integration/spring-integration.xsd
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">

    <context:property-placeholder location="classpath:host.properties"/>

    <int:gateway id="gw" service-interface="com.util.ToFtpFlowGateway"
                 default-request-channel="inbound"/>

    <bean id="downloadProcessBean" class="com.util.FTPDownloadInterceptor">
        <property name="fileType" value="txt"/>
        <property name="sourceType" value="ftp"/>
        <property name="destinationName" value="destinationName"/>
        <property name="destinationQueName" value="destinationQueName"/>
        <property name="sourceAddressDetails" value="sourceAddressDetails"/>
        <property name="sourceName" value="sourceName"/>
    </bean>

    <bean id="ftpSessionFactory"
          class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
        <property name="host" value="${local.host}"/>
        <property name="port" value="${local.availableServerPort}"/>
        <property name="username" value="${local.userid}"/>
        <property name="password" value="${local.user.password}"/>
    </bean>

    <int-ftp:outbound-gateway id="gatewayLS" cache-sessions="false"
                              session-factory="ftpSessionFactory"
                              request-channel="inbound"
                              command="ls"
                              command-options=""
                              expression="payload"
                              reply-channel="toSplitter" reply-timeout="10" />

    <int:channel id="toSplitter">
        <int:interceptors>
            <int:wire-tap channel="logger"/>
        </int:interceptors>
    </int:channel>

    <int:logging-channel-adapter id="logger" log-full-message="true" />

    <int:splitter id="splitter" input-channel="toSplitter" output-channel="toGet"/>

    <int-ftp:outbound-gateway id="gatewayGET" cache-sessions="false"
                              local-directory="/home/udeshika/project/req/local/download"
                              session-factory="ftpSessionFactory"
                              request-channel="toGet"
                              reply-channel="toRemoveChannel"
                              command="get"
                              command-options="-P"
                              expression="payload.remoteDirectory + '/' + payload.filename" reply-timeout="10"/>

    <int-ftp:outbound-gateway id="gatewayRM"
                              session-factory="ftpSessionFactory" cache-sessions="false"
                              expression="payload.remoteDirectory + '/'+ payload.filename"
                              request-channel="toRemoveChannel"
                              command="rm"
                              reply-channel="aggregateResultsChannel"
                              auto-create-local-directory="true"
                              reply-timeout="10"

            />
    <!--<bean id="fileDownloadIntecepter" class="shipxpress.util.FTPDownloadInterceptor"/>-->
    <int:channel id="toRemoveChannel">
        <int:interceptors>
            <int:wire-tap channel="logger2"/>
            <!--<int:ref bean="fileDownloadIntecepter" />-->
        </int:interceptors>
    </int:channel>

    <bean class="org.springframework.integration.file.FileReadingMessageSource"
          p:directory="${download.directory}"/>

    <int:logging-channel-adapter id="logger2"  log-full-message="true" />

    <int-ftp:outbound-gateway id="gatewayRM"
                              session-factory="ftpSessionFactory" cache-sessions="false"
                              expression="headers['file_remoteDirectory'] + '/' + headers['file_remoteFile']"
                              request-channel="toRemoveChannel"
                              command="rm"
                              reply-channel="aggregateResultsChannel"/>

    <int:aggregator input-channel="aggregateResultsChannel"/>

</beans>

誰か私がこれをクリアするのを手伝ってくれませんか?

うでしかさん、よろしくお願いします

4

1 に答える 1

3

このフローの問題は、LS が空のリストを返すことです。これがスプリッターに到達すると、メッセージが発生せず、フローが停止します。ゲートウェイを呼び出すスレッドは、応答を永遠に (デフォルトで) 待ちます。

ゲートウェイに応答タイムアウトを追加すると、応答が受信されない場合は null が返されます。

<int:gateway id="gw" service-interface="org.springframework.integration.samples.ftp.ToFtpFlowGateway"
    default-request-channel="inbound" default-reply-timeout="100" />

Direct チャネルを使用している限り、実行する実際の作業があるときにゲートウェイがタイムアウトする危険はありません。これは、スレッドがゲートウェイに戻ってダウンストリーム フローによって生成された応答を探すまでタイマーが開始されないためです。

于 2013-06-20T09:21:15.883 に答える