From 8324f872ef3a4d0c978a9b1d062800c6a1701c12 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 01 十二月 2023 09:58:17 +0800 Subject: [PATCH] fix --- pkg/plc/modbusx/connection_manager.go | 65 +++++++++++++++++++++++++++++--- 1 files changed, 59 insertions(+), 6 deletions(-) diff --git a/pkg/plc/modbusx/connection_manager.go b/pkg/plc/modbusx/connection_manager.go index 898968f..b8b83ad 100644 --- a/pkg/plc/modbusx/connection_manager.go +++ b/pkg/plc/modbusx/connection_manager.go @@ -1,6 +1,8 @@ package modbusx import ( + "apsClient/conf" + "apsClient/model/common" "github.com/goburrow/modbus" "sync" "time" @@ -10,6 +12,8 @@ connections map[string]modbus.Client mu sync.Mutex } + +var handler *modbus.TCPClientHandler func newPlcConnectionManager() *ConnectionManager { return &ConnectionManager{ @@ -37,19 +41,68 @@ cm.connections[address] = connection } -func (cm *ConnectionManager) CheckConnect(conn modbus.Client, timeout time.Duration) (bool, error) { - return true, nil +func (cm *ConnectionManager) RemoveConnection(address string) { + cm.mu.Lock() + defer cm.mu.Unlock() + delete(cm.connections, address) } - func getModbusConnection(ipAddr string) modbus.Client { if conn, ok := connectionManager.GetConnection(ipAddr); ok { return conn } - conn := newGetModbusConnection(ipAddr) + conn := newModbusConnection(ipAddr) connectionManager.AddConnection(ipAddr, conn) return conn } -func newGetModbusConnection(ipAddr string) modbus.Client { - return modbus.TCPClient(ipAddr) +func unsetModbusConnection(ipAddr string) { + _, ok := connectionManager.GetConnection(ipAddr) + if !ok { + return + } + connectionManager.RemoveConnection(ipAddr) + if handler != nil { + handler.Close() + } +} + +func newModbusConnection(ipAddr string) modbus.Client { + handler = modbus.NewTCPClientHandler(ipAddr) + handler.Timeout = 10 * time.Second + handler.SlaveId = byte(conf.Conf.PLC.SlaveId) + return modbus.NewClient(handler) +} + +var rtuHandler *modbus.RTUClientHandler + +func getModbusRTUConnection(c *common.RTUConfig) modbus.Client { + if conn, ok := connectionManager.GetConnection(c.SerialName); ok { + return conn + } + conn := newModbusRTUConnection(c) + connectionManager.AddConnection(c.SerialName, conn) + return conn +} + +func unsetModbusRTUConnection(serialName string) { + _, ok := connectionManager.GetConnection(serialName) + if !ok { + return + } + connectionManager.RemoveConnection(serialName) + if handler != nil { + handler.Close() + } +} + +func newModbusRTUConnection(c *common.RTUConfig) modbus.Client { + // Modbus RTU/ASCII + rtuHandler = modbus.NewRTUClientHandler(c.SerialName) + rtuHandler.BaudRate = c.BaudRate + rtuHandler.DataBits = c.DataBit + rtuHandler.Parity = c.Parity.ToString() + rtuHandler.StopBits = c.StopBit + rtuHandler.SlaveId = 1 + rtuHandler.Timeout = 5 * time.Second + return modbus.NewClient(rtuHandler) } -- Gitblit v1.8.0