0

我正在使用具有并行处理和聚合器的多播。一个多播正在调用多个端点,这些端点也是另一个多播的一部分。

当有重负载应用程序停止响应时,所有线程都进入等待状态。

这是 Camel Spring-Boot 应用程序

                from(ROUTE1)
                .multicast(new RROUTE1_Aggregator())
                .parallelProcessing()
                .executorService(Executors.newFixedThreadPool(size,new ThreadFactoryBuilder().setNameFormat(ROUE1!+"-%d").build()))
                .to(ROUTE2)
                .to(ROUTE3)
                .to(ROUTE4)
                .to(ROUTE5)
                .to(ROUTE6)             
                .end()
                .process(processResponse)
                .end();
                
                
                from(ROUTE2)
                .multicast(new RROUTE2_Aggregator())
                .parallelProcessing()
                .executorService(Executors.newFixedThreadPool(size,new ThreadFactoryBuilder().setNameFormat(ROUE2!+"-%d").build()))
                .to(ROUTE7)
                .to(ROUTE8)
                .to(ROUTE9)
                .to(ROUTE10)
                .end()
                .process(processResponse)
                .end();
4

0 回答 0