时间戳

首页 > 解决方案 > 来自 RabbitMQ 队列的 Mule ESB 多线程消费者

rabbitmq - 来自 RabbitMQ 队列的 Mule ESB 多线程消费者

问题描述

在我的 MuleESB 应用程序配置中，我有一个 RabbitMQ 队列，我想在顺序无关紧要的情况下使用多线程处理消息。

我有以下配置：

<amqp:connector name="RabbitMQMultiThread"  validateConnections="true" host="${rabbitmq_host}" port="${rabbitmq_port}" fallbackAddresses="${rabbitmq_fallback_addresses}" virtualHost="${rabbitmq_virtual_host}" username="${rabbitmq_username}" password="${rabbitmq_password}" ackMode="AMQP_AUTO" doc:name="AMQP Connector">
       <reconnect-forever frequency="30000"/>           
    </amqp:connector>

我想在我的流程中使用该 AMQP 连接器配置，如下所示：

<flow name="mule-flow">
 <amqp:inbound-endpoint connector-ref="RabbitMQMultiThread" responseTimeout="10000" exchange-pattern="request-response" doc:name="AMQP-0-9" queueName="myqueue"/>
        <logger message="got message" level="INFO" category="mycategory" doc:name="Logger"/> 
  <component doc:name="myPojo">
        <spring-object bean="myPojo"/>
    </component>             
 </flow>

是否可以使用我拥有的流配置在 Mule 中使用多线程来使用来自 RabbitMQ 的消息？

标签： rabbitmqmule-esb

解决方案

是的，Mule 会自动执行此操作。参考：https ://docs.mulesoft.com/mule-runtime/3.8/flow-processing-strategies#implicit-processing-strategies

我们必须保留消息的顺序，因此我们将流设置为同步并将 numChannels 和 prefetch 设置为 1。

<amqp:connector name="AMQP_Connector" validateConnections="true" host="${amqp.host}" port="${amqp.port}" username="${amqp.user}" password="${amqp.password}" numberOfChannels="1" prefetchCount="1" doc:name="AMQP-0-9 Connector" virtualHost="${amqp.virtualHost}">

推荐阅读