add PublishNetTimeout

liuxiaolong

2021-02-05 7cf6b23c83e1c4efb8567a16ab2f401be4b6d1bf

 hbusc.go

@@ -538,6 +538,14 @@
   return err
}

func (h *BHBus) PubTimeout(nodes []bhomebus.NetNode, msg *MsgInfo, timeout int) int {
   data,err := json.Marshal(*msg)
   if err == nil {
      return h.sockPub.sock.PubTimeout(nodes, msg.Topic, data, timeout)
   }
   return -1
}

//追加订阅的主题消息
func (h *BHBus) Sub(topics []string) {
   if topics != nil {