fix
This commit is contained in:
parent
865648fe74
commit
07d1a443b9
|
@ -42,9 +42,9 @@ func queueHandler(w http.ResponseWriter, r *http.Request) {
|
||||||
|
|
||||||
raddr := conn.RemoteAddr()
|
raddr := conn.RemoteAddr()
|
||||||
// laddr := conn.LocalAddr()
|
// laddr := conn.LocalAddr()
|
||||||
log.Printf("%s 建立连接 当前unity处理机器数量 %d", raddr, DequeueHandler.RefCountAdd(1))
|
log.Printf("%s 建立连接 当前unity处理机器数量 %d\n", raddr, DequeueHandler.RefCountAdd(1))
|
||||||
defer func() {
|
defer func() {
|
||||||
log.Printf("%s 退出连接 当前unity处理机器数量 %d", raddr, DequeueHandler.RefCountAdd(-1))
|
log.Printf("%s 退出连接 当前unity处理机器数量 %d\n", raddr, DequeueHandler.RefCountAdd(-1))
|
||||||
}()
|
}()
|
||||||
|
|
||||||
for {
|
for {
|
||||||
|
@ -86,7 +86,7 @@ func queueHandler(w http.ResponseWriter, r *http.Request) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// 打印消息
|
// 打印消息
|
||||||
log.Printf("source: [%s] 数据 推送到unity [%s]\n", item.Source, raddr)
|
log.Printf("source: [%s] 数据 推送到unity [%s]\n", item.Source, raddr.String())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user