From 48ef530180aeec4f91517e2b86ef75745c28241c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 25 八月 2023 18:00:31 +0800
Subject: [PATCH] plc连接加入连接池并设置连接超时为5秒

---
 service/plc.go |    6 ++----
 1 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/service/plc.go b/service/plc.go
index 1cef995..582f0f3 100644
--- a/service/plc.go
+++ b/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 {

--
Gitblit v1.8.0