问MQTTClient侦听器随机断开

EN

private static IMqttClient _client;
private static IMqttClientOptions _options;

static async Task Main(string[] args)
{
        //create subscriber client
        var factory = new MqttFactory();
        _client = factory.CreateMqttClient();
        //configure options
        _options = new MqttClientOptionsBuilder()
            .WithClientId("ListenerClient")
            .WithTcpServer(Utility.brokerIp, Utility.brokerPort).WithCredentials(Utility.brokerUser, Utility.brokerPassword)
            .WithCleanSession()
            .Build();

        //Handlers
        _client.UseConnectedHandler(e =>
        {

            Console.WriteLine("Connected successfully with MQTT Brokers Topic.");
            WriteToLog("***Connected To MQTT Listener.***");
            //Subscribe to topics******************
            
        });
        _client.UseDisconnectedHandler(e =>
        {
            WriteToLog("***DisConnected From MQTT Listener.***");
            WriteToLog(e.Exception.Message);
            _client.ConnectAsync(_options).Wait();
            return;

        });
        _client.UseApplicationMessageReceivedHandler(async e =>
        {
           //manage messages
        });

        //Connect
        _client.ConnectAsync(_options).Wait();
        Task.Run(() => Thread.Sleep(Timeout.Infinite)).Wait();
        _client.DisconnectAsync().Wait();
    }
    catch (Exception e)
    {
        Console.WriteLine(e);
        throw;
    }