从 Azure Servicebus / IotHub 接收消息

Question

我想经常检查 azure servicebus/iothub 是否有消息。但是，当我这样做时，会出现以下错误

"在 mscorlib.dll 中发生了 'Amqp.AmqpException' 类型的异常，但未在用户代码中处理 附加信息：“接收”操作在状态下无效：结束。”

任何想法我应该如何实现消息的持续拉取和/或解决此错误？

var connection = new Connection(address);
var session = new Session(connection);
var entity = Fx.Format("/devices/{0}/messages/deviceBound", _deviceId);

var receiveLink = new ReceiverLink(session, "receive-link", entity);
while (true)
{
    await Task.Delay(1000);

    var message = await receiveLink.ReceiveAsync();
    if (message == null) continue;
    //else do things with message
 }

Answer 1

从您使用的端点看来，您正在谈论接收云到设备 (c2d) 消息，换句话说，您编写的代码在设备上运行，旨在接收消息通过服务发送到此设备，对吗？

最简单的方法是使用C# SDK 的DeviceClient 类。 DeviceClientAmqpSample 项目中提供了如何使用此类的示例。

使用设备连接字符串创建DeviceClient 实例后，DeviceClient 类具有可用于接收消息的ReceiveAsync 方法。

var deviceClient = DeviceClient.CreateFromConnectionString("<DeviceConnectionString>");
while(true)
{
    await Task.Delay(1000);
    var receivedMessage = await deviceClient.ReceiveAsync(TimeSpan.FromSeconds(1));
    if (receivedMessage != null)
    {
        var messageData = Encoding.ASCII.GetString(receivedMessage.GetBytes());
        Console.WriteLine("\t{0}> Received message: {1}", DateTime.Now.ToLocalTime(), messageData);
        await deviceClient.CompleteAsync(receivedMessage);
    }
}