azure - 如何防止在 WebJob 处理时重复消息不插入到服务总线队列中？

Question

我想确保如果队列中已存在相同的消息，则在 webjob 处理第一条消息时应忽略第二条消息(不插入到队列中)。

我尝试了以下代码:

 var namespaceManager =
                NamespaceManager.CreateFromConnectionString(connectionString);

            if (!namespaceManager.QueueExists(queueName))
            {
                namespaceManager.CreateQueue(new QueueDescription(queueName) { RequiresDuplicateDetection = true });
            }

属性RequiresDuplicateDetection应确保重复消息。

 // Get messageFactory for runtime operation
            MessagingFactory messagingFactory = MessagingFactory.CreateFromConnectionString(connectionString);

            QueueClient queueClient = messagingFactory.CreateQueueClient("TestQueue");

            BrokeredMessage message = new BrokeredMessage();
            message.MessageId = "Localization";
            queueClient.Send(message);

但是 webjob 会为每个 messageId 获取触发器。我给了 sleep 时间 150000 毫秒，但在此之前我尝试将相同的消息插入到相同的队列中，但由于重复的消息，不应插入该队列。

我试过MSDN但它在 Azure Webjob 中不起作用。

WebJob 代码:

public static void ProcessQueueMessage([ServiceBusTrigger("TestQueue")] BrokeredMessage message, TextWriter log)
        {
 log.WriteLine("Webjob Start" + message.MessageId + DateTime.Now);
            Thread.Sleep(150000);
            log.WriteLine("Webjob End" + message.MessageId + DateTime.Now);
        }

Answer 1

重复消息检测基于 BrokeredMessage 的 MessageId。 Azure 产品团队有一个示例说明此功能 here .