gaizhengshanchudiaoxianjinchengkeydebug

zhangmeng

2020-07-30 e6b7905ee621994fad2b829d27239486147eebac

 library.go

@@ -156,7 +156,11 @@

   // sub使用一个socket
   sockSub := OpenDgramSocket()
   sockSub.Bind(int(regReply.SubTopicKey))
   // sockSub.Bind(int(regReply.SubTopicKey))
   // 订阅主题
   for _, v := range info.SubTopic {
      sockSub.Sub(v, int(regReply.SubTopicKey))
   }
   // 启动接收线程
   go recvRoutine(ctx, sockSub, chSub)
   sub := &subOReply{
@@ -198,6 +202,8 @@

// GetTopicInfo get topic info
func (h *Handle) GetTopicInfo(topic, typ string) int {
   // 据说不更新,先用缓存,否则需要新创建一个socket,来从manager请求key
   // ***k
   if v, ok := h.m[topic]; ok {
      return v.sock.Port()
   }