问题描述

我已经将一个项目从DotNet core 2.2迁移到3.1，但是代码的某些部分似乎没有按预期工作：Task被取消，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核心2.2中，CloudQueueMessage来自Microsoft.WindowsAzure.Storage.Queue，该方法返回消息，但在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();
            }

        }

推荐答案

您在这里使用的Nuget似乎在.NET Core3.1中不受支持。请遵循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;
}

这篇关于WindowsAzure.Storage.Queue是否与DotNet Core 3.1兼容？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！