如何知道消息在 RabbitMQ 中的位置

How to know where a message is in RabbitMQ

我正在使用 Go 编写服务并使用 RabbitMQ 进行消息传递。我需要在 header 中添加信息,该信息应包含消息流经的位置,它应该在消息 header 中添加 exchange 名称或 queue 名称以及何时它进入一个。

谁能告诉我这是怎么做到的?

每条传递的消息都有一组属性。其中两个是用于路由消息的交换器和路由键。根据交换的类型,您还可以根据此信息计算出队列名称。

https://www.rabbitmq.com/amqp-0-9-1-quickref.html

如果您需要知道消息何时发布,可以使用此插件 - https://github.com/rabbitmq/rabbitmq-message-timestamp


注意: RabbitMQ 团队监控 rabbitmq-users mailing list 并且有时只在 Whosebug 上回答问题。