通过IoTHub/Xamarin App/ESP8266进行双向通信

Question

正在开发一个新产品，该产品将使用ESP8266、Xamarin应用程序和Azure IoTHub为客户的设备启用双向通信。

我们有C2D（云2设备）和D2C（设备2云）通信在应用程序和电除尘器上正常工作，但是我们没有找到任何关于设置IoTHub来解释传入的遥测消息、处理它们各自的“到：”字段并将它们回到C2D主题，这应该允许我们的目标设备接收它。

我们的尝试：

1. 逻辑应用。能够触发进入队列的消息，但不确定要做什么HTTP请求才能将其转发回C2D事件中心。
2. 我们已经成功地将每个消息转发到队列中，但是Xamarin的PCL库无法连接到Azure服务总线队列（糟糕）。

我找到了微软一名实习生为车库开门器开发直接设备到设备通信的参考资料，但她使用的库仅适用于UWP应用程序，当我们真的想瞄准iOS时，这并不方便，Android和UWP（首先选择Xamarin的原因）。

https://blogs.windows.com/buildingapps/2016/09/08/device-to-device-communication-with-azure-iot-hub/#ykPJrVE734GpSEzV.97

是否有人能够使用Azure门户触发C2D条件事件？

Answer 1

通过与Microsoft Azure团队的一些对话，我们确定webjob与队列路由相结合是我们的最佳解决方案。

所有消息都被路由到队列，当它们到达队列时，webjob将处理该消息并使用ServiceBus消息传递对象发送该消息，以发送云到设备响应消息。

这是给任何想使用它的人的代码。

只要消息的原始发送者在代理消息中指定“To”属性，它就会被传递到注册表中的该设备。您将需要服务总线和Azure。消息传递NuGet包以使用此。此代码将复制整个消息并将整个消息发送到所需的注册表设备。

private const string queueName = "<queue_name>";
    private const string IoTHubConnectionString = "HostName=<your_host>;SharedAccessKeyName=<your_service_user>;SharedAccessKey=<your sas>";
    // This function will get triggered/executed when a new message is written 
    // on an Azure Queue called <queue_name>.
    public static void ReceiveQueueMessages(
        [ServiceBusTrigger(queueName)] BrokeredMessage message,
        TextWriter log)
    {
        if (message.To == null)
        {
            //message = null
            return;
        }
        else
        {
            //Retrieve the message body regardless of the content as a stream
            Stream stream = message.GetBody<Stream>();
            StreamReader reader;

            if (stream != null)
                reader = new StreamReader(stream);
            else
                reader = null;

            string s;
            Message serviceMessage;

            if ( reader != null )
            {
                s = reader.ReadToEnd();
                serviceMessage = new Microsoft.Azure.Devices.Message(Encoding.ASCII.GetBytes(s));
            }
            else
            {
                serviceMessage = new Microsoft.Azure.Devices.Message();
            }

            foreach (KeyValuePair<string, object> property in message.Properties)
            {
                serviceMessage.Properties.Add(property.Key, property.Value.ToString());
            }
            SendToIoTHub(message.To.ToString(), serviceMessage);
        }
    }

    static async void SendToIoTHub(string target, Microsoft.Azure.Devices.Message message)
    {
        // Write it back out to the target device

        ServiceClient serviceClient = ServiceClient.CreateFromConnectionString(IoTHubConnectionString);

        var serviceMessage = message;
        serviceMessage.Ack = DeliveryAcknowledgement.Full;
        serviceMessage.MessageId = Guid.NewGuid().ToString();

        try
        {
            await serviceClient.SendAsync(target, serviceMessage);
        }
        catch
        {
            await serviceClient.CloseAsync();
            return;
        }

        await serviceClient.CloseAsync();
    }