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

在訥河等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網站制作、成都網站設計 網站設計制作按需定制開發(fā),公司網站建設,企業(yè)網站建設,品牌網站建設,全網營銷推廣,成都外貿網站建設,訥河網站建設費用合理。

一、tcpServer

1、case "PING”:     健康檢查

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

回復 “OK”

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

此命令，每個 client 只發(fā)送一次。

server 繼續(xù)從 conn 讀取1個 int32，這個數(shù)字表明 body 長度

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

繼續(xù)從 conn 讀取上面獲取長度的字節(jié)流，原始報文是 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     // 鎖用來協(xié)調多個協(xié)程的訪問

     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 主機的信息編碼，發(fā)送給 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

這個地方有個小細節(jié)，不明白作者為什么要創(chuàng)建新的 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命令怎么用”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

網站標題：nsqlookupd中tcpServer命令怎么用
本文路徑：http://www.rwnh.cn/article28/igjhcp.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供靜態(tài)網站、域名注冊、App開發(fā)、用戶體驗、面包屑導航、做網站

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)