尝试使用 Spring Integration 在运行时修改轮询率时出现问题
Spring Integration 是一个用于构建企业级集成解决方案的框架，它提供了一种简单而灵活的方式来连接和协调不同的应用程序和服务。在使用 Spring Integration 进行开发时，有时需要在运行时动态地修改轮询率，但可能会遇到一些问题。
问题可能出现在以下几个方面：
- 配置问题：首先，需要确保正确配置了 Spring Integration 的相关组件和配置文件。可以检查是否正确定义了轮询器（Poller）以及相关的轮询策略和参数。
- 代码问题：其次，需要检查代码中是否正确使用了 Spring Integration 提供的 API。可能需要使用适当的方法来动态修改轮询率，例如使用
setTrigger()方法来设置轮询触发器。 - 运行时环境问题：还有可能是由于运行时环境的限制或冲突导致的问题。可以尝试在不同的环境中运行代码，或者检查是否存在与其他组件或库的冲突。
针对这个问题，可以参考以下步骤来解决：
- 确认配置：首先，确保正确配置了 Spring Integration 的相关组件和配置文件。可以检查是否正确定义了轮询器（Poller）以及相关的轮询策略和参数。可以参考 Spring Integration 的官方文档来了解如何正确配置轮询器。
- 检查代码：其次，检查代码中是否正确使用了 Spring Integration 提供的 API。可以查看是否使用了正确的方法来动态修改轮询率，例如使用
setTrigger()方法来设置轮询触发器。可以参考 Spring Integration 的官方文档和示例代码来了解如何正确使用 API。 - 调试运行时环境：如果问题仍然存在，可以尝试在不同的运行时环境中运行代码，例如不同的操作系统或容器。这有助于确定是否存在与特定环境相关的问题。同时，还可以检查是否存在与其他组件或库的冲突，例如版本冲突或依赖关系问题。
总结起来，解决使用 Spring Integration 在运行时修改轮询率时出现问题的关键是正确配置和使用相关组件和 API，并排除可能的运行时环境问题。如果问题仍然存在，可以进一步调试和排查，或者寻求相关社区或论坛的帮助。
腾讯云提供了一系列与云计算相关的产品和服务，例如云服务器、云数据库、云存储等。这些产品可以帮助开发者构建和部署基于云计算的应用程序。具体推荐的腾讯云产品和产品介绍链接地址可以根据具体需求和场景来确定，可以参考腾讯云的官方文档和产品页面来获取更详细的信息。
相关·内容
我正在编写一个应用程序来连接到FTP服务器以将文件传输到我的本地machine.For --我使用入站通道Adapter.Once，启动应用程序，我看到所有相关文件都从FTP服务器传输到我的本地目录，直到所有文件最终同步时为止(在FTP服务器和本地服务器上的文件数量相同)。现在我想每5分钟轮询一次FTP服务器，以检查是否有新的文件出现，我最初以为是字段“固定速率”，但似乎每3秒就会轮询一次FTP server.Am，我在这里遗漏了什么吗？
我的配置文件如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<b
浏览 6提问于2016-07-14得票数 0
回答已采纳
我希望能够使用Spring Integration并行处理消息。消息来自多个设备，我们需要按顺序处理来自同一设备的消息，但这些设备可以在多个线程中处理。可能有数千个设备，所以我正在尝试尽可能多地使用Spring Integration的语义，根据设备ID的mod来分配处理器。我应该看哪种方法？
浏览 1提问于2014-11-05得票数 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
2回答
我们每个工作日都会在Spring batch中运行一个作业，该作业是从另一个系统触发的。有时会有多个作业实例在同一天运行。每一个都是从另一个系统触发的。每个作业运行大约一个小时，如果有几个作业实例要运行，我们会遇到一些数据问题。
我们希望优化此步骤如下，如果没有作业实例正在运行，则启动一个新的作业实例，如果有一个作业实例正在运行，则将新的作业实例放入队列中。每个作业实例必须在触发下一个作业实例之前完成。如果一个失败了，下一个必须等待。作业参数是一个增量器和一个时间戳。
我用谷歌搜索了一下，但找不到任何有用的东西。所以我想知道，在spring batch中排队作业实例是否有责任？如果是这样，我该
浏览 5提问于2017-10-10得票数 2
问题
对于Spring集成邮件适配器设置，我有一个非常基本的配置(下面是相关示例)：
<int:channel id="emailChannel">
<int:interceptors>
<int:wire-tap channel="logger"/>
</int:interceptors>
</int:channel>
<mail:inbound-channel-adapter id="popChannel"
store-u
浏览 1提问于2013-08-13得票数 4
回答已采纳
我一直在尝试使用Spring Integration的@Router和带有Kafka绑定的Spring Cloud Stream。我的理解是，当您从带有@Router注释的方法返回频道名称的List时，它们应该被生成到目标Kafka主题。但我没有看到正在产生的消息。 Spring Integration的@Router可以与Spring Cloud Stream一起工作吗？如果不是，有什么替代方案，我如何以编程方式路由到在运行时选择的通道？
浏览 16提问于2020-04-06得票数 0
回答已采纳
我有一个应用程序，它连接到pub/Sub并在发布订阅时处理消息。我希望能够将这些消息放入队列通道，以避免同时处理大量消息。但是，当我尝试添加队列通道时，我会得到以下错误？在我看来，一条消息到达inboundChannelAdaptor，将消息输出到队列通道，然后messageReciever在QueueChannel中提取并执行消息？
java.lang.IllegalArgumentException: No poller has been defined for Annotation-based endpoint, and no default poller is available wi
浏览 2提问于2021-09-14得票数 0
回答已采纳
我正在努力实现一个缓冲区，以便执行各种作业。我正在做一个基于Spring的项目。我决定使用Spring Integration来实现我的目标。为了理解SI是如何工作的，我经历了一个Cafèsample项目。
为了演示Spring Integration，我实现了一个表，我在其中动态插入要执行的作业。这个表就是“网关”。然后，我配置了一台路由器和各种通道。
我不完全理解的是poller元素，它必须检查“网关”中是否存在新的工作。这是正确的吗？
如果是这样，我如何配置轮询器？提前感谢！下面是xml代码：
<?xml version="1.0" encoding="UT
浏览 8提问于2013-05-16得票数 0
我有一个具有以下配置的集成测试：
@RunWith(SpringJUnit4ClassRunner.class)
@ActiveProfiles("integration-test")
@ContextConfiguration(classes = { PersistenceJpaConfig.class, ContextConfig.class, ServiceConfig.class, WebConfig.class})
@WebAppConfiguration
public class LeadsIntegrationTest {
...
}
PersistenceJ
浏览 9提问于2016-12-10得票数 0
回答已采纳
我们希望在运行时将会话工厂委托给spring sftp入站通道适配器。为此，我们进行了以下配置。
我们已经看过了spring-sftp集成文档，但是我们不确定如何通过java设置会话工厂属性值。您能建议我们如何使用委托会话工厂来委托spring sftp入站通道适配器中的会话工厂运行时吗？
XML配置
<beans>
<bean id="defaultSftpSessionFactoryOne" class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory&#
浏览 4提问于2016-01-20得票数 2
在我的项目中，我们有一个-spring集成轮询器，它每五分钟获取一堆记录-将其发送到拆分器，拆分器在输出通道使用任务解析器以多线程方式(池大小为4)拆分记录，并发送每条记录进行进一步处理。
这一切都运行得很好。然而，问题是拆分器阻塞，直到它完全处理传递的列表。
我们的要求是，如果另一个列表被传递给拆分器，那么它需要并行处理它，而不是等待第一个列表处理完成。我尝试将另一个任务执行器放到溢出器的输入通道中，但没有解决问题。
如何让拆分器工作对于两个给定的输入列表是并行的，每个输入列表依次为其各自传递的列表运行多线程。
配置：
使用spring集成2.2.0.RELEASE和spring 3.1.1
浏览 0提问于2014-01-29得票数 0
1回答
我试图使用XD源读取activeMq队列中的数据，并将其记录下来。我的要求是只在特定的时间间隔读取队列，尝试实现节流。我需要我的流每秒只处理一条消息，队列可能至少有20条消息/秒等消息。
开箱即用的JMS源实现了message-driven-channel-adapter，它可以立即从队列中读取数据。因此，我创建了一个自定义模块(polledJms)，如下所示：
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSc
浏览 3提问于2015-02-19得票数 2
我尝试用下面的代码通过application.properties和JavaConfig配置Spring兔子应用程序。当应用程序在RabbitMQ运行时工作时。我想确保在第一次AmqpConnectException之后，我要确保不再进行重试。
虽然尝试了不同的配置方式，比如用
BackOff recoveryBackOff = new FixedBackOff(5000, 1);
或者通过配置RabbitTemplate、SimpleRetryPolicy、ExceptionHandler、ConnectionListener、AmqpChannelFactoryBean等bean，我仍然没
浏览 11提问于2022-06-22得票数 0
回答已采纳
我正在使用Spring Integration开发我的第一个flow应用程序。简而言之，我的目标是从tar.gz获取文件json。我完成了，它工作得很好，但在结束时，网关发送了一个异常来结束。
上下文是这样的：
<int:poller default="true" fixed-delay="0" />
<int:gateway id="extractedFolderProcess" default-reply-channel="endFlow"
default-request-channel="
浏览 48提问于2018-09-10得票数 0
回答已采纳
1回答
在Spring Integration中是否可以在执行过程中添加路由？我在Spring Boot中做项目，我需要使用Spring Integration来使路由能够在运行时创建。我找不到合适的例子或文档来描述它是否可能以及如何实现。
浏览 0提问于2019-12-31得票数 0
我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序
“使用@InboundChannelAdapter批注的方法不能接受任何参数”
我试着这样使用它：
@InboundChannelAdapter(value = ChannelManager.OUTPUT)
public EventCreated createCustomerEvent(String customerId, String thingId) {
return new Even
浏览 0提问于2017-07-27得票数 0
当消息处理抛出异常时，我如何有效地支持JMS重新交付？
我有一个使用JMS (ActiveMQ)的流，它的connectionFactory被配置为允许n次重新传递尝试。
我希望在处理msg时发生的任何错误都会导致msg在connectionFactory配置允许的次数内被放回重新传送，然后当最大重新传送尝试用完时，传送到DLQ。像往常一样使用AMQ。
对一个相关SO问题的回答意味着我可以有一个重新抛出的errorChannel，它应该触发重新交付：
但是，由于以下原因，这种情况并没有发生：
/***
* Dispatch msgs from JMS queue to a handler u
浏览 3提问于2018-08-14得票数 0
回答已采纳
kotlin 1.2.40 spring集成5.0.4
(使用1.2.30 +4。* spring集成)
尝试创建集成流配置(几种方法)：
...
.route { m : MyClass -> m.key }
...
.route ( MyClass::class.java, { m : MyClass -> m.key })
...
//even
.route<MyClass,String>( object:java.lang.functions.Function<MyClass,String> ...)
所有这些符号都已编译，但在运行时
浏览 2提问于2018-04-27得票数 1
1回答
了解弹簧集成服务激活器
、、、
我的任务是对一个十年前开发的spring-integration项目进行一些修改，我知道它是如何工作的，所以我看了一些spring-integration教程，尽管我没有完全理解它，我对它有一些基本的了解。现在，在进行更改之前，我正在尝试了解spring-integration spring.integration.version 2.2.4.RELEASE配置的以下代码片段
<!-- Currency Pull from NetSuite -->
<int:gateway id="currencySyncGateway" service-interface=
浏览 0提问于2019-02-05得票数 0
回答已采纳
是否可以从某个xml文件加载Spring Integration应用程序上下文和流/集成？例如，存储在数据库中？ Spring Integration是否将新集成/流的运行时部署作为xml处理，而无需应用程序重启？ 或者这不是Spring集成的情况，我应该看看其他东西，比如BPMN？ 我目前唯一的想法是使用FileSystemXmlApplicationContext来加载新的集成/流。 我试图解决的问题是允许在运行时动态添加新的积分/流，而无需重新部署。
浏览 13提问于2019-10-08得票数 0
回答已采纳
我已经配置了一个MongoDB入站通道适配器。但是，入站通道适配器未按预期工作。我尝试了出站通道适配器，并成功地将一些内容写入数据库。连接似乎成功，但数据检索不成功。我没有看到任何东西也是日志。谁能指出我遗漏了什么？
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchem
浏览 1提问于2014-12-01得票数 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
回答已采纳
1回答
我正在尝试从kafka接收消息，并在java方法上处理它们。我附上了可以帮助你理解和定位问题的文件。问题是，我得到了错误: org.springframework.beans.factory.BeanCreationException:错误，创建名为'org.springframework.integration.config.ConsumerEndpointFactoryBean#0的bean，如下所示。
Web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi
浏览 1提问于2015-11-17得票数 0
回答已采纳
我看到了下面的用例。
我在输入通道上接收到一个Message<Foo>对象，其中Foo对象有两个属性
public class Foo {
...
public String getSourcePathString();
public String getTargetPathString();
...
}
sourcePathString是一个字符串，表示源文件所在的位置，而targetPathString是文件应该复制到的位置。
现在，我知道如何使用file:outbound-channel-adapter通过FileNameGenerator
浏览 1提问于2015-06-24得票数 1
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
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
回答已采纳
我正在创建一个maven多模块项目--其中一个模块仅适用于hibernate实体，问题是两个服务/ api /maven_ project都在使用相同的模块，但其中一个模块需要审计，但另一个模块不需要审计，我如何才能保持代码的完整性(意思是，不需要更改或删除@Audited注释)，如何在运行时或编译时启用或禁用envers审计，因为在我尝试过的所有操作之后，审计对这两个api都有效。
我试过了
spring.jpa.properties.hibernate.integration.envers.enabled=false
spring.jpa.properties.hibernate.list
浏览 2提问于2019-07-02得票数 2
在我的/ Spring批处理应用程序中寻找有关错误处理的建议。
上下文
我使用入站文件适配器来轮询输入目录中的文件。该文件作为参数通过JobLaunchingGateway传递给Spring批处理作业。作业使用TaskExecutor在自己的线程池上运行。
当作业完成时，文件被移动到已处理的目录，在作业执行失败时移到错误目录。
计票程序使用AcceptOnceFileListFilter，由于缓存在内存中，因此在应用程序重新启动之间不保留处理过的文件。这与我的应用程序无关，因为如果同一个文件稍后出现在输入目录中，Spring批处理会抛出异常。
问题
第一天-输入文件abc_success005
浏览 1提问于2022-08-15得票数 1
回答已采纳
我是的新手，我试图基于生成Avro消息。
我可以得到一个非常基本的例子，工作，但是当我试图进一步扩展它以使用Avro时，我会得到异常。
作为一个通用测试环境，我正在运行Docker映像：
使用Spring：生成并稍微修改了测试项目
The pom.xml:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-
浏览 3提问于2017-07-06得票数 3
2回答
我正在执行一个spring引导项目，我需要为从某个位置轮询文件添加Spring集成计票器，并在该文件上运行spring批处理来处理它。
为此，我使用了spring批处理集成(请参阅下面的文档)。
在spring引导中，我已经成功地在@配置文件中配置了我的poller，如下所示
@Bean
@InboundChannelAdapter(value = "fileInputChannel", poller = @Poller(
fixedRate = "1000"), autoStartup = "true")
public MessageSo
浏览 12提问于2016-10-07得票数 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 Integration用于JMS消息的动态选择器
我需要使用动态选择器从队列中检索消息。例如，我需要以固定的时间间隔从队列中获取大于1小时的消息。消息选择器似乎只初始化了一次。它可以在每次使用轮询器时进行更改吗？又是如何做到的？
浏览 2提问于2017-11-07得票数 0
我使用Spring将xml文件从SFTP传输到本地。我使用了Spring社区提供的代码。
主类文件
public class SFTPMain {
public static void main(String[] args) {
ConfigurableApplicationContext context =
new ClassPathXmlApplicationContext("/SftpInboundReceiveSample-context.xml", SftpInboundReceiveSample.class);
SftpInbou
浏览 3提问于2015-02-09得票数 1
回答已采纳
我想使用一个目录中的读取文件，然后移动到另一个目录，为此我使用了spring-integration。当来自另一个系统的请求时，我想执行任务(将文件移动到输出目录)。我不想重复运行文件移动器，在Spring Integration中有办法做到这一点吗？
先谢谢你，Udeshika
浏览 1提问于2013-06-12得票数 0
回答已采纳
我有一个spring集成轮询器，它轮询NAS中的目录。当在本地运行应用程序时，轮询器可以很好地提取文件。但在PCF中，它只在应用程序启动或应用程序重新启动时才会拾取文件。我已经为Spring Integration启用了调试日志记录，并且已经验证了轮询器在PCF中以预定的时间间隔运行。但它不能提取文件。网络连接存储共享由中小型企业绑定到应用程序卷Service.Any帮助。
浏览 16提问于2020-07-16得票数 0
我已经阅读了Spring上的"“指南，并一直试图确定如何在integration.xml文件中使用配置设置(替代)，而不是硬编码各种项。这主要是因为希望将XML中的一些配置具体化，并利用Spring允许外部化配置的能力。
我已经尝试了一段时间来确定解决方案，并认为这可能是一个简单的答案(对于那些知道如何)。
在下面的片段(摘自指南)中，我使用${outputDir}作为配置项的占位符，我将传递给应用程序：
<file:outbound-channel-adapter id="files"
mode="APPEND"
浏览 3提问于2014-10-28得票数 0
回答已采纳
1回答
我有一个下面的spring集成xml，我在其中发送一条消息到队列，该消息最终被消费并显示在控制台上，但是现在我想定制它，比如说那些被消费的消息最终应该被写入(换句话说，那些消息需要被记录)在一个文本文件中，该文本文件应该保存在我的文件夹的C: drive中，文件的名称是messageslog.txt
请告诉我如何在spring集成本身中添加这样的功能来获得这个功能。我已经知道在spring集成中像文件出站通道适配器这样的东西会有所帮助。
下面是我的spring集成xml
<?xml version="1.0" encoding="UTF-8"?>
&
浏览 2提问于2015-04-01得票数 0
我想轮询目录中的文件，并在找到文件后停止轮询。我对Spring框架非常陌生，其中很多仍然非常令人困惑。在做了一些研究之后，我发现了几种方法，但他们中的任何一个都没有运气。
其中一种方法是使用控制总线，如所示。然而，投票似乎在2秒后就停止了。我不知道如何包含仅在接收到文件时停止的条件。
另一种方法是使用“智能轮询”作为应答。答案中的链接是旧的，但它指向这里的官方Spring文档：。通过这篇文章，我了解了AbstractMessageSourceAdvice和SimpleActiveIdleMessageSourceAdvice。后者似乎符合我的目标，也是最简单的实现方法，所以我决定尝试一下。我的
浏览 8提问于2020-03-15得票数 1
回答已采纳
我有一个Spring Boot / Spring Integration应用程序正在运行，它在Spring Integration中使用@Poller，并在一个几乎不相关的类中的另一个方法上使用@Scheduled。@Poller用于轮询FTP服务器以获取新文件。然而，我发现似乎@Poller以某种方式干扰了我的@Scheduled方法。
@Poller有maxMessagesPerPoll = -1，所以它可以处理尽可能多的文件。但是，当我第一次启动我的应用程序时，FTP服务器上有100多个文件，所以它将处理所有这些文件。我发现，如果正在处理这些文件，那么@Scheduler将完全停止触发。
浏览 47提问于2020-03-17得票数 0
我目前的项目是基于Spring Integration的。我正在使用spring Boot开发这个项目。
我的目标是使用Spring Integration来完成下面的任务。
1.我想在spring集成中创建侦听器，以了解文件何时上传到SFTP服务器。
想弄清楚我们为什么要使用SftpInboundFileSynchronizer吗？
Logger logger = LoggerFactory.getLogger(SftpConfig.class);
@Bean
public SessionFactory<ChannelSftp.LsEntry> sftpSess
浏览 15提问于2021-03-22得票数 0
我有一个Spring Integration路由(通过DSL创建)，它轮询特定文件夹中的文件(如所示)并将其发送给Rabbit。
当我按照上面的链接配置流时，它已经在配置阶段启动了。但是，我想稍后在运行时启动它，因为我需要首先连接到Rabbit。
如何将IntegrationFlow配置为稍后按需启动/停止？
浏览 5提问于2017-06-19得票数 0
回答已采纳
我试图为数据导入构建一个简单的文件夹。但是，在处理最后一个文件时，进程会抛出NoSuchFileException。我正在使用Spring5.0.5(在这个演示中SpringBoot2.0.1)
配置
<bean id="dataImporter" class="com.example.demo.DataImporter" />
<bean id="XMLFileListFilter" class="org.springframework.integration.file.filters.SimplePatternFi
浏览 2提问于2018-05-09得票数 1
回答已采纳
用例是，我需要轮询远程服务器上的一个文件夹，如果将一个新文件复制到该文件夹，我需要调用一个带有文件内容的REST get API。REST API将使用Spring batch处理文件内容。
我正在尝试使用Spring boot集成来达到这个目的，但是在寻找方法时遇到了问题。Spring Integration最适合这个目的吗？如果是，我可以举一个简单的示例，说明Spring集成如何获取文件并调用REST API？
或者我可以简单地使用Java Watcher服务吗？
浏览 1提问于2021-05-12得票数 0
我有一些带有自定义注释的类，它们不应该被实例化(抽象类，它只是一个真正bean的子组件)。但是在这个类之上，在运行时，在上下文初始化阶段，我想把额外的bean放到应用程序上下文中。
因此，基本上我需要扫描类路径，处理结果，并在当前应用程序上下文中引入新的bean。
spring-mvc、spring-tasks和spring-integration似乎正在做这件事(我试着从源码中学习它--没有运气)。
我发现我可以创建自己的BeanFactoryPostProcessor，扫描类路径，并为我的自定义bean调用registerSingleton。但我不确定这是不是引入新bean的好方法(似乎它
浏览 0提问于2013-03-31得票数 5
回答已采纳
1回答
我有一个需求，其中一个流同步工作(请求-响应)，而在同一个应用程序中，另一组流在外部源上轮询更改信息。有没有人能告诉我如何使用spring来配置这个。我发现Spring Batch、Camel、Spring Integration可能满足我的需求，我想知道它们是否会有所帮助，或者是否有其他更简单或更好的解决方案？
谢谢。
浏览 0提问于2012-08-28得票数 0
我有一个服务激活器和一个聚合器，如下所示。一些服务执行它们的任务并将输出提供给serviceActivatorInputChannel，然后serviceActivatorInputChannel运行服务方法并将输出提供给aggregatorInputChannel。
<int:service-activator input-channel="serviceActivatorInputChannel"
output-channel="aggregatorInputChannel"
浏览 4提问于2022-04-04得票数 1
这就是我想要达到的目标。每15分钟轮询一次HTTP并处理从中检索的数据。我们计划使用。我是新来的。因此，在不太了解的情况下，我创建了一个出站网关，并为其添加了poller，但是得到了下面的错误。
另外，有人能告诉我如何使用转换器来处理出站网关的数据吗？
Error creating bean with name 'org.springframework.integration.config.ConsumerEndpointFactoryBean#0':
Invocation of init method failed; nested exception is java.lang
浏览 3提问于2016-04-27得票数 2
回答已采纳
我正在尝试配置SpCS的文件供应商来监控目录，并在创建或修改文件时发布消息。基于another SO question，我为FileInboundChannelAdapterSpec bean提供了以下自定义配置： @Bean
public BeanPostProcessor inboundFileAdaptorCustomizer() {
return new BeanPostProcessor() {
@Override
public Object postProcessBeforeInitialization(Object bean, Strin
浏览 21提问于2021-11-01得票数 3
回答已采纳
我有一个基于Spring3.0.3的EAR+WAR，我正在将它部署到WebLogic 10.3.4.0上。我希望能够通过JMX在运行时看到我的各种框架Spring Beans，最好是在WebLogic控制台中。(请注意，这些不是我们编写的bean，而是Spring默认提供的bean。)
理想情况下，我们应该能够让它与中描述的WebLogic Spring控制台扩展一起工作。但是，在执行完所有这些步骤(再加上在WL Admin UI中导航到Spring选项卡时，在WebLogic日志中看到ClassNotFoundException错误之后，将weblogic-spring.jar添加到我们的W
浏览 3提问于2011-03-25得票数 0
我当前工作的XML配置如下所示： 生产者->网关->队列通道(在Oracle DB上持久存在)带有外部会话的->接收器服务->服务(例如TCP/IP) <?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
浏览 17提问于2020-10-06得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
