Spring和RabbitMQ如何声明和使用队列？

Question

我正在开发一个使用 Spring 和 RabbitMQ 的 Web 项目。这是一个基本系统，其中主节点将任务发送到从节点（使用直接交换），从节点使用简单的队列响应主节点。

新的奴隶可能随时来来去去，因此他们使用匿名队列。也可以有多个主节点，在这种情况下，每个主节点都有自己的回复队列。当 Master 向 Slave 发送任务时，该任务包含发送该任务的 Master 的回复队列名称。发送消息是使用 AmqpTemplate 完成的。

我正在使用 XML 配置所有这些，这是到目前为止我所得到的：

对于从站：

<!-- Message listener -->
<bean id="taskListener" class="tgi.docgen.amqp.TypedListener" />
  <bean id="slave" class="tgi.docgen.node.Slave" />
    <bean id="handler" class="tgi.docgen.task.TaskHandler" />

<!-- Rabbit infrastructure -->
<!-- Slave reading queue, bound to the exchange -->
<rabbit:queue id="receiveQueue" auto-delete="true" durable="false" />

<!-- Master -> Slave exchange -->
<rabbit:direct-exchange name="docgenExchange" auto-delete="true" durable="false">   
    <rabbit:bindings>
        <rabbit:binding queue="receiveQueue" />
    </rabbit:bindings>
</rabbit:direct-exchange>

<!-- taskListener bean listens to the queue -->
<rabbit:listener-container connection-factory="rabbitFactory">
    <rabbit:listener queues="receiveQueue" ref="taskListener" />
</rabbit:listener-container>

对于主站：

<!-- Message listener -->
<bean id="taskListener" class="tgi.docgen.amqp.TypedListener" />
  <bean id="master" class="tgi.docgen.node.Master">
      <property name="docgenExchange" value="???" />
      <property name="receiveQueue" value="???" />
  </bean>

<!-- Rabbit infrastructure -->
<!-- Anonymous reception queue -->
<rabbit:queue id="receiveQueue" auto-delete="true" durable="false" />

<!-- Master -> Slave exchange -->
<rabbit:direct-exchange name="docgenExchange" auto-delete="true" durable="false" />

<!-- taskListener listens to reception queue -->
<rabbit:listener-container connection-factory="rabbitFactory">
    <rabbit:listener queues="receiveQueue" ref="taskListener" />
</rabbit:listener-container>

这是我想知道的

1) 如何避免在两个 XML 配置文件中重复交换的名称？主项目依赖于从项目，因此我可以轻松地在它们之间共享配置，但我不知道如何提取交换名称并在两个文件中使用它。

2）正如我所说，Master会向exchange发送任务，并且必须在任务中写入其回复队列的名称。如何在 Master bean 中注入队列和交换的名称？也就是说：我如何将两个 ??? 分别替换为“docgenExchange”和上面配置文件中匿名回复队列的生成名称？

Answer 1

那不是 Spring Integration 2 吗？

不管怎样，几天前我已经为自己做了一个“概念验证”，做的事情正是你想要存档的。请参阅 https://github.com/knalli/task-worker

关于您的第一个问题：嗯，这取决于。这取决于你到底想要什么。我认为在两个项目（主项目和从项目）中配置中央队列的名称没有问题。当然，这不应该是硬编码的，而是一个配置选项。您可以为两个正在运行的程序提供相同的外部属性，这些属性将用作 Spring 配置上下文中的属性占位符 Bean。

第二个有点奇怪：也许你有一个旧的例子，或者这是 Spring Ingegration 1.x.. 我不知道。无论如何：您不需要提供回复名称。因为如果您使用 AMPQ Gateway Beans，Spring Integration 将自动为您处理此问题。

我引用了我的守护进程的入站 AMQP 网关配置的配置端口（这是您的“从属”）：

<int-amqp:inbound-gateway 
    connection-factory="connectionFactory" 
    request-channel="requestChannel"
    reply-channel="replyChannel" 
    error-channel="errorChannel"
    queue-names="${rabbitmq.queue}"/>

每个提到的通道 - requestChannel、replyChannel、errorChannel - 仅通过一个简单的方法在 Spring Integration Context 中注册

 <int:channel id="requestChannel"/>

对于 AMQP（即消息​​代理配置），除了 项之外，不需要更多配置部分。

此外，我将使用 Java 注释将消息连接到服务接口 (@Gateway) 和服务类 (@ServiceActivator)。这样就减少了很多配置。