Конфигурирование нескольких очередей с обменом темами и использование ключа маршрутизации для направления определенной очереди сообщений с весенними облачными потоками

Question

Настройка нескольких очередей с обменом темами и использование ключа маршрутизации для направления определенной очереди сообщений в потоки весенних облаков

Мое требование - пример. У меня есть очереди и обмен, определенные ниже в потребительской части

spring.cloud.stream.bindings.inputA.destination=Common-Exchange
spring.cloud.stream.bindings.inputA.group=A-Queue

spring.cloud.stream.bindings.inputB.destination=Common-Exchange
spring.cloud.stream.bindings.inputB.group=B-Queue

• Я должен быть в состоянии указать ключ маршрутизации в потребителе, как мы делаем это в AMQP, где мы можем передать очередь обмена и ключ маршрутизации создать привязку

• Я должен иметь возможность установить ключ маршрутизации при отправке сообщения в конец производителя с использованием MessageBuilder

  channel.send (MessageBuilder.withPayload (сообщение) .build ())

Конечно, мы можем использовать одну очередь и заголовки для направления сообщений различного типа, но мне нужно знать, как несколько очередей, подключенных к одному обмену, работают с потоками.

Answer 1

См. Документацию Связующее для кроликов .

• . На стороне потребителя установите свойство привязки потребителя bindingRoutingKey.
• На стороне производителяroutingKeyExpression свойство привязки производителя (например, headers['routingKey'] и установить этот заголовок по необходимости).

Также см. Использование существующих очередей / обменов .