rabbitmq-bundle - symfony3 - 如何配置主题交换和队列?
rabbitmq-bundle - symfony3 - how to configure a topic exchange and queues?
我找不到适合旧声音 rabbitmq 包的好配置来处理主题和通配符。
我想要的只是一个使用通配符 post 到多个队列的独特交换。
例如,我有我的交易所名称 user.update,我想 post 在 user.update.address,user.update.profile 上发送相同的消息微服务策略。
你知道如何在配置文件中配置吗?
感谢阅读。
正因为你在寻找
... great configuration for old sound rabbitmq bundle ...
访问 http://www.inanzzz.com/ 并搜索 "rabbitmq",这将为您提供所需的信息。
为了解决你的问题,你可以使用下面的配置(我没有测试过,但应该没问题)。但是,您仍然需要编写整个 functionality/classes/consumers/producers 等,因此请遵循以下示例:RabbitMQ topic example with symfony including 1 Producer & 1 Exchange & 2 Queue & N Worker & 2 Consumer
old_sound_rabbit_mq:
connections:
default:
host: %rabbitmq.host%
port: %rabbitmq.port%
user: %rabbitmq.user%
password: %rabbitmq.pswd%
vhost: /
lazy: true
producers:
user_update_producer:
connection: default
exchange_options: { name: user.update, type: topic }
consumers:
user_update_consumer:
connection: default
exchange_options: { name: user.update, type: topic }
queue_options:
name: user_update_queue
routing_keys:
- 'user.update.address'
- 'user.update.profile'
callback: your_application.consumer.user_update_consumer
流程:user.update (P)
-> user.update (E)
-> [user.update.address & user.update.profile]
-> user_update_queue (Q)
我找不到适合旧声音 rabbitmq 包的好配置来处理主题和通配符。
我想要的只是一个使用通配符 post 到多个队列的独特交换。
例如,我有我的交易所名称 user.update,我想 post 在 user.update.address,user.update.profile 上发送相同的消息微服务策略。
你知道如何在配置文件中配置吗?
感谢阅读。
正因为你在寻找
... great configuration for old sound rabbitmq bundle ...
访问 http://www.inanzzz.com/ 并搜索 "rabbitmq",这将为您提供所需的信息。
为了解决你的问题,你可以使用下面的配置(我没有测试过,但应该没问题)。但是,您仍然需要编写整个 functionality/classes/consumers/producers 等,因此请遵循以下示例:RabbitMQ topic example with symfony including 1 Producer & 1 Exchange & 2 Queue & N Worker & 2 Consumer
old_sound_rabbit_mq:
connections:
default:
host: %rabbitmq.host%
port: %rabbitmq.port%
user: %rabbitmq.user%
password: %rabbitmq.pswd%
vhost: /
lazy: true
producers:
user_update_producer:
connection: default
exchange_options: { name: user.update, type: topic }
consumers:
user_update_consumer:
connection: default
exchange_options: { name: user.update, type: topic }
queue_options:
name: user_update_queue
routing_keys:
- 'user.update.address'
- 'user.update.profile'
callback: your_application.consumer.user_update_consumer
流程:user.update (P)
-> user.update (E)
-> [user.update.address & user.update.profile]
-> user_update_queue (Q)