我一直在学习RabbitMQ的各种拓扑结构,但是我找不到有关从生产者中动态创建队列(即声明队列)的参考资料。
其想法是根据特定事件(例如HTTP请求)动态创建临时队列,并设置TTL并以事件ID命名。
然后消费者可以订阅主题“event.*”并合并与其相关的所有消息。
例如:
1.收到HTTP POST“创建用户”的请求 2.生产者创建一个名为user.ID的队列 3.将所有涉及该用户的后续消息推送到其队列中(例如“添加用户名”,“添加电子邮件”...) 4.工作程序被分配到一个随机队列“user.*”并将所有内容合并到用户帐户中 5.队列在TTL过期后会自动删除
那么,这种情况在RabbitMQ中可行吗?
例如:
1.收到HTTP POST“创建用户”的请求 2.生产者创建一个名为user.ID的队列 3.将所有涉及该用户的后续消息推送到其队列中(例如“添加用户名”,“添加电子邮件”...) 4.工作程序被分配到一个随机队列“user.*”并将所有内容合并到用户帐户中 5.队列在TTL过期后会自动删除
那么,这种情况在RabbitMQ中可行吗?