|
@@ -114,7 +114,7 @@ func (c *WebSocketConn) readLoop() {
|
|
|
}
|
|
}
|
|
|
message := string(msg)
|
|
message := string(msg)
|
|
|
// 处理消息
|
|
// 处理消息
|
|
|
- utils.FileLog.Info("收到客户端 %s 消息: %s", c.id, message)
|
|
|
|
|
|
|
+ //utils.FileLog.Info("收到客户端 %s 消息: %s", c.id, message)
|
|
|
|
|
|
|
|
// 启动一个新的协程处理消息，避免阻塞读取循环
|
|
// 启动一个新的协程处理消息，避免阻塞读取循环
|
|
|
go c.handleMessage(message)
|
|
go c.handleMessage(message)
|
|
@@ -126,7 +126,7 @@ func (c *WebSocketConn) readLoop() {
|
|
|
func (c *WebSocketConn) handleMessage(message string) {
|
|
func (c *WebSocketConn) handleMessage(message string) {
|
|
|
defer utils.FileLog.Info("处理来自客户端 %s 的消息: %s, 结束", c.id, message)
|
|
defer utils.FileLog.Info("处理来自客户端 %s 的消息: %s, 结束", c.id, message)
|
|
|
// 模拟消息处理
|
|
// 模拟消息处理
|
|
|
- utils.FileLog.Info("处理来自客户端 %s 的消息: %s", c.id, message)
|
|
|
|
|
|
|
+ //utils.FileLog.Info("处理来自客户端 %s 的消息: %s", c.id, message)
|
|
|
|
|
|
|
|
// 如果是PING消息，回复PONG
|
|
// 如果是PING消息，回复PONG
|
|
|
if message == "ping\n" {
|
|
if message == "ping\n" {
|
