Apache Camel中split上的并行处理线程

Question

我试图根据一些逻辑在路由中拆分一个传入交换。每个拆分部分都将连接到bean中的ssh服务器。

from("seda:compression")
    .routeId("Compressor")
    .split(beanExpression(new InstanceListParser(), "process"))
    .parallelProcessing()
        .to("bean:compressorClient?method=compress(${header.remoteHost},${header.dataCenter})")
    .end();

但似乎最多有10个进程并行运行。

我添加了以下代码以增加线程池工厂的大小，但这没有帮助。

ThreadPoolProfile poolProfile = new ThreadPoolProfile("masterPoolProfile");
poolProfile.setMaxPoolSize(100);
poolProfile.setMaxQueueSize(100);
poolProfile.setPoolSize(50);
poolProfile.setKeepAliveTime(1L);
poolProfile.setTimeUnit(TimeUnit.MINUTES);

ThreadPoolFactory poolFactory = new DefaultThreadPoolFactory();
poolFactory.newThreadPool(poolProfile, Executors.defaultThreadFactory());

getContext().getExecutorServiceManager().setThreadPoolFactory(poolFactory);

Answer 1

这对我很有用：

ThreadPoolProfile poolProfile = new ThreadPoolProfile("masterPoolProfile");
poolProfile.setMaxPoolSize(100);
poolProfile.setMaxQueueSize(100);
poolProfile.setPoolSize(50);
poolProfile.setKeepAliveTime(1L);
poolProfile.setTimeUnit(TimeUnit.MINUTES);
getContext().getExecutorServiceManager().setDefaultThreadPoolProfile(poolProfile)

Answer 2

您需要将拆分器配置为使用masterPoolProfile作为线程池，或者将masterPoolProfile配置为默认配置文件。后者意味着在Camel中使用该API创建的所有线程池都将使用此配置文件作为基线。

请在Camel文档中阅读更多相关信息：http://camel.apache.org/threading-model.html