From bbabdc2a280606100637bff28c1dbf83ce7d9492 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 23 十二月 2020 10:23:49 +0800
Subject: [PATCH] 使用CommonReply解析Register返回的结果
---
hbusc.go | 19 +++++++++++++++----
1 files changed, 15 insertions(+), 4 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index dbf5498..f3532bf 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -142,13 +142,24 @@
n := regSock.Sendandrecv(regAddr, msg, &rMsg) //n浠ｈ〃鎴愬姛鍙戦�佺殑鑺傜偣鐨勪釜鏁�
handle.printLog("regSock.Sendandrecv n:", n, "len(rMsg):", len(rMsg))
if n == 1 && len(rMsg) == 1 {
- var rr RegisterReply
- if err = json.Unmarshal(rMsg[0].Data, &rr);err != nil {
+ var cr CommonReply
+ if err = json.Unmarshal(rMsg[0].Data, &cr);err != nil {
handle.printLog("unmarshal regReply err:", err)
return nil, errors.New("unmarshal regReply err:"+err.Error())
} else {
- regR = &rr
- break loop
+ if cr.Status == REPLY_SUCCESS {
+ var rr RegisterReply
+ if err = json.Unmarshal(cr.Body, &rr);err ==nil {
+ regR = &rr
+ break loop
+ } else {
+ handle.printLog("unmarshal RegisterReply err:", err)
+ }
+
+ } else {
+ handle.printLog("cr.Status:", cr.Status, "Desc:", cr.Desc)
+ }
+
}
} else {
time.Sleep(100 * time.Millisecond)
--
Gitblit v1.8.0