如何知道消息在 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 上回答问题。
我正在使用 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 上回答问题。