2018-05-23字節(jié)點(diǎn)也可以廣播

/主節(jié)點(diǎn)廣播后建立字節(jié)點(diǎn)的廣播

package main

import (
    "os"
    "fmt"
    "net/http"
    "io"
)

type nodeINfo struct {
    // 節(jié)點(diǎn)名稱(chēng)
    id string
    //節(jié)點(diǎn)路徑
    path  string
    // http 相應(yīng)
    write http.ResponseWriter
}
// 創(chuàng)建map老翘,存儲(chǔ)各個(gè)國(guó)家的ip地址
var nodeTable  = make(map[string]string)


func main()  {
    // 接收終端參數(shù)
    userId := os.Args[1]
    fmt.Println(userId)
    // 存儲(chǔ)四個(gè)國(guó)家的ip地址
    nodeTable = map[string]string{
        "Apple" :"localhost:1111",
        "MS" :"localhost:1112",
        "Google" :"localhost:1113",
        "IBM" :"localhost:1114",

    }

    // 創(chuàng)建國(guó)家對(duì)象
    node := nodeINfo{id:userId,path:nodeTable[userId]}
// http協(xié)議的回掉函數(shù)
// http://localhost:1111/req?warTime =1111
http.HandleFunc("/req",node.request)
http.HandleFunc("/prePrepare",node.prePrepare)
http.HandleFunc("/prepare",node.prepare)
    http.HandleFunc("/commit",node.commit)

    if err:=http.ListenAndServe(node.path,nil);err!=nil {
        fmt.Println(err)
    }

}
// http服務(wù)器区赵,接收到網(wǎng)絡(luò)請(qǐng)求并且映之。req則回掉request
func (node *nodeINfo)request(writer http.ResponseWriter,request *http.Request)  {
   // 該命令允許request請(qǐng)求參數(shù)
    request.ParseForm()
    if (len(request.Form["warTime"])>0) {
        node.write =writer
        fmt.Println("主節(jié)點(diǎn)接收到的參數(shù)信息為",request.Form["warTime"][0])
        
        // 激活主節(jié)點(diǎn)后向其他的節(jié)點(diǎn)發(fā)送廣播
        node.broadcast(request.Form["warTime"][0],"/prePrepare")

    }
}
// 節(jié)點(diǎn)發(fā)送廣播的方法
func (node *nodeINfo)broadcast(msg string,path string)  {
    fmt.Println("廣播",path)
    // 遍歷所有的節(jié)點(diǎn)
    for nodeId,url :=range nodeTable  {
        if nodeId== node.id{
            continue

        }
        // 使當(dāng)前節(jié)點(diǎn)外的節(jié)點(diǎn)作出相應(yīng)
        http.Get("http://"+url+path+"?warTime="+msg+"&nodeId="+node.id)


    }

}
//處理廣播后接收到的數(shù)據(jù)
func (node *nodeINfo)prePrepare(writer http.ResponseWriter,request *http.Request)  {
    request.ParseForm()
    fmt.Println("接收到的廣播為",request.Form["warTime"][0])
    if len(request.Form["warTime"])>0 {
        node.broadcast(request.Form["warTime"][0],"/prepare")
    }

}

//接收子節(jié)點(diǎn)的廣播
func (node *nodeINfo)prepare(writer http.ResponseWriter,request *http.Request){
    request.ParseForm()
    //打印
    fmt.Println("接收到子節(jié)點(diǎn)的廣播",request.Form["warTime"][0])
    //校驗(yàn)
    if len(request.Form["warTime"])>0 {
        node.authentication(request)
    }

}


var authenticationNOdeMap  =make(map[string]string)
var  authenticationSuceess =false
// 校驗(yàn)拜占庭
func (node *nodeINfo)authentication(request *http.Request )  {
    if !authenticationSuceess {
        if len(request.Form["nodeId"])>0 {

          authenticationNOdeMap[request.Form["nodeId"][0]]="OK"
          // 如果由兩個(gè)國(guó)家節(jié)點(diǎn)成功正確返回了結(jié)果便锨,則成功
            if len(authenticationNOdeMap)>len(nodeTable)/3 {
                authenticationSuceess = true
                node.broadcast(request.Form["warTime"][0],"/commit")

                
            }
        }

    }


}
// 返回成功相應(yīng)
func(node *nodeINfo)commit(writer http.ResponseWriter,request *http.Request)  {
    if writer !=nil {
        fmt.Println("拜占庭校驗(yàn)成功哈哈哈哈哈哈哈")
        io.WriteString(node.write,"ok")

    }

}

/*運(yùn)行起來(lái)主節(jié)點(diǎn)歪架,一次運(yùn)行子節(jié)點(diǎn),然后運(yùn)行網(wǎng)頁(yè)端的http://localhost:1111/req?warTime=1111
然后看圖
*/葛闷,
主節(jié)點(diǎn)廣播的圖:

