plc连接加入连接池并设置连接超时为5秒

zhangqian

2023-08-25 48ef530180aeec4f91517e2b86ef75745c28241c

 service/plc.go

@@ -27,12 +27,11 @@
   }
   ipAddr = fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port)

   conn, err := plc.NewModbusConnection(ipAddr)
   conn, err := plc.GetModbusConnection(ipAddr)
   if err != nil {
      logx.Errorf("GetProductProgress 连接plc失败: %v", err.Error())
      return
   }
   defer conn.Close()

   rawData, err := plc.ReadHoldingRegister(conn, startAddress, dataLength)
   if err != nil {
@@ -61,12 +60,11 @@
   }
   ipAddr = fmt.Sprintf("%s:%v", plcConfig.Address, plcConfig.Port)

   conn, err := plc.NewModbusConnection(ipAddr)
   conn, err := plc.GetModbusConnection(ipAddr)
   if err != nil {
      logx.Errorf("GetProductProgress 连接plc失败: %v", err.Error())
      return
   }
   defer conn.Close()

   result, err := plc.WriteHoldingRegister(conn, startAddress, value)
   if err != nil {