From 322a051f325daa49bc48b681c1c1cd0ee1cda36c Mon Sep 17 00:00:00 2001
From: "qiyunfanbo126.com" <815699>
Date: Wed, 22 Jan 2025 15:10:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=87=8D=E8=BF=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/http/tcppool/single.go | 23 ++++++++++++-----------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/app/http/tcppool/single.go b/app/http/tcppool/single.go
index 4c91a8b..77ffc07 100644
--- a/app/http/tcppool/single.go
+++ b/app/http/tcppool/single.go
@@ -18,6 +18,7 @@ var (
 	TcpFactory       = TcpHelper{Full: &full}
 	lockSingle sync.Once
 	OrderMap   = sync.Map{}
+	expire     = 10 * time.Second
 )
 
 type TcpHelper struct {
@@ -28,7 +29,7 @@ type TcpHelper struct {
 
 func (t *TcpHelper) Init(port string) *TcpHelper {
 	lockSingle.Do(func() {
-		var conn, err = net.DialTimeout("tcp", config.GetConf().Url+":"+port, 10*time.Second)
+		var conn, err = net.DialTimeout("tcp", config.GetConf().Url+":"+port, expire)
 		if err == nil {
 			t.client = conn
 			atomic.StoreInt32(t.Full, 0)
@@ -42,7 +43,7 @@ func (t *TcpHelper) Init(port string) *TcpHelper {
 	return t
 }
 func (t *TcpHelper) reconnect(port string) {
-	var conn, err = net.DialTimeout("tcp", config.GetConf().Url+":"+port, 5*time.Second)
+	var conn, err = net.DialTimeout("tcp", config.GetConf().Url+":"+port, expire)
 	if err == nil {
 		utils.Log(nil, "连接下游成功")
 		atomic.StoreInt32(t.Full, 0)
@@ -64,7 +65,7 @@ func (t *TcpHelper) SendMsg(msg []byte) error {
 	}
 	var start = time.Now().Unix()
 	var clinet = t.Init(config.GetConf().OrderPort).client
-	clinet.SetReadDeadline(time.Now().Add(time.Second * 5))
+	clinet.SetReadDeadline(time.Now().Add(time.Second * 10))
 	_, err := clinet.Write(msg)
 	var end = time.Now().Unix()
 	fmt.Println(end-start, "秒")
@@ -111,13 +112,13 @@ func (t *TcpHelper) Close(conn net.Conn) {
 }
 func (t *TcpHelper) watch(conn net.Conn) {
 	go func() {
-		defer func() {
-			if err := recover(); err != nil {
-				fmt.Println("连接断开", err)
-			}
-		}()
+		//defer func() {
+		//	if err := recover(); err != nil {
+		//		fmt.Println("连接断开", err)
+		//	}
+		//}()
 		for {
-			conn.SetWriteDeadline(time.Now().Add(time.Second * 5))
+			conn.SetWriteDeadline(time.Now().Add(expire))
 			_, err := conn.Write([]byte("1\n"))
 
 			if err != nil {
@@ -129,7 +130,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
 			} else {
 				var buffer = make([]byte, 1)
 				// 持续读取数据
-				t.client.SetReadDeadline(time.Now().Add(time.Second * 5))
+				t.client.SetReadDeadline(time.Now().Add(expire))
 				n, err := t.client.Read(buffer[:])
 				if err == nil && n > 0 {
 					recvStr := string(buffer[:n])
@@ -144,7 +145,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
 				} else {
 					atomic.StoreInt32(t.Full, 1)
 					utils.Log(nil, "连接关闭", err)
-					t.reconnect(config.GetConf().OrderPort)
+					//t.reconnect(config.GetConf().OrderPort)
 				}
 			}
 			time.Sleep(1 * time.Second)