golang實(shí)現(xiàn)簡(jiǎn)易的分布式系統(tǒng)方法
本文介紹了golang實(shí)現(xiàn)簡(jiǎn)易的分布式系統(tǒng)方法,分享給大家,具體如下:
功能
- 能夠發(fā)送/接收請(qǐng)求和響應(yīng)
- 能夠連接到集群
- 如果無(wú)法連接到群集(如果它是第一個(gè)節(jié)點(diǎn)),則可以作為主節(jié)點(diǎn)啟動(dòng)節(jié)點(diǎn)
- 每個(gè)節(jié)點(diǎn)有唯一的標(biāo)識(shí)
- 能夠在節(jié)點(diǎn)之間交換json數(shù)據(jù)包
- 接受命令行參數(shù)中的所有信息(將來(lái)在我們系統(tǒng)升級(jí)時(shí)將會(huì)很有用)
源碼
package main import ( "fmt" "strconv" "time" "math/rand" "net" "flag" "strings" "encoding/json" ) // 節(jié)點(diǎn)數(shù)據(jù)信息 type NodeInfo struct { // 節(jié)點(diǎn)ID,通過(guò)隨機(jī)數(shù)生成 NodeId int `json:"nodeId"` // 節(jié)點(diǎn)IP地址 NodeIpAddr string `json:"nodeIpAddr"` // 節(jié)點(diǎn)端口 Port string `json: "port"` } // 將節(jié)點(diǎn)數(shù)據(jù)信息格式化輸出 //NodeInfo:{nodeId: 89423,nodeIpAddr: 127.0.0.1/8,port: 8001} func (node *NodeInfo) String() string { return "NodeInfo:{ nodeId:" + strconv.Itoa(node.NodeId) + ",nodeIpAddr:" + node.NodeIpAddr + ",port:" + node.Port + "}" } /* 添加一個(gè)節(jié)點(diǎn)到集群的一個(gè)請(qǐng)求或者響應(yīng)的標(biāo)準(zhǔn)格式 */ type AddToClusterMessage struct { // 源節(jié)點(diǎn) Source NodeInfo `json:"source"` // 目的節(jié)點(diǎn) Dest NodeInfo `json:"dest"` // 兩個(gè)節(jié)點(diǎn)連接時(shí)發(fā)送的消息 Message string `json:"message"` } /* Request/Response 信息格式化輸出 */ func (req AddToClusterMessage) String() string { return "AddToClusterMessage:{\n source:" + req.Source.String() + ",\n dest: " + req.Dest.String() + ",\n message:" + req.Message + " }" } // cat vi go // rm func main() { // 解析命令行參數(shù) makeMasterOnError := flag.Bool("makeMasterOnError", false, "如果IP地址沒(méi)有連接到集群中,我們將其作為Master節(jié)點(diǎn).") clusterip := flag.String("clusterip", "127.0.0.1:8001", "任何的節(jié)點(diǎn)連接都連接這個(gè)IP") myport := flag.String("myport", "8001", "ip address to run this node on. default is 8001.") flag.Parse() //解析 fmt.Println(*makeMasterOnError) fmt.Println(*clusterip) fmt.Println(*myport) /* 為節(jié)點(diǎn)生成ID */ rand.Seed(time.Now().UTC().UnixNano()) //種子 myid := rand.Intn(99999999) // 隨機(jī) //fmt.Println(myid) // 獲取IP地址 myIp,_ := net.InterfaceAddrs() fmt.Println(myIp[0]) // 創(chuàng)建NodeInfo結(jié)構(gòu)體對(duì)象 me := NodeInfo{NodeId: myid, NodeIpAddr: myIp[0].String(), Port: *myport} // 輸出結(jié)構(gòu)體數(shù)據(jù)信息 fmt.Println(me.String()) dest := NodeInfo{ NodeId: -1, NodeIpAddr: strings.Split(*clusterip, ":")[0], Port: strings.Split(*clusterip, ":")[1]} /* 嘗試連接到集群,在已連接的情況下并且向集群發(fā)送請(qǐng)求 */ ableToConnect := connectToCluster(me, dest) /* * 監(jiān)聽(tīng)其他節(jié)點(diǎn)將要加入到集群的請(qǐng)求 */ if ableToConnect || (!ableToConnect && *makeMasterOnError) { if *makeMasterOnError {fmt.Println("Will start this node as master.")} listenOnPort(me) } else { fmt.Println("Quitting system. Set makeMasterOnError flag to make the node master.", myid) } } /* * 這是發(fā)送請(qǐng)求時(shí)格式化json包有用的工具 * 這是非常重要的,如果不經(jīng)過(guò)數(shù)據(jù)格式化,你最終發(fā)送的將是空白消息 */ func getAddToClusterMessage(source NodeInfo, dest NodeInfo, message string) (AddToClusterMessage){ return AddToClusterMessage{ Source: NodeInfo{ NodeId: source.NodeId, NodeIpAddr: source.NodeIpAddr, Port: source.Port, }, Dest: NodeInfo{ NodeId: dest.NodeId, NodeIpAddr: dest.NodeIpAddr, Port: dest.Port, }, Message: message, } } func connectToCluster(me NodeInfo, dest NodeInfo) (bool){ /* 連接到socket的相關(guān)細(xì)節(jié)信息 */ connOut, err := net.DialTimeout("tcp", dest.NodeIpAddr + ":" + dest.Port, time.Duration(10) * time.Second) if err != nil { if _, ok := err.(net.Error); ok { fmt.Println("未連接到集群.", me.NodeId) return false } } else { fmt.Println("連接到集群. 發(fā)送消息到節(jié)點(diǎn).") text := "Hi nody.. 請(qǐng)?zhí)砑游业郊?." requestMessage := getAddToClusterMessage(me, dest, text) json.NewEncoder(connOut).Encode(&requestMessage) decoder := json.NewDecoder(connOut) var responseMessage AddToClusterMessage decoder.Decode(&responseMessage) fmt.Println("得到數(shù)據(jù)響應(yīng):\n" + responseMessage.String()) return true } return false } func listenOnPort(me NodeInfo){ /* 監(jiān)聽(tīng)即將到來(lái)的消息 */ ln, _ := net.Listen("tcp", fmt.Sprint(":" + me.Port)) /* 接受連接 */ for { connIn, err := ln.Accept() if err != nil { if _, ok := err.(net.Error); ok { fmt.Println("Error received while listening.", me.NodeId) } } else { var requestMessage AddToClusterMessage json.NewDecoder(connIn).Decode(&requestMessage) fmt.Println("Got request:\n" + requestMessage.String()) text := "Sure buddy.. too easy.." responseMessage := getAddToClusterMessage(me, requestMessage.Source, text) json.NewEncoder(connIn).Encode(&responseMessage) connIn.Close() } } }
運(yùn)行程序
/Users/liyuechun/go liyuechun:go yuechunli$ go install main liyuechun:go yuechunli$ main My details: NodeInfo:{ nodeId:53163002, nodeIpAddr:127.0.0.1/8, port:8001 } 不能連接到集群. 53163002 Quitting system. Set makeMasterOnError flag to make the node master. 53163002 liyuechun:go yuechunli$
獲取相關(guān)幫助信息
$ ./bin/main -h
liyuechun:go yuechunli$ ./bin/main -h Usage of ./bin/main: -clusterip string ip address of any node to connnect (default "127.0.0.1:8001") -makeMasterOnError make this node master if unable to connect to the cluster ip provided. -myport string ip address to run this node on. default is 8001. (default "8001") liyuechun:go yuechunli$
啟動(dòng)Node1主節(jié)點(diǎn)
$ ./bin/main --makeMasterOnError
liyuechun:go yuechunli$ ./bin/main --makeMasterOnError My details: NodeInfo:{ nodeId:82381143, nodeIpAddr:127.0.0.1/8, port:8001 } 未連接到集群. 82381143 Will start this node as master.
添加節(jié)點(diǎn)Node2到集群
$ ./bin/main --myport 8002 --clusterip 127.0.0.1:8001
添加節(jié)點(diǎn)Node3到集群
main --myport 8004 --clusterip 127.0.0.1:8001
添加節(jié)點(diǎn)Node4到集群
$ main --myport 8003 --clusterip 127.0.0.1:8002
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Go語(yǔ)言調(diào)用ffmpeg-api實(shí)現(xiàn)音頻重采樣
最近對(duì)golang處理音視頻很感興趣,對(duì)golang音視頻常用庫(kù)goav進(jìn)行了一番研究。自己寫了一個(gè)wav轉(zhuǎn)采樣率的功能。給大家分享一下,中間遇到了不少坑,解決的過(guò)程中還是蠻有意思的,希望大家能喜歡2022-12-12go slice 數(shù)組和切片使用區(qū)別示例解析
這篇文章主要為大家介紹了go slice 數(shù)組和切片使用區(qū)別示例解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-01-01Golang多線程爬蟲(chóng)高效抓取大量數(shù)據(jù)的利器
Golang多線程爬蟲(chóng)是一種高效抓取大量數(shù)據(jù)的利器。Golang語(yǔ)言天生支持并發(fā)和多線程,可以輕松實(shí)現(xiàn)多線程爬蟲(chóng)的開(kāi)發(fā)。通過(guò)使用Golang的協(xié)程和通道,可以實(shí)現(xiàn)爬蟲(chóng)的高效并發(fā)抓取、數(shù)據(jù)處理和存儲(chǔ)2023-05-05GoLand編譯帶有構(gòu)建標(biāo)簽的程序思路詳解
這篇文章主要介紹了GoLand編譯帶有構(gòu)建標(biāo)簽的程序,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-11-11Go語(yǔ)言中init函數(shù)和defer延遲調(diào)用關(guān)鍵詞詳解
這篇文章主要介紹了Go語(yǔ)言中init函數(shù)和defer延遲調(diào)用關(guān)鍵詞,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-03-03一文搞懂如何實(shí)現(xiàn)Go 超時(shí)控制
這篇文章主要介紹了一文搞懂如何實(shí)現(xiàn)Go 超時(shí)控制,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03重學(xué)Go語(yǔ)言之基礎(chǔ)數(shù)據(jù)類型詳解
Go語(yǔ)言有非常強(qiáng)大的數(shù)據(jù)類型系統(tǒng),其支持的數(shù)據(jù)類型大體上可分為四類:基礎(chǔ)數(shù)據(jù)類型、引用數(shù)據(jù)類型、接口類型、復(fù)合類型。本文就來(lái)講講它們各自的用法吧2023-02-02一文帶你了解Go語(yǔ)言fmt標(biāo)準(zhǔn)庫(kù)輸出函數(shù)的使用
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言中 fmt 標(biāo)準(zhǔn)庫(kù)輸出函數(shù)的使用,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起了解一下2022-12-12golang判斷chan channel是否關(guān)閉的方法
這篇文章主要介紹了golang判斷chan channel是否關(guān)閉的方法,結(jié)合實(shí)例形式對(duì)比分析了Go語(yǔ)言判斷chan沒(méi)有關(guān)閉的后果及關(guān)閉的方法,需要的朋友可以參考下2016-07-07