Я новичок в интеграции с Spring, поэтому это может быть глупо для экспертов.
Я хочу читать файл Excel, который находится на SFTP-сервере каждое утро (сейчас я настроен на чтение каждую минуту, как показано ниже),Я написал весь код, который получает входной поток Excel и использует POI для его обхода.
Если я даю файл вручную, как загруженный из JSP, тогда нет проблем, все работает нормально.
Но когда я включаюSpring интеграции с использованием приведенного ниже кода, то это дает мне ошибку.
Я обнаружил, что «DefaultSftpSessionFactory» имеет внутреннюю зависимость от «jsch-0.1.51.jar», и это также получает комплект как часть моего артефакта.
https://docs.spring.io/spring-integration/api/org/springframework/integration/sftp/session/DefaultSftpSessionFactory.html
Я использую пружину 4.0.9.
К вашему сведению, контроль не приходит до моего метода "processFTPFile".
<bean id="ultiProSftpSessionFactory" class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory">
<property name="host" value="serverhost" />
<property name="user" value="user" />
<property name="password" value="password" />
</bean>
<int-ftp:inbound-channel-adapter id="ftpInboundChannelAdapter" session-factory="ultiProSftpSessionFactory" channel="fileAvailableChannel"
filename-pattern="* Consolidated Report.xlsx"
remote-directory="/folder1/folder2"
preserve-timestamp="true"
local-directory="."
auto-create-local-directory="true"
delete-remote-files="false"
auto-startup="true">
<int:poller cron="0 0/1 * * * *">
</int:poller>
</int-ftp:inbound-channel-adapter>
<int:service-activator id="serviceUpdateTrackingItem" method="processFTPFile" ref="cAPunchDataAdapter" input-channel="fileAvailableChannel" />
<int:publish-subscribe-channel id="fileAvailableChannel"/>
Код, который я хочу выполнить для каждого файла
@Component("cAPunchDataAdapter")
public class CAPunchDataAdapter {
public void processFTPFile(FTPFile file) {
//Code goes here to get inputstream of file.
}
}
Ниже приведены журналы ошибок.
[3/4/19 18:20:00:731 EST] 00002560 SystemErr R [ERROR] LoggingHandler - -org.springframework.messaging.MessagingException: Problem occurred while synchronizing remote to local directory
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer.synchronizeToLocalDirectory(AbstractInboundFileSynchronizer.java:209)
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource.receive(AbstractInboundFileSynchronizingMessageSource.java:167)
at org.springframework.integration.endpoint.SourcePollingChannelAdapter.receiveMessage(SourcePollingChannelAdapter.java:144)
at org.springframework.integration.endpoint.AbstractPollingEndpoint.doPoll(AbstractPollingEndpoint.java:192)
at org.springframework.integration.endpoint.AbstractPollingEndpoint.access$000(AbstractPollingEndpoint.java:55)
at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:149)
at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:146)
at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller$1.run(AbstractPollingEndpoint.java:298)
at org.springframework.integration.util.ErrorHandlingTaskExecutor$1.run(ErrorHandlingTaskExecutor.java:52)
at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50)
at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:49)
at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:292)
at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:522)
at java.util.concurrent.FutureTask.run(FutureTask.java:277)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:191)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1153)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.lang.Thread.run(Thread.java:785)
Caused by: org.springframework.messaging.MessagingException: Failed to execute on session
at org.springframework.integration.file.remote.RemoteFileTemplate.execute(RemoteFileTemplate.java:321)
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer.synchronizeToLocalDirectory(AbstractInboundFileSynchronizer.java:167)
... 20 more
Caused by: java.lang.ClassCastException: com.jcraft.jsch.ChannelSftp$LsEntry incompatible with org.apache.commons.net.ftp.FTPFile
at org.springframework.integration.ftp.filters.FtpSimplePatternFileListFilter.getFilename(FtpSimplePatternFileListFilter.java:29)
at org.springframework.integration.file.filters.AbstractSimplePatternFileListFilter.accept(AbstractSimplePatternFileListFilter.java:49)
at org.springframework.integration.file.filters.AbstractFileListFilter.filterFiles(AbstractFileListFilter.java:40)
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer.filterFiles(AbstractInboundFileSynchronizer.java:157)
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer$1.doInSession(AbstractInboundFileSynchronizer.java:173)
at org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer$1.doInSession(AbstractInboundFileSynchronizer.java:167)
at org.springframework.integration.file.remote.RemoteFileTemplate.execute(RemoteFileTemplate.java:312)
... 21 more