调整日志打印，判断rNodes

liuxiaolong

2021-02-22 c55fbd310d9a467effdbdf0e24010fce966900bc

 message.go

@@ -4,7 +4,7 @@
   PORT_DEFAULTPROXY int = 5000
   KEY_REGISTER      int = 101 //处理TOPIC_REGISTER / TOPIC_LEAVE和TOPIC_UPDATETOPIC
   KEY_HEARTBEAT     int = 102 //处理TOPIC_HEARTBEAT
   KEY_QUERY         int = 103 //处理TOPIC_QUERYKEY和TOPIC_QUERYTOPIC
   KEY_QUERY         int = 103 //处理TOPIC_QUERYKEY和TOPIC_QUERYTOPIC和TOPIC_QUERYPROC
)

const (
@@ -16,17 +16,18 @@
   TOPIC_UPDATETOPIC        string = "Topic_UpdateTopic"
   TOPIC_QUERYKEY           string = "Topic_QueryKey"
   TOPIC_QUERYTOPIC         string = "Topic_QueryTopic"
   TOPIC_QUERYPROC          string = "Topic_QueryProc"
)

const (
   REPLY_SUCCESS int = 200
   REPLY_FAILED int = 202
)
type CommonReply struct {
   Status int    `json:"status"` // 请求状态,目前只有两个,成功返回200,失败202
   Desc   string `json:"desc"`   // 请求状态的描述,成功"success",失败返回失败原因,如心跳服务未启动
   Body   []byte `json:"body"`   // 返回值的具体内容,用户约定
}
//const (
//   REPLY_SUCCESS int = 200
//   REPLY_FAILED int = 202
//)
//type CommonReply struct {
//   Status int    `json:"status"` // 请求状态,目前只有两个,成功返回200,失败202
//   Desc   string `json:"desc"`   // 请求状态的描述,成功"success",失败返回失败原因,如心跳服务未启动
//   Body   []byte `json:"body"`   // 返回值的具体内容,用户约定
//}

const (
   NODE_ALIVE int = 0
@@ -104,4 +105,14 @@
   SvrInfo         ServerInfo           `json:"svrInfo"`        //节点基本信息
   Topic2Key       map[string]int       `json:"topic2Key"`      //topic-replyKey的对应关系
   Status          int                  `json:"status"`         //节点状态
}


//已注册的Proc进程信息
type RegisteredClient struct {
   Info           RegisterInfo       `json:"info"`
   ReplyKey       int               `json:"replyKey"`
   HeartbeatCount int               `json:"heartbeatCount"`
   DeadCount      int               `json:"deadCount"`
   Status         int               `json:"status"`
}