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 {