From 973d7543c4b7cecf09071416d4b0b6e3aaab785d Mon Sep 17 00:00:00 2001 From: boyce Date: Tue, 2 Apr 2019 15:13:23 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AF=BB=E5=86=99=E5=8A=A0=E5=85=A5=E8=B6=85?= =?UTF-8?q?=E6=97=B6=E9=99=90=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- network/websocketserver.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/network/websocketserver.go b/network/websocketserver.go index 9506db6..dfdf9e4 100644 --- a/network/websocketserver.go +++ b/network/websocketserver.go @@ -135,7 +135,7 @@ func (slf *WSClient) startSendMsg() { if ok == false { break } - + slf.conn.SetWriteDeadline(time.Now().Add(15 * time.Second)) err := slf.conn.WriteMessage(msgbuf.msgtype, msgbuf.bwritemsg) if err != nil { service.GetLogger().Printf(sysmodule.LEVER_INFO, "write client id %d is error :%v\n", slf.clientid, err) @@ -189,6 +189,7 @@ func (slf *BaseMessageReciver) startReadMsg(pclient *WSClient) { }() for { + pclient.conn.SetReadDeadline(time.Now().Add(15 * time.Second)) msgtype, message, err := pclient.conn.ReadMessage() if err != nil { slf.messageReciver.OnDisconnect(pclient.clientid, err)