在发布时设置/获取 DeliveryTag RabbitMQ

Question

是否可以在我在发布者客户端代码中发布的消息上设置传递标签？是否可以获得我在发布者客户端中发布的消息的传递标签？

这是我的情况：

1) 我正在创建一个作业（作业 a），它会创建许多可能需要很长时间才能处理的消息。一次可以运行多个作业。

2) 我正在使用单个队列

3) 我使用的是单个接收器

4) 我希望能够“删除”作业 a 的所有消息。

如果我知道传递标签是什么，那么我可以确认每条消息以从队列中“删除”我想要的那些。

提前致谢。

Answer 1

您可以通过以下方式为每条消息设置自定义标头：

出版商：

byte[] messageBodyBytes = System.Text.Encoding.UTF8.GetBytes("Hello, world!");
IBasicProperties props = model.CreateBasicProperties();
props.ContentType = "text/plain";
props.DeliveryMode = 2;
props.Headers = new Dictionary<string, object>();
props.Headers.Add("header",  value);
model.BasicPublish(exchangeName,
               routingKey, props,
               messageBodyBytes);

参考：https://www.rabbitmq.com/dotnet-api-guide.html#publishing

在消费者处，您可以访问BasicProperties。

消费者：

public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)

        {

            header_value = // Read the value from the properites variable

            if (header_value matches) {
                // Reject or delete the message
                _channel.BasicReject(deliveryTag, false);
            }
            else {
                // Accept the message and do your processing
                _channel.BasicAck(deliveryTag, false);
            }

        }

参考：https://www.tutlane.com/tutorial/rabbitmq/csharp-read-messages-from-rabbitmq-queue

我正在使用RabbitMQ 和pika，这是一个python 客户端。我对C# 或.NET 不是很流利，但我希望这会有所帮助！