nsqlookupd中tcpServer命令怎么用

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

一、tcpServer

1、case "PING”:     健康檢查

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

回復(fù) “OK”

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

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

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

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

繼續(xù)從 conn 讀取上面獲取長(zhǎng)度的字節(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 對(duì)其有一個(gè)指針。

type NSQLookupd struct {

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

     DB           *RegistrationDB

}

type RegistrationDB struct {

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

     registrationMap map[Registration]Producers     // producer slice

}

// 下面這句是非常重要的注冊(cè) 添加生產(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 注冊(cè)

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

// channel 注冊(cè)

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

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

// topic 注冊(cè)

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)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！