From 6b142b1fde1968768d04980cbc275045b3ef22ae Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 7 Feb 2020 15:25:39 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E7=AB=AF=E5=8F=A3=E9=85=8D?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Test/config/nodeconfig.json | 4 ++-- network/tcpsocketserver.go | 6 ++++++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/Test/config/nodeconfig.json b/Test/config/nodeconfig.json index 2e30e10..e745f6d 100644 --- a/Test/config/nodeconfig.json +++ b/Test/config/nodeconfig.json @@ -2,8 +2,8 @@ "Public":{ "LogLevel":1, "HttpPort":9400, - "WSPort":9500, - + "WSPort":9401, + "ListenPort":9402, "CAFile":[ { "CertFile":"", diff --git a/network/tcpsocketserver.go b/network/tcpsocketserver.go index 67c2ae1..ba92981 100644 --- a/network/tcpsocketserver.go +++ b/network/tcpsocketserver.go @@ -42,6 +42,7 @@ type TcpSocketServer struct { MaxRecvPackSize uint16 MaxSendPackSize uint16 iReciver ITcpSocketServerReciver + nodelay bool } type MsgBasePack struct { @@ -74,6 +75,8 @@ func (slf *TcpSocketServer) Start(){ } func (slf *TcpSocketServer) listenServer(){ + slf.nodelay = true + listener, err := net.Listen("tcp", slf.listenAddr) if err != nil { service.GetLogger().Printf(service.LEVER_FATAL, "TcpSocketServer Listen error %+v",err) @@ -88,6 +91,9 @@ func (slf *TcpSocketServer) listenServer(){ continue } + if slf.nodelay { + //conn.(ifaceSetNoDelay) + } for { clientId += 1 if slf.mapClient.Get(clientId)!= nil {