代码之家 › 专栏 › 技术社区 › Mik

Net核心中的Azure服务总线-如何仅接收一条消息

azureservicebus queue .net-core azure

Mik · 技术社区 · 8 年前

Microsoft.Azure.ServiceBus 不支持这种情况。到目前为止,测试代码让我走了这么远:

public void ReceiveOne()
{
    var queueClient = new QueueClient(ServiceBusConnectionString, "go_testing");

    queueClient.RegisterMessageHandler(
        async (message, token) =>
        {
            var messageBody = Encoding.UTF8.GetString(message.Body);
            Console.WriteLine($"Received: {messageBody}, time: {DateTime.Now}");
            await queueClient.CompleteAsync(message.SystemProperties.LockToken);

            await queueClient.CloseAsync();
        },
        new MessageHandlerOptions(async args => Console.WriteLine(args.Exception))
        { MaxConcurrentCalls = 1, AutoComplete = false });
}

所以我在成功读取一条消息后关闭队列。它可以工作,但也会触发异常。

2 回复 | 直到 7 年前

hujtomi 7 年前

我找到了一个解决方案:

IMessageReceiver messageReceiver = new MessageReceiver(ServiceBusConnectionString, QueueName, ReceiveMode.PeekLock);

// Receive the message
Message message = await messageReceiver.ReceiveAsync();

// Process the message
Console.WriteLine($"Received message: SequenceNumber:{message.SystemProperties.SequenceNumber} Body:{Encoding.UTF8.GetString(message.Body)}");

// Complete the message so that it is not received again.
// This can be done only if the MessageReceiver is created in ReceiveMode.PeekLock mode (which is default).
await messageReceiver.CompleteAsync(message.SystemProperties.LockToken);
await messageReceiver.CloseAsync();

using Microsoft.Azure.ServiceBus;
using Microsoft.Azure.ServiceBus.Core;

这是原始来源: https://github.com/Azure/azure-service-bus/tree/master/samples/DotNet/GettingStarted/Microsoft.Azure.ServiceBus/SendReceiveUsingMessageSenderReceiver

David Browne - Microsoft 8 年前

RegisterMessageHandler是一个方便的API,用于接收队列中显示的所有消息。

queueClient.ReceiveAsync

看到这个样本了吗 Receive Loop 了解如何使用ReceiveAsync API接收多条消息(如果需要)。

推荐文章

realmikep · `Github Actions工作流中的git commit`失败:未授予对存储库的写入访问权限,403

1 年前

Erik Westwig · 使用反射调用程序集中的方法,该程序集中包含来自另一个程序集中基类的派生类

1 年前

Andrus · 如何从syslog中删除计算机和进程名称以及进程ID

1 年前

Escher · 如何将记录成员存储为uint,但将其呈现为DateTIme?

2 年前

Guillermo Espert · 无法在系统中实现INNotifyProperty。反思。Emit

2 年前

javad rabbani · 在ASP.NET中有一个助手类的最佳实践是什么。NET Core可以在所有视图中使用吗?[关闭]

2 年前

Vasu V · 将foreach转换为select语句

2 年前

Inglonias · 初始化集合的语法是什么?

2 年前

Alexander Zeitler · 将字典<string,string>绑定到配置节不起作用

2 年前

watkipet · 如何使用System将布尔标志选项添加到命令中。命令行?

2 年前