image.png

字節(jié)點(diǎn)1:
image.png

字節(jié)點(diǎn)2:
[圖片上傳中...(image.png-5b30e8-1527060651051-0)]
字節(jié)點(diǎn)3
image.png

這樣一個(gè)字節(jié)點(diǎn)的廣播服務(wù)算是成功了

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末憋槐,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子淑趾,更是在濱河造成了極大的恐慌阳仔,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,590評(píng)論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件扣泊,死亡現(xiàn)場(chǎng)離奇詭異近范,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)旷赖,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,157評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門(mén)顺又,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái),“玉大人等孵,你說(shuō)我怎么就攤上這事稚照。” “怎么了俯萌?”我有些...
    開(kāi)封第一講書(shū)人閱讀 169,301評(píng)論 0 362
  • 文/不壞的土叔 我叫張陵果录,是天一觀(guān)的道長(zhǎng)。 經(jīng)常有香客問(wèn)我咐熙,道長(zhǎng)弱恒,這世上最難降的妖魔是什么? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 60,078評(píng)論 1 300
  • 正文 為了忘掉前任棋恼,我火速辦了婚禮返弹,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘爪飘。我一直安慰自己义起,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,082評(píng)論 6 398
  • 文/花漫 我一把揭開(kāi)白布师崎。 她就那樣靜靜地躺著默终,像睡著了一般。 火紅的嫁衣襯著肌膚如雪犁罩。 梳的紋絲不亂的頭發(fā)上齐蔽,一...
    開(kāi)封第一講書(shū)人閱讀 52,682評(píng)論 1 312
  • 那天,我揣著相機(jī)與錄音床估,去河邊找鬼含滴。 笑死,一個(gè)胖子當(dāng)著我的面吹牛丐巫,可吹牛的內(nèi)容都是我干的蛙吏。 我是一名探鬼主播源哩,決...
    沈念sama閱讀 41,155評(píng)論 3 422
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼鸦做!你這毒婦竟也來(lái)了励烦?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 40,098評(píng)論 0 277
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤泼诱,失蹤者是張志新(化名)和其女友劉穎坛掠,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體治筒,經(jīng)...
    沈念sama閱讀 46,638評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡屉栓,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,701評(píng)論 3 342
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了耸袜。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片友多。...
    茶點(diǎn)故事閱讀 40,852評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖堤框,靈堂內(nèi)的尸體忽然破棺而出域滥,到底是詐尸還是另有隱情,我是刑警寧澤蜈抓,帶...
    沈念sama閱讀 36,520評(píng)論 5 351
  • 正文 年R本政府宣布启绰,位于F島的核電站,受9級(jí)特大地震影響沟使,放射性物質(zhì)發(fā)生泄漏委可。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,181評(píng)論 3 335
  • 文/蒙蒙 一腊嗡、第九天 我趴在偏房一處隱蔽的房頂上張望着倾。 院中可真熱鬧,春花似錦燕少、人聲如沸卡者。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,674評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)虎眨。三九已至蟋软,卻和暖如春镶摘,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背岳守。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,788評(píng)論 1 274
  • 我被黑心中介騙來(lái)泰國(guó)打工凄敢, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人湿痢。 一個(gè)月前我還...
    沈念sama閱讀 49,279評(píng)論 3 379
  • 正文 我出身青樓涝缝,卻偏偏與公主長(zhǎng)得像扑庞,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子拒逮,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,851評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開(kāi)發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見(jiàn)模式的工具(例如配置管理罐氨,服務(wù)發(fā)現(xiàn),斷路器滩援,智...
    卡卡羅2017閱讀 134,715評(píng)論 18 139
  • 01.{ 換行: Opening Brace Can't Be Placed on a Separate Lin...
    碼農(nóng)不器閱讀 2,405評(píng)論 0 14
  • // 主節(jié)點(diǎn)是apple 會(huì)分發(fā)給其余的節(jié)點(diǎn)信息// 啟動(dòng)一個(gè)網(wǎng)頁(yè)服務(wù)例如http://localhost:111...
    fairy冉冉閱讀 247評(píng)論 0 0
  • 吃雞蛋對(duì)身體好不好栅隐?有個(gè)人說(shuō)好!另一個(gè)人說(shuō)不好玩徊。 另一個(gè)人手中恰好有根大棒租悄,于是劈地把那個(gè)說(shuō)好的人打了。 于是恩袱,那...
    名叫傅蓓閱讀 496評(píng)論 0 0
  • 深夜十點(diǎn)畔塔,習(xí)慣性的在聽(tīng)一個(gè)電臺(tái)潭辈,這一期的主題是“你想成為一個(gè)什么樣的人?” 這是一個(gè)比較文藝的主題俩檬,按正常套路萎胰,接...
    少女阿花閱讀 271評(píng)論 1 2