如何 M2MQTT 自动重新连接答案

【问题标题】：How to M2MQTT Auto Reconnect如何 M2MQTT 自动重新连接
【发布时间】：2017-09-18 17:17:01
【问题描述】：

我正在尝试使用此协议，并且已经有 2 个客户端（一个要发布，另一个要订阅）和一个正在工作的代理。

我的问题是我想在订阅客户端中实现重新连接功能，因为 wifi 信号不稳定并且不想每次都手动重启客户端，我该如何实现呢？

【问题讨论】：

【解决方案1】：

您可以使用 ConnectionClosed 事件来检测何时发生断开连接。

然后我启动一个尝试重新连接客户端的任务。比如：

 private async Task TryReconnectAsync(CancellationToken cancellationToken)
    {
        var connected = _client.IsConnected;
        while (!connected && !cancellationToken.IsCancellationRequested)
        {
            try
            {
                _client.Connect(_clientId);
            }
            catch
            {
                _logger.Log(LogLevel.Warn, "No connection to...{0}",_serverIp);
            }
            connected = _client.IsConnected;
            await Task.Delay(10000, cancellationToken);
        }
    }

不完美，但可以胜任。

【讨论】：

在 ConnectionClosed 事件中我有这个，CancellationTokenSource source = new CancellationTokenSource();任务 T = Task.Run(() => TryReconnectAsync(source.Token)); T.等待（）；我不知道这是否正确，重新连接后 sub 停止接收来自 pub 的消息...
重新连接后尝试再次订阅主题。

【解决方案2】：

对于那些寻求简单连接持久性的人来说，这是我使用的解决方案。

当您想启动 mqtt 连接时，调用 Task.Run(() => PersistConnectionAsync()); 并注意 static bool _tryReconnectMQTT 应在类（或所需）范围级别定义。

private async Task PersistConnectionAsync()
{
    var connected = _mqttClient.IsConnected;
    while (_tryReconnectMQTT)
    {
        if (!connected)
        {
            try
            {
                _mqttClient.Connect(_clientId);
            }
            catch
            {
                Debug.WriteLine("failed reconnect");
            }
        }
        await Task.Delay(1000);
        connected = _mqttClient.IsConnected;
    }
}

我还建议使用最后的遗嘱和遗嘱来了解您的客户停工了多长时间以及何时停工。将_mqttClient.Connect(_clientId); 替换为以下内容。

_mqttClient.Connect(_clientId, 
            null, null,
            false,
            MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE, //aws 
            true,
            $"/my/topic/{_clientId}connectionstatus",
            "{\"message\":\"disconnected\"}",
            true,
            60);

在连接语句之后将连接消息发布到具有相似消息的同一主题，以确保您知道所有断开连接的时间。使用 AWS 规则引擎，您将能够发送有关连接状态的通知，甚至可以在重新连接之间的持续时间超过一定时间时通知自己。

m2mqtt 客户端有一个.ConnectionClosed 事件，您可以订阅您的重新连接方法。

【讨论】：