上传socket 读取超时设置

This commit is contained in:
liwei1dao 2022-08-18 10:32:47 +08:00
parent 911c17bcf7
commit 58e8c9002d

View File

@ -36,6 +36,7 @@ func newAgent(gateway IGateway, conn *websocket.Conn) *Agent {
closeSignal: make(chan bool), closeSignal: make(chan bool),
state: 1, state: 1,
} }
conn.SetReadDeadline(time.Now().Add(time.Minute)) //一分钟内不登录 自动断开连接
agent.wg.Add(2) agent.wg.Add(2)
go agent.readLoop() go agent.readLoop()
go agent.writeLoop() go agent.writeLoop()