如果没有pubTopics或者subTopic，则不启动server接收

liuxiaolong

2021-01-08 986c949195d1f50758602f198cae76d56c3b8d56

 hbusc.go

@@ -192,8 +192,16 @@
      }
   }

   //维持心跳的socket
   sockHB := bhomebus.OpenSocket()
   handle.sockHB = &sockClient{
      sock: sockHB,
      peer: int(regR.HeartbeatKey),
   }

   handle.wg = &sync.WaitGroup{}

   if ri.PubTopic != nil && len(ri.PubTopic) > 0 {
   sockReply := bhomebus.OpenSocket()
   sockReply.ForceBind(int(regR.ReplyKey))
   handle.wg.Add(1)
@@ -203,13 +211,8 @@
      sock: sockReply,
      info: &ri.Proc,
   }

   //维持心跳的socket
   sockHB := bhomebus.OpenSocket()
   handle.sockHB = &sockClient{
      sock: sockHB,
      peer: int(regR.HeartbeatKey),
   }


   //发布消息的socket, pub是将消息发布到bus中，所以不需要指定key
   sockPub := bhomebus.OpenSocket()
@@ -218,6 +221,8 @@
      peer: -1,
   }

   //有订阅消息才需要启动协程接收消息
   if ri.SubTopic != nil && len(ri.SubTopic) > 0 {
   //订阅消息的socket
   sockSub := bhomebus.OpenSocket()
   //订阅所有主题
@@ -232,6 +237,7 @@
      sock: sockSub,
      peer: -1,
   }
   }

   sockWorker := bhomebus.OpenSocket()
   handle.sockWorker = &sockClient{