新库使用短连接

zhangqian

2023-09-18 23a92b7802357da7650c7362fb4dd1b029123aa5

 pkg/plc/modbusx/connection_manager.go

@@ -12,6 +12,8 @@
   mu          sync.Mutex
}

var handler *modbus.TCPClientHandler

func newPlcConnectionManager() *ConnectionManager {
   return &ConnectionManager{
      connections: make(map[string]modbus.Client),
@@ -58,10 +60,13 @@
      return
   }
   connectionManager.RemoveConnection(ipAddr)
   if handler != nil {
      handler.Close()
   }
}

func newGetModbusConnection(ipAddr string) modbus.Client {
   handler := modbus.NewTCPClientHandler(ipAddr)
   handler = modbus.NewTCPClientHandler(ipAddr)
   handler.Timeout = 10 * time.Second
   handler.SlaveId = byte(conf.Conf.PLC.SlaveId)
   return modbus.NewClient(handler)