当前位置: 首页 > 知识库问答 >
问题:

Spring集成-路由器、任务执行器和智能LB

孟璞
2023-03-14

我有一个队列通道和一个链,轮询器和任务执行器在该通道上“监听”,并行执行一些处理。我想做的是以这样一种方式配置它,我可以根据一些逻辑/属性路由特定消息,以确保特定消息“类型”始终由任务执行器的特定线程处理。

示例:消息,其中:PAYLOAD_PROPERTY

我最初的想法是以某种方式使用通道调度员(它可以有load-balacer-reftask-执行者),但不确定这是否可以工作,因为我有一个带有轮询器的链,它做我需要进一步的处理。

您能建议什么是具有上述工作流程的最佳组件设置吗?


共有1个答案

董意蕴
2023-03-14

在“标准”任务执行器中没有这样的东西。

删除队列通道可能更容易,因为有一个路由器(订阅了直接通道)路由到10个单独的执行器通道,每个通道都配置了一个单线程执行器。

 类似资料:
  • 我正在开发一个Spring集成应用程序。 我有一个入站通道适配器,用于读取目录,然后是一个拆分器,用于将文件拆分为行,最后是一个udp出站通道适配器,用于发送行 我想每秒钟发一封信 我可以通过定义自己的拆分器并在每次读取一行时等待1s来做到这一点,但我想知道是否可以在xml文件中尽可能简单地完成它。 提前谢谢

  • 我正在开发一个现有的Spring集成代码,该代码被卡住了。 代码: 在网上做了一些搜索之后,下面是我对代码的理解。如果我错了,请纠正我: 拆分器输出通道是容量为25的队列通道,这意味着它将从查询中获取一批25条记录。 现在,service activator中编写的代码将每100毫秒轮询一次,并从队列通道中获取25条消息。Service Activator与task executor一起在多线程环

  • 我无法找到必要的信息,无论是在文档中还是在这里已经存在的问题中,这就是为什么我自己创建了一个(我还不能在类似的帖子下提问)。 我需要知道的是Spring任务执行器和调度器之间的关系。我当前的配置如下所示: 我不确定的是它是如何工作的。“谁”运行我的任务?是调度器,因为任务是和他一起安排的吗?或者调度器只是创建它们,放在队列中,由执行者运行它们? 如果没有,运行的是scheduler,我必须在特定类

  • 我想把react-route添加到我的应用程序中,我有下面的代码: 更新:已安装react-router 3.0.2并工作。

  • 我是spring Integration的新手。在spring integration的配置中,我有: 在CSVEntreprise类中,我用布尔返回定义了方法,我希望当它返回true时使用通道channel1_3TRUE,当它返回false时使用通道channel1_3FALSE?