0

我正在使用 m2mqtt.net 的 .net 框架构建（可在此处获得：https ://github.com/mohaqeq/paho.mqtt.m2mqtt ）。在端口 8883 上连接标准 mqtt 工作正常：

_MqttClient = new MqttClient(IoTHost, IoTPort, true, certificate.CertCA, certificate.CertClient, MqttSslProtocols.TLSv1_2);

使用 ALPN 扩展在端口 443 上连接 mqtt 不起作用：

_MqttClient = new MqttClient(IoTHost, IoTPort, true, certificate.CertCA, certificate.CertClient, MqttSslProtocols.TLSv1_2, new RemoteCertificateValidationCallback(RemoteCertificateValidationCallback), new LocalCertificateSelectionCallback(SelectLocalCertificate), ALPNProtocols);

ALPNProtocols 参数根据要求设置：

List<string> ALPNProtocols = new List<string>();
ALPNProtocols.Add("x-amzn-mqtt-ca");

当我连接 ( _MqttClient.Connect(serial);) 时，m2mqtt.net 项目文件中的所有内容都运行顺利，直到它到达 MqttClient.cs 中的第 1102 行：

// wait for answer from broker
if (this.syncEndReceiving.WaitOne(timeout))

然后它等待 30 秒，然后超时并抛出异常：“抛出了 'uPLibrary.Networking.M2Mqtt.Exceptions.MqttCommunicationException' 类型的异常。”

我做了一个网络跟踪，在 TLS 握手中没有看到 ALPN 信息/协商，所以可能这就是服务器没有回复的原因。

我正在运行标准项目，没有任何修改。定义了 SSL 符号，项目设置为 .net framework 4.5。

我假设构建的 .net 框架版本支持 ALPN，因为这里没有提到任何内容：https ://libraries.io/nuget/M2MqttDotnetCore 。我似乎找不到我的 ALPN 参数的任何问题。

有人对此有任何运气吗？

4

1 回答 1

0

我认为以下取自 MqttNetworkChannel.cs 的代码片段表明，如果 M2Mqtt 在 .net 标准/.net 核心环境中运行，它只会尊重 ALPN 参数。

如果文档明确指出 .net 框架构建中不支持 ALPN，那就太好了...

#if (NETSTANDARD1_6 || NETSTANDARD2_0 || NETCOREAPP3_1)

                if ((this.alpnProtocols != null) && (0 < this.alpnProtocols.Count))
                {
                    this.sslStream = new SslStream(this.netStream, false);
                    SslClientAuthenticationOptions authOptions = new SslClientAuthenticationOptions();
                    List<SslApplicationProtocol> sslProtocolList = new List<SslApplicationProtocol>();
                    foreach (string alpnProtocol in this.alpnProtocols)
                    {
                        sslProtocolList.Add(new SslApplicationProtocol(alpnProtocol));
                    }
                    authOptions.ApplicationProtocols = sslProtocolList;
                    authOptions.EnabledSslProtocols = MqttSslUtility.ToSslPlatformEnum(this.sslProtocol);
                    authOptions.TargetHost = remoteHostName;
                    authOptions.AllowRenegotiation = false;
                    authOptions.ClientCertificates = clientCertificates;
                    authOptions.EncryptionPolicy = EncryptionPolicy.RequireEncryption;

                    this.sslStream.AuthenticateAsClientAsync(authOptions).Wait();
                }
                else
                {
                    this.sslStream.AuthenticateAsClientAsync(this.remoteHostName,
                        clientCertificates,
                        MqttSslUtility.ToSslPlatformEnum(this.sslProtocol),
                        false).Wait();
                }
#else
                this.sslStream.AuthenticateAsClient(this.remoteHostName,
                    clientCertificates,
                    MqttSslUtility.ToSslPlatformEnum(this.sslProtocol),
                    false);
#endif
于 2021-01-20T08:59:17.823 回答