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

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

一、背景

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

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

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

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

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

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

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

packagemain

import(

"fmt"

"math/rand"

"time"

funcmain(){

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

intChannels:=[3]chanint{

make(chanint,1),

make(chanint,1),

make(chanint,1),

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

index:=rand.Intn(3)

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

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

//intChannels[index]-index

//哪一個通道中有可取的元素值，哪個對應(yīng)的分支就會被執(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通過time.sleep（簡單有效）

通過time.sleep()實現(xiàn)超時操作，是比較巧妙的。一般來說心跳超時是一個雙方交互的行為。

下面畫一個圖來描述一下。

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

下面是代碼。

基本的邏輯是：

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

2、客戶端每次收到心跳的時候，更新這個時間

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

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

packagemain

import(

"fmt"

"sync"

"time"

typeClientstruct{

locksync.Mutex//加鎖

nextTimeOutTimetime.Time//下次超時時間

consttenSec=10

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

func(client*Client)freshTimeOutTime(){

client.lock.Lock()

deferclient.lock.Unlock()

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

//開啟一個gp，每隔500ms判斷有沒有超時

func(client*Client)judgeTimeOut(){

for{

time.Sleep(500*time.Millisecond)

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

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

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

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

func(client*Client)receiveHeart(){

client.freshTimeOutTime()

//開啟一個模擬ping客戶端的線程

funcpingClient(client*Client){

fortrue{

time.Sleep(11*time.Second)

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

client.receiveHeart()

funcmain(){

cl