nsqlookupd中tcpServer命令怎么用

這篇文章主要介紹nsqlookupd中tcpServer命令怎么用，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

一、tcpServer

1、case "PING”:     健康檢查

更新 client.peerInfo.lastUpdate 為 time.Now().UnixNano()

回復 “OK”

2、case "IDENTIFY”:     身份認證，client 注冊（ip，port等）

此命令，每個 client 只發送一次。

server 繼續從 conn 讀取1個 int32，這個數字表明 body 長度

err = binary.Read(reader, binary.BigEndian, &bodyLen)

繼續從 conn 讀取上面獲取長度的字節流，原始報文是 json 格式

peerInfo := PeerInfo{id: client.RemoteAddr().String()}

err = json.Unmarshal(body, &peerInfo)

解碼成 PeerInfo；同時 驗證字段是否完整，設置 lateUpdate

下一步就是要把 producer 的信息保存起來，這塊涉及一個非常重要的 struct，在 NSQLookupd 對其有一個指針。

type NSQLookupd struct {

     // ............

     DB           *RegistrationDB

}

type RegistrationDB struct {

     sync.RWMutex     // 鎖用來協調多個協程的訪問

     registrationMap map[Registration]Producers     // producer slice

}

// 下面這句是非常重要的注冊 添加生產者，注意到 Registration 只有第一個字段有值

// 添加時會做判斷，根據 peerInfo.Id，也就是 client 的 ip 地址

p.context.nsqlookupd.DB.AddProducer(Registration{"client", "", ""}, &Producer{peerInfo: client.peerInfo})

注意其中鎖的使用，sync.RWMutex 默認初始值就可以直接使用

r.Lock()

defer r.Unlock()     // 方法結束時，確保釋放鎖

最后一步把 nsqlookupd 主機的信息編碼，發送給 client

3、case "REGISTER”:     topic，channel 注冊

client 首先要 IDENTITY，即身份認證

// channel 注冊

key := Registration{"channel", topic, channel}

p.context.nsqlookupd.DB.AddProducer(key, &Producer{peerInfo: client.peerInfo})

// topic 注冊

key := Registration{"topic", topic, ""}

p.context.nsqlookupd.DB.AddProducer(key, &Producer{peerInfo: client.peerInfo})

注意 key 和 client 認證時候的不同

給 client 返回 “OK”

4、case "UNREGISTER”:     注銷 topic, channel

這個地方有個小細節，不明白作者為什么要創建新的 Producer slice

cleaned := make(Producers, 0)

for _, producer := range producers {

      if   producer.peerInfo.id   != id {

           cleaned = append(cleaned, producer)

      } else {

           removed = true

      }

}

// Note: this leaves keys in the DB even if they have empty lists

r.registrationMap[k] = cleaned 

以上是“nsqlookupd中tcpServer命令怎么用”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！