多线程Spring集成DSL

Question

我想创建一个简单的IntegrationFlow与Spring集成，我有困难。

我想创建一个集成流，从Rabbit Mq中的多个队列中获取消息，并将消息发布到不同的Restendpoint。

我想知道我是否可以并行化这个。

我想检查两个场景的可行性：

• 首先，我想为每个RabbitMq队列创建一个线程，该队列在接收到消息后将侦听并执行流：

场景1

• 第二个场景：在这个场景中，我想为每个队列创建一个动态的线程数，线程数根据消息的数量增减

场景2

 HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        RestTemplate restTemplate = new RestTemplate();
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
        container.setQueueNames(BOUTIQUE_QUEUE_NAME);
        container.setAcknowledgeMode(AcknowledgeMode.AUTO);
        return IntegrationFlows.from(Amqp.inboundAdapter(container)) /* Get Message from RabbitMQ */
                .handle(msg ->
                {
                    String msgString = new String((byte[]) msg.getPayload(), StandardCharsets.UTF_8);
                    HttpEntity<String> requestBody = new HttpEntity<String>(msgString, headers);
                    restTemplate.postForObject(ENDPOINT_LOCAL_URL, requestBody, String.class);
                    System.out.println(msgString);
                   
                })
                .get();
    }

Answer 1

对于第一个场景，只需为每个配置一个入站适配器，并将输出通道设置为下游流的公共通道。

对于第二种场景，只需在侦听器容器上设置concurrentcumers和maxconcurrentcumers，它就会根据需要放大/缩小线程。

请参阅Spring AMQP文档。