From e6b7905ee621994fad2b829d27239486147eebac Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 30 七月 2020 16:57:11 +0800
Subject: [PATCH] gaizhengshanchudiaoxianjinchengkeydebug
---
library.go | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/library.go b/library.go
index c212100..242ac00 100644
--- a/library.go
+++ b/library.go
@@ -156,7 +156,11 @@
// sub浣跨敤涓�涓猻ocket
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 {
+ // 鎹涓嶆洿鏂�,鍏堢敤缂撳瓨,鍚﹀垯闇�瑕佹柊鍒涘缓涓�涓猻ocket,鏉ヤ粠manager璇锋眰key
+ // ***k
if v, ok := h.m[topic]; ok {
return v.sock.Port()
}
--
Gitblit v1.8.0