hbusc.go

@@ -199,6 +199,7 @@

    //维持心跳的socket
    sockHB := bhomebus.OpenSocket()
    handle.printLog("open sockHB")
    handle.sockHB = &sockClient{
        sock: sockHB,
        peer: int(regR.HeartbeatKey),
@@ -209,6 +210,7 @@
    if ri.PubTopic != nil && len(ri.PubTopic) > 0 {
        sockReply := bhomebus.OpenSocket()
        sockReply.ForceBind(int(regR.ReplyKey))
        handle.printLog("after pubTopic forceBind")
        handle.wg.Add(1)
        //serve server reply
        go recvRoutine(ctx, sockReply, handle.wg, handle.chReply, handle.printLog)
@@ -231,6 +233,7 @@
        //订阅消息的socket
        sockSub := bhomebus.OpenSocket()
        //订阅所有主题
        handle.printLog("start Sub topics")
        for _,v := range ri.SubTopic {
            subN := sockSub.Sub(v)
            handle.printLog("subTopic:", v, " ret n:", subN)