diff --git a/dao/mq/simple.go b/dao/mq/simple.go index 0ae01fec6767332ee130572df01614d7e55bb359..6ed0059a9c09f5955fcef512b9823dc1c4322425 100755 --- a/dao/mq/simple.go +++ b/dao/mq/simple.go @@ -59,8 +59,6 @@ func NewRabbitMQSimple(queueName string) *RabbitMQ { // ) // // if err != nil { -// fmt.Println(5) -// fmt.Println(err) // return err // } // return nil @@ -68,7 +66,6 @@ func NewRabbitMQSimple(queueName string) *RabbitMQ { // 2.2 å‘逿¶ˆæ¯åˆ°é˜Ÿåˆ—ä¸ //func (r *RabbitMQ) PublishSimple(message []byte) { -// //fmt.Println("push:", string(message)) // // err := r.channel.Publish( // r.Exchange, @@ -85,8 +82,6 @@ func NewRabbitMQSimple(queueName string) *RabbitMQ { // }, // ) // if err != nil { -// fmt.Println(6) -// fmt.Println(err) // return // } // diff --git a/pool/private.go b/pool/private.go index 83cd5602e9154c916fe703683a49c37bdd8759ab..3976b223edc614cd9262d2f3d0936ba09117c08d 100755 --- a/pool/private.go +++ b/pool/private.go @@ -13,7 +13,6 @@ func dump() { return } wsSever.ErrFun(rcv_err) - //log.Error("è¿è¡Œè¿‡ç¨‹ä¸å‡ºçŽ°å¼‚å¸¸ï¼Œé”™è¯¯ä¿¡æ¯å¦‚下:",rcv_err) } func searchStrArray(arr []string, ch string) bool { @@ -29,7 +28,6 @@ func searchStrArray(arr []string, ch string) bool { func SerializeJson(data interface{}) []byte { reply, _ := json.Marshal(data) - //fmt.Println(err) return reply } diff --git a/pool/publicApi.go b/pool/publicApi.go index 732ece65a35e6fa9f3698e37945c51bd68208b25..8008fe876112f83807a19e82a6b83705a32064dd 100755 --- a/pool/publicApi.go +++ b/pool/publicApi.go @@ -245,8 +245,6 @@ func (c *Client) Close() { // å‘逿¶ˆæ¯ åªä»Žè¿žæŽ¥æ± 䏿Œ‰æŒ‡å®šçš„toClientId的连接对象å‘é€å‡ºæ¶ˆæ¯ // åœ¨æ¤æ–¹æ³•ä¸sendMsg.Channel指定的值ä¸ä¼šå¤„ç† func Send(msg *SendMsg) error { - //log.Info("å‘逿Œ‡ä»¤ï¼š",msg.Cmd,msg.ToClientId) - if msg.ToClientId == "" { return errors.New("å‘逿¶ˆæ¯çš„æ¶ˆæ¯ä½“䏿œªæŒ‡å®šToClientç›®æ ‡ï¼") } @@ -265,7 +263,6 @@ func Send(msg *SendMsg) error { //} } else { fmt.Println(1) - //fmt.Println(wsSever.hub.clients) } } @@ -354,8 +351,9 @@ func GetClientInfo(id string) (*UserInfo, error) { tokenData := strings.Split(id, "_") - fmt.Println(tokenData) + //fmt.Println(tokenData) if len(tokenData) < 4 { + fmt.Println(tokenData) return nil, errors.New("ç”¨æˆ·æ•°æ®æœ‰è¯¯") } diff --git a/ws_server.go b/ws_server.go index 8a8feb3f915196a1d6ef589a623dc4cd9ea94d92..3cbec895fa118bec054809ac7f1ca5ab4f0b1262 100755 --- a/ws_server.go +++ b/ws_server.go @@ -105,7 +105,6 @@ func ws(w http.ResponseWriter, r *http.Request) { fmt.Println("OnMessage:收到出错消æ¯=》", client.Id, msg.Desc) return } - //fmt.Println(msg.Msg) if msg.ToClientId != "" { //å‘逿¶ˆæ¯ç»™æŒ‡å®šçš„ToClientID连接 err := pool.Send(msg) @@ -115,20 +114,17 @@ func ws(w http.ResponseWriter, r *http.Request) { //å‘逿¶ˆæ¯ç»™å½“å‰è¿žæŽ¥å¯¹è±¡ //err = client.Send(msg) //if err != nil { - // fmt.Println("client.Send(msg):", err.Error()) //} } //if len(msg.Channel)>0{ // //按频é“广æ’ï¼Œå¯æŒ‡å®šå¤šä¸ªé¢‘é“[]string // err:=pool.Broadcast(msg) //或者 wsPool.Broadcast(msg) // if err!=nil { - // fmt.Println("pool.Broadcast(msg)", err.Error()) // } //} ////或都全局广æ’,所有连接都进行å‘é€ //err:=pool.BroadcastAll(msg) //if err!=nil { - // fmt.Println("pool.BroadcastAll(msg)", err.Error()) //} })