MQTT：C#实现断线重连

private MqttClient client;
//创建客户端并连接
private void  CreateClient(Action<object, MqttMsgPublishEventArgs> callBack)
{
    //1.创建客户端
    client = new MqttClient("xx.xx.xx.xx");
    //2.为MqttMsgPublishReceived 事件绑定方法，当订阅到消息时执行callBack委托方法
    client.MqttMsgPublishReceived += (sender, e) =>
    {
           callBack.Invoke(sender, e);
    };
    //3.建立连接
    string clientid = Guid.NewGuid().ToString();
    byte result = client.Connect(clientid, "username", "password");
    //4.为ConnectionClosed连接断开事件绑定一个回调方法
    client.ConnectionClosed += delegate
    {
         Task.Factory.StartNew(() =>
          {
               while (client== null || client.IsConnected == false)
               {
                      Thread.Sleep(5 * 1000);
                       CreateClient(callBack);
               }
            }).ConfigureAwait(false);
    };
}
//订阅,省略了判断步骤，保留核心代码
public void SubTopic(string topic, Action<object, MqttMsgPublishEventArgs> callBack)
{
      //创建客户端并连接代理
       var result = CreateClient(callBack);
      //订阅主题
       client.Subscribe(new string[] { topic }, new byte[] { 1 });
}
//模拟main方法调用SubTopic，进行订阅操作
SubTopic("topic", ReceiveProcessDataMqtt);

ClientDebug.ConnectionClosed += delegate
{
      Task.Factory.StartNew(() =>
      {
           while (client== null || client.IsConnected == false)
           {
                 Thread.Sleep(5 * 1000);
                 CreateClient(topic, callBack);
                 SubTopic(topic, callBack);
           }
         }).ConfigureAwait(false);
};