使用LockToken我删除了特定的消息。

• 创建Azure服务总线、Azure服务总线队列并发送消息。

string itemToRemove = "HelloUser";  // Replace with the specific item you want to remove
            QueueClient queueClient = new QueueClient(connectionString, queueName);
            MessageReceiver messageReceiver = new MessageReceiver(connectionString, queueName, ReceiveMode.PeekLock);
            while (true)
            {
                Message message = await messageReceiver.ReceiveAsync();
                  if (message == null || message.Body == null || message.Body.Length == 0)
                {
                    break;
                }
              string messageContent = Encoding.UTF8.GetString(message.Body);  
          if((messageContent.Contains(itemToRemove)))
                {
                  await messageReceiver.AbandonAsync(message.SystemProperties.LockToken);
                 log.LogInformation($"Item '{itemToRemove}' not found in message with ID '{message.MessageId}'. Message abandoned and moved to the back of the queue.");
                }
            }

            await queueClient.CloseAsync();
            await messageReceiver.CloseAsync();

• 用于检查队列中的消息。

using System.Collections.Generic;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using Microsoft.Azure.ServiceBus;
using Microsoft.Azure.WebJobs.ServiceBus;
using System.Text;
using System;

public static class ServiceBusFunction
{
    [FunctionName("ServiceBusFunction")]
    public static void Run(
        [ServiceBusTrigger("your Queue", Connection = "ServiceBusConnectionString")] Message message,
        ILogger log)
    {
        log.LogInformation($"C# ServiceBus queue trigger function processed message: {Encoding.UTF8.GetString(message.Body)}");
    }

    [FunctionName("DisplayMessagesFunction")]
    public static void DisplayMessages(
        [TimerTrigger("0 */1 * * * *")] TimerInfo myTimer,
        [ServiceBus("myqueue", Connection = "ServiceBusConnectionString", EntityType = EntityType.Queue)]
        IEnumerable<Message> messages,
        ILogger log)
    {
        log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");

        if (messages != null)
        {
            foreach (var message in messages)
            {
                log.LogInformation($"Message: {Encoding.UTF8.GetString(message.Body)}");
            }
        }
        else
        {
            log.LogInformation("No messages in queue");
        }
    }
}