5

我是 RabbitMQ 的新手，我刚刚浏览了 Rabbitmq 文档（路由）。我对带有路由键的 Exchange 感到很困惑。我的要求是，我想动态创建多个队列。请参考下图。

Producer 将作业发送到 Exchange 并将其转发到相应的 Queue

前任。假设如果生产者为消费者 c3 创建消息，那么它应该去 Exchange 并仅路由到队列 3 并仅由 C3 消费。目前我只需要 3 个队列，将来这个数量可能会增加。那么如何处理这种情况呢。

注意：我参考这个博客交流

我使用了 Spring hibernate 和 Rabbitmq。下面的代码显示了 Rabbit MQ 侦听器配置文件。

<?xml version="1.0" encoding="UTF-8" ?>
<beans xmlns="http://www.springframework.org/schema/beans" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/rabbit  
http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">

<rabbit:connection-factory id="connectionFactory" host="xx.xx.10.181" username="admin" password="admin" />
<rabbit:admin connection-factory="connectionFactory" />

<!--  Create Queues -->
<rabbit:queue id="q1" name="q1.queue" durable="true" />
<rabbit:queue id="q2" name="q2.queue" durable="true"  />
<rabbit:queue id="q3" name="q3.queue" durable="true"  />

<!--create Exchange here -->
<rabbit:direct-exchange id="myExchange" name="MY Exchange">
    <rabbit:bindings>
         <rabbit:binding queue="q1" key="my.queue.q1" />
         <rabbit:binding queue="q2" key="my.queue.q2" />
         <rabbit:binding queue="q3" key="my.queue.q3" />
    </rabbit:bindings>
</rabbit:direct-exchange>

<!-- instantiate Listeners -->
<bean id="q1Listener" class="in.my.brocker.amqp.Q1Listener" />
<bean id="q2Listener" class="in.my.brocker.amqp.Q2Listener" />
<bean id="q3Listener" class="in.my.brocker.amqp.Q3Listener" />

<!-- glue the listener and myAnonymousQueue to the container-->
<rabbit:listener-container id="myListenerContainer" connection-factory="connectionFactory">
    <rabbit:listener ref="q1Listener" queues="q1" />
    <rabbit:listener ref="q2Listener" queues="q2" />
    <rabbit:listener ref="q3Listener" queues="q3" />
 </rabbit:listener-container>
</beans>

在上面的 rabbit-listener-context.xml 中，我创建了 3 个队列和 3 个监听器类。我的目标是队列应该通过定义的路由键进行访问。我想动态创建第n个队列吗？我们怎样才能做到这一点？

4

0 回答 0