go語(yǔ)言心跳超時(shí)的實(shí)現(xiàn)示例

第go語(yǔ)言心跳超時(shí)的實(shí)現(xiàn)示例目錄一、背景二、心跳超時(shí)的實(shí)現(xiàn)2.1通過(guò)selectcase（設(shè)計(jì)概念比較多）2.2通過(guò)time.sleep（簡(jiǎn)單有效）三、個(gè)人的實(shí)現(xiàn)觀感

一、背景

本文描述的是客戶端接收心跳信息的超時(shí)實(shí)現(xiàn)。心跳超時(shí)，或者接受信息超過(guò)限定時(shí)間在分布式系統(tǒng)中出現(xiàn)的次數(shù)比較多。常見(jiàn)的就有hadoop中節(jié)點(diǎn)超時(shí)，或者日志中出現(xiàn)timeout的字樣。

在學(xué)習(xí)go語(yǔ)言中，我也根據(jù)go語(yǔ)言的機(jī)制實(shí)現(xiàn)了心跳超時(shí)的這個(gè)問(wèn)題。踩過(guò)坑，趟過(guò)水。

二、心跳超時(shí)的實(shí)現(xiàn)

2.1通過(guò)selectcase（設(shè)計(jì)概念比較多）

這種方法實(shí)現(xiàn)心跳，需要對(duì)go語(yǔ)言中的channel和selectcase機(jī)制有所了解。select代碼段中沒(méi)有包含default條件時(shí)，會(huì)一直阻塞到有通道操作。

需要注意的是?。。?！select語(yǔ)言只會(huì)阻塞一次，且執(zhí)行一次。如果需要多次判斷，或者可能有多個(gè)case條件需要滿足，那就需要增加for語(yǔ)句。

首先需要知道的是select是專為channel設(shè)計(jì)的，所以說(shuō)每個(gè)case表達(dá)式都必須是包含操作通道的表達(dá)式。下面這段代碼是描述了隨機(jī)抽取一個(gè)channel發(fā)消息，正常情況下，不會(huì)觸發(fā)超時(shí)。為了觸發(fā)超時(shí)，注釋掉通道發(fā)送數(shù)據(jù)操作。超時(shí)五秒，則觸發(fā)超時(shí)。

packagemain

import(

"fmt"

"math/rand"

"time"

funcmain(){

//準(zhǔn)備好三個(gè)通道。

intChannels:=[3]chanint{

make(chanint,1),

make(chanint,1),

make(chanint,1),

//隨機(jī)選擇一個(gè)通道，并向它發(fā)送元素值。

index:=rand.Intn(3)

fmt.Printf("Theindex:%d\n",index)

//??取消這行代碼的注視，超時(shí)條件的選擇就會(huì)觸發(fā)。

//intChannels[index]-index

//哪一個(gè)通道中有可取的元素值，哪個(gè)對(duì)應(yīng)的分支就會(huì)被執(zhí)行。

select{

case-intChannels[0]:

fmt.Println("Thefirstcandidatecaseisselected.")

case-intChannels[1]:

fmt.Println("Thesecondcandidatecaseisselected.")

caseelem:=-intChannels[2]:

fmt.Printf("Thethirdcandidatecaseisselected,theelementis%d.\n",elem)

case-time.After(5*time.Second):

fmt.Println("timedout")

2.2通過(guò)time.sleep（簡(jiǎn)單有效）

通過(guò)time.sleep()實(shí)現(xiàn)超時(shí)操作，是比較巧妙的。一般來(lái)說(shuō)心跳超時(shí)是一個(gè)雙方交互的行為。

下面畫(huà)一個(gè)圖來(lái)描述一下。

為了方便理解，定義雙方都使用共同時(shí)間。

下面是代碼。

基本的邏輯是：

1、先給客戶端設(shè)置一個(gè)下次超時(shí)的時(shí)間

2、客戶端每次收到心跳的時(shí)候，更新這個(gè)時(shí)間

3、開(kāi)啟一個(gè)獨(dú)立的線程，一致判斷當(dāng)前客戶端是否超時(shí)。

ps：結(jié)合時(shí)效和性能，可以間隔一定的時(shí)間來(lái)進(jìn)行判斷。

packagemain

import(

"fmt"

"sync"

"time"

typeClientstruct{

locksync.Mutex//加鎖

nextTimeOutTimetime.Time//下次超時(shí)時(shí)間

consttenSec=10

刷新每次的心跳超時(shí)機(jī)制

func(client*Client)freshTimeOutTime(){

client.lock.Lock()

deferclient.lock.Unlock()

client.nextTimeOutTime=time.Now().Add(tenSec*time.Second)

//開(kāi)啟一個(gè)gp，每隔500ms判斷有沒(méi)有超時(shí)

func(client*Client)judgeTimeOut(){

for{

time.Sleep(500*time.Millisecond)

fmt.Printf("%v在判斷是否超時(shí)\n",client.nextTimeOutTime)

iftime.Now().After(client.nextTimeOutTime){

fmt.Printf("%v超時(shí)了\n",client.nextTimeOutTime)

//客戶端收到以后，修改下次心跳超時(shí)時(shí)間

func(client*Client)receiveHeart(){

client.freshTimeOutTime()

//開(kāi)啟一個(gè)模擬ping客戶端的線程

funcpingClient(client*Client){

fortrue{

time.Sleep(11*time.Second)

fmt.Printf("%v請(qǐng)求發(fā)送時(shí)間\n",time.Now())

client.receiveHeart()

funcmain(){

cl