如何M2MQTT自动重新连接

Question

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

我的问题是我想在订阅客户端实现重新连接功能，因为wifi信号不稳定，并且不想每次都手动重启客户端，我该怎么做到这一点？

Answer 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);
        }
    }

不完美，但会完成这项工作。

Answer 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事件，您可以订阅您的重新连接方法。