WindowsAzure.Storage.Queue 是否与 dotnet core 3.1 兼容？答案

【问题标题】：Is WindowsAzure.Storage.Queue compatible with dotnet core 3.1?WindowsAzure.Storage.Queue 是否与 dotnet core 3.1 兼容？
【发布时间】：2021-06-25 16:02:49
【问题描述】：

我已经将一个项目从 dotnet core 2.2 迁移到 3.1，但似乎代码的某些部分没有按预期工作：任务被取消并且 GetMessageQueue() 的调用返回 null。在一个用于执行一些自动化测试的类中，我有以下方法：

public static async Task<CloudQueueMessage> WaitForMessage(this CloudQueue queue, TimeSpan interval, CancellationToken ct)
        {
            var message = await queue.GetMessageAsync();
            while (message == null)
            {
                await Task.Delay(interval, ct);
                ct.ThrowIfCancellationRequested();
                message = await queue.GetMessageAsync();
            }
        }

我是这样称呼它的：

await myObject.CallbackQueue.WaitForMessage(TimeSpan.FromSeconds(1),
                new CancellationTokenSource(TimeSpan.FromSeconds(60)).Token)

在 dotnet core 2.2 中使用了来自 Microsoft.WindowsAzure.Storage.Queue 的 CloudQueueMessage 并且该方法返回了消息，但在 3.1 中似乎没有返回消息并且任务被取消。我已将包 Microsoft.WindowsAzure.Storage.Queue 替换为 Microsoft.Azure.Storage.Queue，但仍然是同样的问题。

复制：

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Queue;
using System;
using System.Threading;
using System.Threading.Tasks;

 public async Task Test()
        {


            CloudStorageAccount storageAccount = CloudStorageAccount.Parse("UseDevelopmentStorage=true");
            CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
            CloudQueue queue = queueClient.GetQueueReference("callbackmock");

            var message = await queue.GetMessageAsync();
            var ct = new CancellationTokenSource(TimeSpan.FromSeconds(60)).Token;
            while (message == null)
            {
                await Task.Delay(TimeSpan.FromSeconds(1), ct);
                ct.ThrowIfCancellationRequested();
                message = await queue.GetMessageAsync();
            }

        }

【问题讨论】：

你能发布一个最小的复制吗？
嗨@StephenCleary，我添加了一个repro。感谢您的帮助！
嗨@singhh-msft，是的，它有帮助！谢谢！

标签： c# .net task azure-storage

【解决方案1】：

.NET Core 3.1 似乎不支持您在此处使用的 nuget。请关注Tutorial: Work with Azure Queue Storage queues in .NET 并使用如下代码读取队列消息：

static async Task<string> RetrieveNextMessageAsync(QueueClient theQueue)
{
    if (await theQueue.ExistsAsync())
    {
        QueueProperties properties = await theQueue.GetPropertiesAsync();

        if (properties.ApproximateMessagesCount > 0)
        {
            QueueMessage[] retrievedMessage = await theQueue.ReceiveMessagesAsync(1);
            string theMessage = retrievedMessage[0].MessageText;
            await theQueue.DeleteMessageAsync(retrievedMessage[0].MessageId, retrievedMessage[0].PopReceipt);
            return theMessage;
        }

        return null;
    }

    return null;
}

【讨论】：