fml

pool/client.go

@@ -129,7 +129,7 @@ type Conversation struct {
 // reads from this goroutine.
 func (c *Client) readPump() {
 	defer func() {
-		fmt.Println("连接己关闭或者断开，正在清理对像")
+		fmt.Println("连接己关闭或者断开，正在清理对像", c.User)
 		c.conn.Close()
 		//触发连接关闭的事件回调
 		c.onClose() //先执行完关闭回调，再请空所有的回调
@@ -174,17 +174,17 @@ Loop:
 					websocket.CloseTLSHandshake) {
 					fmt.Println("err:", err)
 					c.onError(errors.New("连接ID：" + c.Id + "ReadMessage Is Unexpected Close Error:" + err.Error()))
-					//c.closeChan<-true;
+
 					goto Loop1
 				}
 				c.onError(errors.New("连接ID：" + c.Id + "ReadMessage other error:" + err.Error()))
-				//c.closeChan<-true;
+
 				goto Loop1
 			}
 			c.conn.SetReadDeadline(time.Now().Add(pongWait))
 			c.pingPeriodTicker.Reset(pingPeriod)
 			c.lastReceiveTime = time.Now()
-			//msg, err := unMarshal(message)
+
 			msg := &SendMsg{}
 			UnserislizeJson(message, msg)
 			if err != nil {
@@ -278,12 +278,8 @@ Loop:
 				//glog.Error("连接ID："+c.Id,"wsServer发送消息失败,一般是连接channel已经被关闭：(此处服务端会断开连接，使客户端能够感知进行重连)")
 				goto Loop1
 			}
-			//message, err := marshal(d)
 			message := SerializeJson(d)
-			//if err != nil {
-			//	c.onError(errors.New("接收数据ProtoBuf编码失败！！连接ID：" + c.Id + "原因：" + err.Error()))
-			//	break Loop
-			//}
+
 			w, err := c.conn.NextWriter(websocket.TextMessage)
 			if err != nil {
 				goto Loop1

pool/publicApi.go

@@ -262,7 +262,7 @@ func Send(msg *SendMsg) error {
 			}
 			//}
 		} else {
-			fmt.Println(1)
+			fmt.Println("接收方数据有误", c)
 		}
 	}
 
@@ -278,7 +278,7 @@ func Send(msg *SendMsg) error {
 					}
 				}
 			} else {
-				fmt.Println(2)
+				fmt.Println("发送方数据有误", c)
 			}
 		}
 	}

ws_server.go

@@ -78,7 +78,7 @@ func ws(w http.ResponseWriter, r *http.Request) {
 	userInfo, err := pool.GetClientInfo(headData)
 
 	if err != nil {
-		fmt.Println("用户信息报错：", err)
+		fmt.Println("用户:", headData, "信息报错：", err)
 		return
 	}
 
@@ -91,7 +91,7 @@ func ws(w http.ResponseWriter, r *http.Request) {
 		Goroutine: 100,
 	})
 
-	fmt.Println(client.User, "实例化连接对象完成")
+	//fmt.Println(client.User, "实例化连接对象完成")
 
 	//连接成功回调
 	client.OnOpen(func() {
@@ -109,7 +109,7 @@ func ws(w http.ResponseWriter, r *http.Request) {
 			//发送消息给指定的ToClientID连接
 			err := pool.Send(msg)
 			if err != nil {
-				fmt.Println("pool.Send(msg):", err.Error())
+				fmt.Println("pool.Send(msg)err:", err.Error())
 			}
 			//发送消息给当前连接对象
 			//err = client.Send(msg)
@@ -151,16 +151,15 @@ func ws(w http.ResponseWriter, r *http.Request) {
 			fmt.Println("专家关闭连接", client.User)
 		}
 		pool.DelClient(client.User)
-
-		fmt.Printf("连接己经关闭%s", client.Id)
 	})
+
 	client.OnError(func(err error) {
-		fmt.Printf("连接%s错误信息：%s", client.Id, err.Error())
+		fmt.Println("连接错误信息：", client.Id, err.Error())
 	})
 
 	//开启连接
 	client.OpenClient(w, r, head)
-	fmt.Println(client.Id, "开启连接")
+	//fmt.Println(client.Id, "开启连接")
 
 	r.Close = true
 	return