每当Spring Integration Poller触发时写入日志
，可以通过以下方式实现：
- Spring Integration是一个轻量级的集成框架，用于构建企业级应用程序的消息驱动和事件驱动的解决方案。它提供了一种简单而强大的方式来处理消息传递、事件驱动和集成模式。Spring Integration中的Poller是一个定时任务，用于轮询消息通道并触发相应的处理逻辑。
- 写入日志是一种常见的记录系统运行状态和问题的方式，可以帮助开发人员进行故障排查和性能优化。在Spring Integration中，可以使用日志框架（如Log4j、Logback等）来记录Poller触发时的相关信息。
- 在Spring Integration中，可以通过配置Poller的触发条件和处理逻辑来实现日志记录。可以使用Spring Integration的配置文件（如XML配置文件、Java配置类等）来定义Poller的触发频率、触发条件和处理逻辑。在处理逻辑中，可以调用日志框架的API来记录相关信息。
- 优势：通过记录Poller触发时的信息，可以及时发现系统运行状态和问题，帮助开发人员进行故障排查和性能优化。同时，日志记录也可以作为系统运行的证据，用于追踪和审计系统的操作和行为。
- 应用场景：日志记录可以应用于各种场景，如系统监控、故障排查、性能优化、安全审计等。在Spring Integration中，可以将日志记录应用于消息通道的监控、消息处理的跟踪、系统运行的审计等场景。
- 推荐的腾讯云相关产品：腾讯云提供了一系列与云计算和日志记录相关的产品和服务，如云服务器、云数据库、云原生应用平台、云监控等。其中，云监控可以帮助监控系统的运行状态和性能指标，提供实时的日志记录和告警功能。您可以访问腾讯云官网了解更多产品和服务的详细信息：腾讯云产品介绍
请注意，以上答案仅供参考，具体的实现方式和产品选择应根据实际需求和情况进行评估和选择。
相关·内容
我正在测试，我遇到了以下问题。
我的SI ver-1.0.4
为了更容易理解，我正在粘贴以下内容：
fileCopyDemo-text.xml
<file:inbound-channel-adapter id="filesIn"
directory="file:${java.io.tmpdir}/spring-integration-samples/input" filename-pattern=".*\.xml">
<integrati
浏览 1提问于2013-01-05得票数 2
回答已采纳
2回答
我正在执行一个spring引导项目，我需要为从某个位置轮询文件添加Spring集成计票器，并在该文件上运行spring批处理来处理它。
为此，我使用了spring批处理集成(请参阅下面的文档)。
在spring引导中，我已经成功地在@配置文件中配置了我的poller，如下所示
@Bean
@InboundChannelAdapter(value = "fileInputChannel", poller = @Poller(
fixedRate = "1000"), autoStartup = "true")
public MessageSo
浏览 12提问于2016-10-07得票数 0
回答已采纳
1回答
最近，我们向spring集成轮询器引入了任务执行器，以加快我们的文件读取过程。然而，引入任务执行器导致了意外的问题，在我们的服务中停止处理spring集成通道中的消息 <?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:integ
浏览 19提问于2020-08-19得票数 0
1回答
我有application.yml配置
cloud:
stream:
poller:
# Cron for polling data.
cron: 0 0/30 * * * *
........
我正面临这样的错误
Description:
The following configuration properties are mutually exclusive:
spring.integration.poller.cron
spring.integration.poller.fixed-delay
浏览 13提问于2022-04-27得票数 1
回答已采纳
我正在努力实现一个缓冲区，以便执行各种作业。我正在做一个基于Spring的项目。我决定使用Spring Integration来实现我的目标。为了理解SI是如何工作的，我经历了一个Cafèsample项目。
为了演示Spring Integration，我实现了一个表，我在其中动态插入要执行的作业。这个表就是“网关”。然后，我配置了一台路由器和各种通道。
我不完全理解的是poller元素，它必须检查“网关”中是否存在新的工作。这是正确的吗？
如果是这样，我如何配置轮询器？提前感谢！下面是xml代码：
<?xml version="1.0" encoding="UT
浏览 8提问于2013-05-16得票数 0
2回答
如何使用spring集成将文件从一个位置复制到另一个位置。在我的例子中，我希望将war外部的文件复制到war内部。下面是我正在考虑的代码片段：
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns:beans="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
浏览 1提问于2011-02-04得票数 0
1回答
在计票器从DB获取数据后，我将调用外部服务。在从该服务获得响应后，我想在一个单独的线程中调用另一个系统。这意味着，在得到响应后，我的计票程序应该再进行一次记录，并且send.In加法调用其他系统应该并行地工作。
为此，我使用了一个直接通道来接收来自DB的数据。使用服务激活器向外部服务发送请求。响应被传递给一个执行者channel.can，请告诉我下面的配置对于这个场景是否正确？
为了清晰起见，我共享poller.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http
浏览 1提问于2015-11-26得票数 0
回答已采纳
1回答
我有一个流，它从目录读取csv文件，拆分行，然后处理每一行并从每一行提取2个对象。然后将这两个对象发送到两个独立的int-mongodb:outbound-channel-adapter。在处理和保存所有行之后，我希望删除传入的文件。我看过使用事务管理器对入站适配器执行此操作的示例，但没有使用出站适配器。有办法这样做吗？
我的配置如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans
浏览 2提问于2015-06-11得票数 2
回答已采纳
下面的程序可以发送消息并使用队列中的消息，现在我已经注释掉发送部分，只想使用队列中的消息。
现在我想在下面的程序中启用日志记录，以便在我的c:驱动器中生成一个日志文件，并且在这个日志文件中它应该指示它在什么时候正在使用什么消息，请建议如何在下面的配置文件中配置日志记录。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.
浏览 0提问于2016-02-28得票数 4
我的头撞到了墙上，因为我不知道为什么交易没有回滚。
我在我的项目中使用了spring集成，我的applicationContext.xml如下所示：
<context:component-scan base-package="com.jms.spring.integration.*"></context:component-scan>
<tx:annotation-driven/>
<int:poller default="true" id="poller" fixed-delay="500&
浏览 9提问于2016-07-15得票数 0
回答已采纳
我有一个Spring Boot应用程序，它使用Spring Cloud Config刷新其属性。我可以很容易地用@RefreshScope刷新我的控制器，但是我不确定如何对我的poller做同样的事情来重新启动我的Spring Integration作业。
我的integration-config.xml：
<context:property-placeholder location="file:///C:/workspace/config/tasky-dev.properties" />
<int:inbound-channel-adapter ref=&
浏览 10提问于2018-08-18得票数 0
回答已采纳
我已经使用Apache POI API生成了一个Excel文件，并尝试使用Spring Integration将其发送到远程目录，但当我在编写下面的代码时给出了编译时错误，因为它只支持“文件”类型对象Excel类型为"HSSFWorkbook“。
HSSFWorkbook workbook = gerateExcelFile(data);
excelCollector.add((workbook);
并对"inbound-channel-adaptor“使用下面的代码
<inbound-channel-adapter id="excelAdapter"
浏览 2提问于2015-06-11得票数 1
我将Spring Batch和Spring Integration结合在一起，我使用的是poller和玉米：
@Bean
@SchedulerLock(name = "importEntitiesRiskCodes", lockAtMostForString = "PT5M")
public IntegrationFlow integrationFlow() {
return IntegrationFlows.from(fileReadingMessageSource(),
c -> c.poller(Pollers.cro
浏览 3提问于2021-01-22得票数 0
1回答
我们有一个spring-boot应用程序(spring-boot-starter-parent-2.0.0.RELEASE)，它使用spring-cloud-starter-zipkin将“span”写入zipkin。
我们也使用了spring-integration (通过spring-boot-starter- integration )，并且我们已经添加了一个带有PollableChannel的集成流，以便在轮询器中使用：
@Bean
public PollableChannel pollableChannel() {
return new QueueChannel(100);
浏览 0提问于2018-07-20得票数 0
我正在使用Spring Integration从FTP服务器检索文件(使用SFTP)。我的问题是FTP服务器上的文件名包含重音字符('é'，'à‘等)。找到这些文件时没有问题，但一旦传输完成，重音符号就会替换为其他字符，如“？”。我在想..。Spring Integration中有没有我遗漏的配置？
顺便说一句，FTP服务器和应用服务器都在Linux Ubuntu下。
下面是我的Spring集成配置：
<beans:bean id="sftpSessionFactory"
class="org.springframe
浏览 0提问于2014-07-31得票数 0
版本： Spring: 5.2.16.RELEASE
Spring Integrations: 5.3.9.RELEASE
macOS Big Sur: 11.6 我使用XML来设置目录扫描器FileReadingMessageSource.WatchServiceDirectoryScanner，如下所示： <int-file:inbound-channel-adapter id="channelIn" directory="${channel.dir}" auto-create-directory="false" use-watch-
浏览 36提问于2021-11-02得票数 1
我想把我的xml配置转换成Java类配置，但是我找不到解决方案。例如，我的一段配置：
<file:inbound-channel-adapter id="filesIn" directory="file:${java.io.tmpdir}/spring-integration-samples/input"
filename-regex="^.*\.(xml|json)$" >
<int:poller id="poller" fixed-delay
浏览 5提问于2017-07-17得票数 2
回答已采纳
一旦消费者队列客户端使用jms入站通道适配器接收到服装消息，我希望将其作为(接收到的消息)发送到生产者队列客户端。需要帮助如何实现这一点或任何替代方式使用xml配置。
XML文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmln
浏览 0提问于2020-08-28得票数 0
我正在使用JavaSpringIntegrationVersion2.0.0和JavaSpringFramework3.0.5
我得到错误“属性‘时间单位’不允许出现在元素‘int:poller’”。在我的配置xml文件中，这给我的程序带来了很大的问题。我认为这可能是一个版本问题，但我不确定。任何帮助都将不胜感激。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi=
浏览 0提问于2014-11-06得票数 0
回答已采纳
场景:每'n‘秒轮询数据库并检索列表。做一些内部业务validations.If验证是成功的，将检索到的列表发送给外部system.Receive一个来自该系统的确认响应(接收到此之后，poller应该发送下一个列表).Then执行一些业务操作，比如调用不需要轮询的其他系统。有人能告诉我如何处理这个场景吗？
poller.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans
浏览 1提问于2015-11-07得票数 1
回答已采纳
在我的项目中，我们有一个-spring集成轮询器，它每五分钟获取一堆记录-将其发送到拆分器，拆分器在输出通道使用任务解析器以多线程方式(池大小为4)拆分记录，并发送每条记录进行进一步处理。
这一切都运行得很好。然而，问题是拆分器阻塞，直到它完全处理传递的列表。
我们的要求是，如果另一个列表被传递给拆分器，那么它需要并行处理它，而不是等待第一个列表处理完成。我尝试将另一个任务执行器放到溢出器的输入通道中，但没有解决问题。
如何让拆分器工作对于两个给定的输入列表是并行的，每个输入列表依次为其各自传递的列表运行多线程。
配置：
使用spring集成2.2.0.RELEASE和spring 3.1.1
浏览 0提问于2014-01-29得票数 0
2回答
我正在使用一个Spring Integration应用程序，它应该遍历目录的内容，处理其中的文件，然后退出。
我将下面的XML设置为每秒轮询目录，但这并不是我想要的。如何将其更改为读取目录中的所有文件，然后在消息流经系统后退出程序？
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-
浏览 2提问于2012-11-28得票数 1
1回答
修复了任务执行器的延迟
、、、、
我的项目有一个-spring集成固定延迟轮询器(5分钟)其获得一串记录-将其发送到拆分器，拆分器将记录拆分并在输出通道将它们发送到池大小为2的任务执行器路由器通道，并且发送每个记录以便在服务激活器处进一步处理并在聚合器处接收。流程运行得很好。
然而，固定延迟是将先前的执行时间视为将记录提交给任务执行器的时间，而不是所有记录处理完成并在聚合器通道接收到的时间。
如何让轮询器在所有记录处理完成后等待5分钟，而不是在拆分器通道上等待5分钟？
配置：
使用spring集成2.2.0.RELEASE和spring 3.1.1.RELEASE版本
<integration:channel id=&#
浏览 6提问于2015-06-06得票数 1
我有一个自定义Spring源代码，我想使用：
package com.my.springproject;
import org.springframework.integration.annotation.InboundChannelAdapter;
import org.springframework.integration.annotation.Poller;
public class MySource
{
@InboundChannelAdapter(value = "output",
poller
浏览 2提问于2016-04-06得票数 2
回答已采纳
我有一个分配，在那里，我正在读取两个不同的文件夹文件使用spring集成入站通道适配器。
我的bean定义如下：
<file:inbound-channel-adapter id="channel1"
directory="file:${java.io.tmpdir}/input1">
<integration:poller id="poller" fixed-delay="60000">
</integration:poller>
</file:inbound-c
浏览 6提问于2017-02-07得票数 0
我需要从源目录中读取文件并按顺序(一个接一个)处理。
我有以下应用程序上下文配置，
<?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:int="http://www.springframework.org/schema/integrat
浏览 10提问于2017-02-21得票数 0
回答已采纳
我正在尝试使用S3StreamMessageSource轮询一个S3StreamMessageSource对象存储，如下所示(在流入通道适配器下)：
@Bean
@InboundChannelAdapter(value = "s3Channel", poller = @Poller(fixedDelay = "15000", maxMessagesPerPoll = "1"))
public MessageSource<InputStream> s3InboundStreamingMessageSource() {
S3Str
浏览 1提问于2018-01-25得票数 2
回答已采纳
日安， 我正在使用spring集成2.2来构建文件夹的侦听器。我可以知道如何检查我的监听器在中途传输文件时是否会拿起文件？或者它将等待完整的文件传输完成？ 假设有一个大小为10MB的txt文件，但由于internet速度较慢，该文件需要10秒才能传输到文件夹。比方说在第5秒，文件只做了5MB的传输，还有5MB的空间，有没有可能监听器去拿文件进行处理呢？ 下面是我的xml侦听器代码的一部分： <int-file:inbound-channel-adapter id="hostFilesIn" directory="${hostfile.dir.in}"
浏览 26提问于2019-02-11得票数 0
我有以下Spring Integration配置：
<int-file:inbound-channel-adapter
auto-startup="true"
channel="localInboundFilesChannel"
directory="${in.received}"
auto-create-directory="true">
<int:poller fixed-rate="60&
浏览 0提问于2017-08-11得票数 1
我使用Spring Batch管理项目，在该项目中，我获得了一个异步处理来自特定文件夹的文件的作业。目前，我通过批处理管理ui传递相关的作业参数来运行它。
现在，我正在尝试使用文件入站通道适配器自动执行此过程。我已经配置了服务激活器，它将在接收到文件时调用批处理作业。我现在有了一个新的需求，一旦第一个文件上传作业完成，就需要调用另一个批处理作业。为此，我创建了另一个服务激活器，它使用第一个服务激活器的输出通道。但由于批处理作业异步运行，因此将立即执行下一个批处理作业。有没有办法让第二个批处理作业等到第一个批处理作业完成。
我当前的配置是
<file:inbound-channel-ad
浏览 0提问于2013-06-19得票数 2
回答已采纳
下面我有一个发送消息和从队列中消费消息的程序，现在我已经注释掉了发送部分，只想消费队列中的消息，消息可以是字符串类型或对象消息类型，我已经为其配置了路由器。
现在有文本消息在队列中，我的下面的程序没有消耗请建议如何克服这是我的配置，因为你可以看到我已经注释掉了发送者部分，所以队列中唯一的阅读部分是活动的部分
另外，当现在写入时，我观察到消息正在被使用，但是没有生成文件，所以这意味着在我配置了有效负载路由器之后出现了一些错误
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.sprin
浏览 0提问于2016-02-27得票数 0
1回答
我有一个JMS出站网关，它通过请求队列发送消息，并通过响应队列接收消息。我想知道什么是将节流应用于响应队列中的消息接收部分的最简单方法。我尝试过将Poller设置为出站网关，但是当我设置它时，响应消息根本不会被消耗。在出站网关中可以使用Poller进行邮件消费节流吗？如果是这样的话，是怎么做的？如果没有，我如何才能最好地抑制消息响应消费呢？
我的堆栈是：
o.s.i:spring-integration-java-dsl:1.0.0.RC1
o.s.i:spring-integration-jms:4.0.4.RELEASE
我的IntegrationgConfig.class：
@Confi
浏览 2提问于2014-11-19得票数 1
回答已采纳
1回答
：远程过滤器不应用于句柄方法
、、、、
我希望从SFTP服务器读取特定的文件，并且只获得一次压缩文件。我在处理消息时遇到了一个问题，因为远程服务器上定义的过滤器似乎没有应用到handle方法中。
依赖关系：
2.2.1spring-integration: 5.2.1spring-integration-jdbc: 5.2.1spring-integration-sftp: 5.2.1 SpringBoot：
public IntegrationFlow buildSftpInboundIntegrationFlow() {
return IntegrationFlows
.f
浏览 10提问于2019-12-17得票数 2
回答已采纳
我使用了spring-integration-jdbc数据库监听器。
它将永远对数据库进行查询，配置如下
<int-jdbc:inbound-channel-adapter id="listener"
channel="target"
data-source="dataSource"
query="select * from view1 where type='ABCD' and date=:newDate"
selec-sql-paramater-source="p
浏览 0提问于2013-01-17得票数 0
1回答
当我在使用卡夫卡的信息时，我得到了例外。
org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is in failed state
我在应用程序上下文中有一个使用者，其中有一个出站适配器。
应用程序上下文中的使用者配置
<int-kafka:consumer-context
浏览 2提问于2015-01-20得票数 2
我正在使用spring整数poller从sftp服务器下载文件。
<int-sftp:inbound-channel-adapter channel="myFileDownloadChannel"
session-factory="mySftpSessionFactory"
remote-directory="#{remote}"
浏览 1提问于2013-10-03得票数 0
回答已采纳
3回答
您好，我很难解决我的xml配置问题，
下面是我的spring集成配置xml：
<context:annotation-config />
<context:component-scan base-package="hk.com.test.spring.integration" />
<int:channel id="orders" />
<int:channel id="drinks" />
<int:channel id="hotDrink"
浏览 3提问于2013-12-27得票数 12
回答已采纳
我已经为Spring Integration编写了基于Java DSL文档的代码。当我运行代码时，我一直收到以下警告，即使日志还显示消息已成功传递给两个订阅者。
2021-03-04 17:21:25.589 WARN 46929 --- [enerContainer-1] bleJmsChannel$DispatchingMessageListener : Dispatcher has no subscribers for jms-channel 'application.jmsPublishSubscribeChannel'.
org.springframework.i
浏览 48提问于2021-03-05得票数 1
回答已采纳
我有一个基于spring-integration 4.0.x的应用程序，它连接到Websphere管理器以生成/消费JMS消息。应用程序当前部署在Tomcat 7.0.x容器上，当在Windows主机上运行时，应用程序在容器关闭时按预期停止，但在RH6 Linux主机上运行时，应用程序在容器关闭时无法按预期停止。
查看基于Linux的关机期间的跟踪级别日志记录，我可以看到，当试图关闭到Websphere MQ队列的JMS连接时，应用程序会陷入困境：
15:24:30.628 [localhost-startStop-2] DEBUG org.springframework.beans.fact
浏览 2提问于2015-01-12得票数 0
回答已采纳
1回答
我们正在开发一个使用Spring集成和Rabbit MQ的POC。我们有两个模块，生产者模块和消费者模块，它们都运行在不同的JVM中。生产者模块在新文件到达时立即监听一个文件夹(输入文件夹)，创建一条消息，然后推送到(incoming.q.in)队列，也移动到process文件夹。
在生产者模块中，我们有以下代码。当我将大约100个文件放在传入文件夹中时，大约有90个文件被处理并移动到进程文件夹，但有10个文件没有移动到进程文件夹。
对于失败的案例，这些是日志文件中的消息
....
07/30/13 07:34:23:023EDT DEBUG org.springframework.
浏览 1提问于2013-07-30得票数 0
我有一个处理方法的集成流。在将文件从FTP服务器提取到本地后，此方法读取csv文件ex: foo.csv并创建一个新文件bar.csv，然后bar.csv再次被ftpd转到FTP服务器，我正在考虑一种解决方案，将foo.csv的名称更改为允许指定foo_10012019.csv并将其再次发送到FTP服务器下游的一个历史文件夹，并将其从本地删除，我如何做到这一点？我看到我们可以使用FileHeaders.ORIGINAL_FILE，但不确定如何使用它，我已经创建了一个建议，它将删除流的有效负载，但是有效负载是新生成的文件bar.csv，我可以在出站时使用相同的流发送原始文件并将其名称更改为FTP
浏览 0提问于2019-02-01得票数 0
回答已采纳
2回答
我的要求是将一个大文件(包含数百万条记录)拆分为100 K记录文件，并将它们分发到3个文件夹中。我使用Java来拆分文件，并使用spring集成来分发它们。在此过程中，将文件分发到文件夹需要很长时间。添加了下面的配置文件。弹簧集成桥的使用是正确的还是有任何优化的方法？我需要增强这段代码，以便将来将文件读写到s3桶而不是本地目录。s3入站/出站适配器是否支持同样的用途？
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/
浏览 2提问于2017-02-07得票数 0
回答已采纳
下面的代码是用spring-integration-java-dsl的1.2.1版本写回的 IntegrationFlows.from(inMessageChannel())//
.enrichHeaders(
c -> c.<InMessage>headerFunction(HEADER_IN_MESSAGE_ID,
(message) -> message.getPayload().getInMes
浏览 21提问于2019-02-06得票数 0
1回答
没有为信道适配器定义轮询器。
、、、、
我使用一个入站通道下载文件，然后使用其他出站通道上传文件&我不需要任何计票器，但不知道为什么会有这个异常。有人能帮我解决这个问题吗。我使用的是Spring4.0.6集成和spring核心4.0.6。
Logtrace：
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'sftpInboundAdapter': Invocation of init method fail
浏览 3提问于2015-08-18得票数 1
回答已采纳
在Spring引导应用程序中，在添加文件时获取以下异常:入站通道适配器中的nio-锁以获得文件锁定。
异常:‘过滤器’和‘锁’选项必须出现在提供的外部‘扫描器’上
org.springframework.beans.factory.BeanCreationException:堆栈跟踪:在设置bean属性“”时，启动application.Cannot解析对bean 'filesInChannel.adapter.source‘的解析引用时面对错误的；嵌套的异常是创建名为“FileInChannel.Adapter.source”的错误: FactoryBean在创建对象时抛出异常；嵌套
浏览 0提问于2018-08-14得票数 2
我有一个Spring Boot / Spring Integration应用程序正在运行，它在Spring Integration中使用@Poller，并在一个几乎不相关的类中的另一个方法上使用@Scheduled。@Poller用于轮询FTP服务器以获取新文件。然而，我发现似乎@Poller以某种方式干扰了我的@Scheduled方法。
@Poller有maxMessagesPerPoll = -1，所以它可以处理尽可能多的文件。但是，当我第一次启动我的应用程序时，FTP服务器上有100多个文件，所以它将处理所有这些文件。我发现，如果正在处理这些文件，那么@Scheduler将完全停止触发。
浏览 47提问于2020-03-17得票数 0
我是Spring集成的新手，所以它对专家来说可能是愚蠢的。
我想每天早上在SFTP服务器上读取一个excel文件(目前我设置为每分钟读取一次，如下所示)。我已经写了所有的代码，收到的excel的输入流和使用POI遍历它。
如果我给文件手动从JSP上传，那么没有问题，一切都很好。
但是当我使用下面的代码启用spring集成时，它会给我错误。
我发现"DefaultSftpSessionFactory“对"jsch-0.1.51.jar”有内在的依赖关系，这也是我手工绑定的一部分。
我使用的是spring 4.0.9。
仅供参考，控件在我的"processFTPFile“
浏览 200提问于2019-03-05得票数 -2
回答已采纳
1回答
我需要从所有目录中获取所有文件，并且我想在command = "mget"中使用command = "mget"(当然是带有过滤器)。
样本代码
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
x
浏览 0提问于2015-12-16得票数 1
回答已采纳
1回答
我正在尝试创建以下配置的等价物：
<int:channel id="fromdb"/>
<int:service-activator input-channel="fromdb" ref="jdbcMessageHandler" />
<int-jdbc:inbound-channel-adapter
channel="fromdb"
data-source="dataSource"
query="SELECT * FROM Items WHERE I
浏览 1提问于2018-03-10得票数 0
回答已采纳
我正在用两个PollableChannel构建Sprint的实现：
正则信道错误信道
从常规信道轮询消息并进行处理。如果在处理过程中出现错误(例如，外部服务不可用)，则将消息发送到错误通道。从错误通道重新排队到常规信道，循环一直持续到消息被成功处理为止。
这样做的目的是不频繁地轮询错误通道，给处理器一些时间(希望)恢复。
我在下面的测试中模拟了这个工作流：
package com.stackoverflow.questions.sipoller;
import java.time.Duration;
import java.time.Instant;
import java.util.Arr
浏览 3提问于2020-04-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
