C# 网口通信（modbus），自动重连

1.创建接收线程。

   Com2Ups60Thread = new Thread(Com2Ups60);
   Com2Ups60Thread.IsBackground = true;
   Com2Ups60Thread.Start();

2.线程函数。

        private void Com2Ups60()
        {
            try
            {
                Logger.Info("Com2Ups60() Start");

                ModbusFactory modbusFactory = new ModbusFactory();
                NModbus.IModbusMaster master = modbusFactory.CreateMaster(new TcpClient(_nameValueCollection["UPSYiDun_IP"], int.Parse(_nameValueCollection["UPSYiDun_Port"])));
                master.Transport.ReadTimeout = 1000;
                master.Transport.Retries = 1000;

                //参数(分别为站号,起始地址,长度)
                byte slaveAddress = 1;
                ushort startAddress = 200;
                ushort numberOfPoints = 125; // 这个长度不能超过125

                isups60Connect = true;
                while (true)
                {
                    ushort[] registerBuffer = master.ReadInputRegisters(slaveAddress, startAddress, numberOfPoints);
                    for (int i = 0; i < registerBuffer.Length; i++)
                    {
                        isups60Connect = true;

                        //Logger.Info("receive Data：" + registerBuffer[i]);

                        Application.Current.Dispatcher.Invoke(() =>
                        {
                            srA = registerBuffer[77].ToString();
                            srB = registerBuffer[78].ToString();
                            srC = registerBuffer[79].ToString();

                            scA = registerBuffer[95].ToString();
                            scB = registerBuffer[96].ToString();
                            scC = registerBuffer[97].ToString();
                        });
                    }
                    Thread.Sleep(5000);
                }
            }
            catch (Exception ex)
            {
                isups60Connect = false;
                Logger.Error("MainWinViewModel()->Com2Ups60()->" , ex);
            }
        }

3.定时器实时判断。

if (isups60Connect == false)
 {
                        Com2Ups60Thread.Abort();
                        Com2Ups60Thread = new Thread(Com2Ups60);
                        Com2Ups60Thread.IsBackground = true;
                        Com2Ups60Thread.Start();
 }