1
This commit is contained in:
parent
083781737a
commit
d4b6ef5d7c
|
@ -308,8 +308,8 @@ func (w *wsConnectItem) readLoop() {
|
|||
w.close()
|
||||
return
|
||||
}
|
||||
//ping的消息不处理
|
||||
if msgType != websocket.PingMessage {
|
||||
//ping/pong/close的消息不处理
|
||||
if msgType != websocket.PingMessage && msgType != websocket.PongMessage && msgType != websocket.CloseMessage {
|
||||
select {
|
||||
case w.inChan <- data: //消息传入缓冲通道
|
||||
continue
|
||||
|
|
Loading…
Reference in New Issue
Block a user