Azure 服务总线和 Xamarin.Android MessageHandler

问题描述

我正在尝试在 Xamarin.Android 移动应用程序上使用 Microsoft.Azure.ServiceBus。我想将设备订阅到特定队列，并让它持续监视该队列以获取任何消息。

我找到了一篇文章来向队列发送消息，但我最难找到订阅队列的方法。使用以下代码似乎不起作用。

QueueClient queueClient = new QueueClient(connectionString,requestQueueName);

        var messageHandlerOptions = new MessageHandlerOptions(ExceptionReceivedHandler)
        {
            MaxConcurrentCalls = 1,AutoComplete = false
        };

        queueClient.RegisterMessageHandler(ProcessMessageAsync,messageHandlerOptions);

有没有其他人遇到过类似的问题？

感谢 Jlimited

解决方法

您可能想尝试将 TransportType 设置为 AmqpWebSockets。使用默认 TCP 传输时，Android 有时会出现问题。由于您没有注册错误处理程序，因此您不会观察到任何连接失败的异常。

将其集成到当前代码段的最简单方法是使用 ServiceBusConnectionStringBuilder：

var builder = new ServiceBusConnectionStringBuilder(connectionString);
builder.TransportType = TransportType.AmqpWebSockets;

var queueClient = new QueueClient(builder.ToString(),requestQueueName);

如果这是新开发的，并且没有对旧服务总线库的现有投资，您可能需要考虑使用当前一代，Azure.Messaging.ServiceBus。它的 ServiceBusProcessor 提供您正在使用的基于推送的模型，支持指定消息处理选项并注册错误处理程序，而旧客户端则没有。

azureservicebus xamarin.android