快捷導(dǎo)航

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

更新時(shí)間：2022年05月13日 11:46:19 作者：大錘愛編程

本文主要介紹了go語言心跳超時(shí)的實(shí)現(xiàn)示例，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、背景

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

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

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

2.1 通過select case （設(shè)計(jì)概念比較多）

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

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

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

package main
 
import (
    "fmt"
    "math/rand"
    "time"
)
 
func main() {
    // 準(zhǔn)備好三個(gè)通道。
    intChannels := [3]chan int{
        make(chan int, 1),
        make(chan int, 1),
        make(chan int, 1),
    }
    // 隨機(jī)選擇一個(gè)通道，并向它發(fā)送元素值。
    index := rand.Intn(3)
    fmt.Printf("The index: %d\n", index)
 
    //?? 取消這行代碼的注視，超時(shí)條件的選擇就會觸發(fā)。
    //intChannels[index] <- index
    // 哪一個(gè)通道中有可取的元素值，哪個(gè)對應(yīng)的分支就會被執(zhí)行。
    select {
    case <-intChannels[0]:
        fmt.Println("The first candidate case is selected.")
    case <-intChannels[1]:
        fmt.Println("The second candidate case is selected.")
    case elem := <-intChannels[2]:
        fmt.Printf("The third candidate case is selected, the element is %d.\n", elem)
    case <-time.After(5 * time.Second):
        fmt.Println("timed out")
    }
}

2.2 通過time.sleep（簡單有效）

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

下面畫一個(gè)圖來描述一下。

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

下面是代碼。

基本的邏輯是：

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

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

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

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

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
type Client struct {
    lock sync.Mutex //加鎖
    nextTimeOutTime time.Time //下次超時(shí)時(shí)間
}
 
const tenSec = 10
/**
刷新每次的心跳超時(shí)機(jī)制
 */
func (client *Client) freshTimeOutTime()  {
    client.lock.Lock()
    defer client.lock.Unlock()
    client.nextTimeOutTime =time.Now().Add(tenSec*time.Second)
}
 
//開啟一個(gè)gp，每隔500ms判斷有沒有超時(shí)
func (client *Client) judgeTimeOut()  {
    for  {
        time.Sleep(500*time.Millisecond)
        fmt.Printf("%v 在判斷是否超時(shí)\n", client.nextTimeOutTime)
        if time.Now().After(client.nextTimeOutTime) {
            fmt.Printf("%v 超時(shí)了\n", client.nextTimeOutTime)
        }
    }
}
 
//客戶端收到以后，修改下次心跳超時(shí)時(shí)間
func (client *Client) receiveHeart()  {
    client.freshTimeOutTime()
}
 
//開啟一個(gè)模擬ping 客戶端的線程
func pingClient(client *Client)  {
    for true {
        time.Sleep(11*time.Second)
        fmt.Printf("%v 請求發(fā)送時(shí)間\n", time.Now())
        client.receiveHeart()
    }
 
}
 
func main() {
    client := Client{
        lock:            sync.Mutex{},
        nextTimeOutTime: time.Time{},
    }
    //在當(dāng)前時(shí)刻，更新下次的超時(shí)時(shí)刻是10s中后
    client.freshTimeOutTime()
 
 
    go pingClient(&client)
 
 
    go client.judgeTimeOut()
 
    for true {
 
    }
}