mirror of
https://github.com/xinliangnote/go-gin-api.git
synced 2024-04-21 12:31:46 +00:00
22 lines
381 B
Go
22 lines
381 B
Go
package socket
|
|
|
|
import "go.uber.org/zap"
|
|
|
|
func (s *server) OnMessage() {
|
|
defer func() {
|
|
s.OnClose()
|
|
}()
|
|
|
|
for {
|
|
//接收消息
|
|
_, message, err := s.socket.ReadMessage()
|
|
if err != nil {
|
|
s.logger.Error("socket on message error", zap.Error(err))
|
|
break
|
|
}
|
|
|
|
// 为了便于演示，仅输出到日志文件
|
|
s.logger.Info("receive message: " + string(message))
|
|
}
|
|
}
|