向 IoTHub 发送消息失败

Question

我一直在研究一种将一些数据发送到 Azure IoT 中心的设备该设备在代码中的两个不同位置执行此操作。一方面它工作得很好，我可以通过连接字符串和传输类型 MQTT_WebSocket_Only 连接到集线器。

public static class Mqtt2IoTNew
{
    private static string _DeviceConnectionString = Properties.Settings.Default.MqttUri;

    private static TransportType _TransportType = TransportType.Mqtt_WebSocket_Only;

   public static void Send(object argEntry, bool argIsList)
    {
        var deviceClient = DeviceClient.CreateFromConnectionString(_DeviceConnectionString, _TransportType);
        deviceClient.ReceiveAsync(TimeSpan.FromSeconds(2)).Wait();

        var message = new Message(deviceClient, argEntry, argIsList);
        message.RunAsync().GetAwaiter().GetResult();
    }

}

internal class Message
{
    private DeviceClient _DeviceClient;
    private readonly string _Message;

    public Message(DeviceClient argDeviceClient, object argEntry, bool isList)
    {
        _DeviceClient = argDeviceClient;
        StringBuilder stb = new StringBuilder();
        if (isList)
        {
            foreach (var entity in (List<object>) argEntry)
            {
                stb.Append("<entity>").Append(JsonConvert.SerializeObject(entity)).Append("</entity>\n");
            }
        }
        else
        {
            stb.Append(JsonConvert.SerializeObject(argEntry));
        }
        _Message = stb.ToString();
    }

    public async Task RunAsync()
    {
        await SendEvent().ConfigureAwait(false);
    }

    private async Task SendEvent()
    {
        Microsoft.Azure.Devices.Client.Message eventMessage = new Microsoft.Azure.Devices.Client.Message(Encoding.UTF8.GetBytes(_Message));
        await _DeviceClient.SendEventAsync(eventMessage).ConfigureAwait(false);
    }
}



//Call of method that does not work
    protected override void DoOnCompleted(IRepository argRepository)
    {
        if (_CurrentlySendingTreadId.HasValue)
        {
            if (_CurrentlySendingTreadId.Value == Thread.CurrentThread.ManagedThreadId)
            {
                return;
            }
        }

        TaskFactoryProvider.GetFactory().StartNew(()=>SendBatchProtocols());
    }

    public bool SendBatchProtocols()
    {
        using (var repository = RepositoryProviderHolder.RepositoryProvider.GetRepository(Constants.CONTAINERCONTRACT_PRODUCTIONREPOSITORY))
        {
            IQueryable<BatchProtocol> batchProtocolQuery = repository.GetQuery<BatchProtocol>().OrderBy(bp => bp.InternalNoInteger);
            batchProtocolQuery = batchProtocolQuery.Where(bp => !bp.IsArchived).Take(1);

            if (!batchProtocolQuery.Any()) return false;

            var batchProtocols = batchProtocolQuery.ToList();
            IsBatchProtocolSend = false;
            try
            {
                foreach (var bps in batchProtocols)
                {
                    Mqtt2IoTNew.Send(bps,false);
                }
                IsBatchProtocolSend = true;
            }
            catch (Exception ex)
            {
                throw;
            }
        }
        return IsBatchProtocolSend;
    }

//Call of Method that does work
    private void AddEntitiesAndSaveChanges(IEnumerable argEntities)
    {
        if (argEntities == null)
        {
            return;
        }

        lock (_UnderlyingRepositoryAccessLockObject)
        {
            #region Log2DornerIoT


            if (Properties.Settings.Default.Log2DornerIoT)
            {
                List<object> entities = new List<object>();
                int i = 0;
                foreach (var entity in argEntities)
                {
                    if (i < 100)
                    {
                        entities.Add(entity);
                        i++;
                    }
                    else
                    {
                        try
                        {
                            Mqtt2IoTNew.Send(entities, true);
                        }
                        catch (Exception e)
                        {
                            throw;
                        }
                        entities.Clear();
                        i = 0;
                    }
                }
            }
        }

在代码的另一部分，我只是收集相同的 class 以使用相同的方式发送方法，但在这里我得到一个异常 "TLS authentication error" 和内部异常"Unable to connect to the remote server", "The underlying connection was closed: Could not establish trust relationship for the SSL/TLS secure channel".

但是：除了第一部分，我从未使用过任何类型的授权，但在第二部分中都无法正常工作。

如果有人能帮助我，我会很高兴。关于这个问题，我没有发现任何问题。

感谢您的宝贵时间。迈克尔

Answer 1

我找到了它不起作用的原因。应用的 Persmissice 证书策略阻止了项目一侧的证书。我禁用了它，现在它工作得很好。
无论如何感谢您的帮助。

向 IoTHub 发送消息失败

Sending message to IoTHub fails

client

azure

azure-iot-hub