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

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

一、tcpServer

1、case "PING”:     健康檢查

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

回復(fù) “OK”

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

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

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

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

繼續(xù)從 conn 讀取上面獲取長度的字節(jié)流，原始報(bào)文是 json 格式

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

err = json.Unmarshal(body, &peerInfo)

解碼成 PeerInfo；同時(shí) 驗(yàn)證字段是否完整，設(shè)置 lateUpdate

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

type NSQLookupd struct {

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

     DB           *RegistrationDB

}

type RegistrationDB struct {

     sync.RWMutex     // 鎖用來協(xié)調(diào)多個(gè)協(xié)程的訪問

     registrationMap map[Registration]Producers     // producer slice

}

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

// 添加時(shí)會(huì)做判斷，根據(jù) peerInfo.Id，也就是 client 的 ip 地址

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

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

r.Lock()

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

最后一步把 nsqlookupd 主機(jī)的信息編碼，發(fā)送給 client

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

client 首先要 IDENTITY，即身份認(rèn)證

// 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 認(rèn)證時(shí)候的不同

給 client 返回 “OK”

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

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

網(wǎng)站標(biāo)題：nsqlookupd中tcpServer命令怎么用
本文路徑：http://www.aaarwkj.com/article28/igjhcp.html

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

廣告

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