最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Go gRPC超時(shí)控制Deadlines用法詳解

 更新時(shí)間:2022年06月15日 16:35:36   作者:煎魚eddycjy  
這篇文章主要為大家介紹了Go gRPC超時(shí)控制Deadlines用法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

Deadlines

今天將介紹 gRPC Deadlines 的用法,這一個(gè)必備技巧。內(nèi)容也比較簡單。

Deadlines 意指截止時(shí)間,在 gRPC 中強(qiáng)調(diào) TL;DR(Too long, Don't read)并建議始終設(shè)定截止日期,為什么呢?

為什么要設(shè)置

當(dāng)未設(shè)置 Deadlines 時(shí),將采用默認(rèn)的 DEADLINE_EXCEEDED(這個(gè)時(shí)間非常大)

如果產(chǎn)生了阻塞等待,就會(huì)造成大量正在進(jìn)行的請(qǐng)求都會(huì)被保留,并且所有請(qǐng)求都有可能達(dá)到最大超時(shí)

這會(huì)使服務(wù)面臨資源耗盡的風(fēng)險(xiǎn),例如內(nèi)存,這會(huì)增加服務(wù)的延遲,或者在最壞的情況下可能導(dǎo)致整個(gè)進(jìn)程崩潰

gRPC

Client

func main() {
    ...
	ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Duration(5 * time.Second)))
	defer cancel()
	client := pb.NewSearchServiceClient(conn)
	resp, err := client.Search(ctx, &pb.SearchRequest{
		Request: "gRPC",
	})
	if err != nil {
		statusErr, ok := status.FromError(err)
		if ok {
			if statusErr.Code() == codes.DeadlineExceeded {
				log.Fatalln("client.Search err: deadline")
			}
		}
		log.Fatalf("client.Search err: %v", err)
	}
	log.Printf("resp: %s", resp.GetResponse())
}
  • context.WithDeadline:會(huì)返回最終上下文截止時(shí)間。第一個(gè)形參為父上下文,第二個(gè)形參為調(diào)整的截止時(shí)間。若父級(jí)時(shí)間早于子級(jí)時(shí)間,則以父級(jí)時(shí)間為準(zhǔn),否則以子級(jí)時(shí)間為最終截止時(shí)間
func WithDeadline(parent Context, d time.Time) (Context, CancelFunc) {
	if cur, ok := parent.Deadline(); ok && cur.Before(d) {
		// The current deadline is already sooner than the new one.
		return WithCancel(parent)
	}
	c := &timerCtx{
		cancelCtx: newCancelCtx(parent),
		deadline:  d,
	}
	propagateCancel(parent, c)
	dur := time.Until(d)
	if dur <= 0 {
		c.cancel(true, DeadlineExceeded) // deadline has already passed
		return c, func() { c.cancel(true, Canceled) }
	}
	c.mu.Lock()
	defer c.mu.Unlock()
	if c.err == nil {
		c.timer = time.AfterFunc(dur, func() {
			c.cancel(true, DeadlineExceeded)
		})
	}
	return c, func() { c.cancel(true, Canceled) }
}

context.WithTimeout:很常見的另外一個(gè)方法,是便捷操作。實(shí)際上是對(duì)于 WithDeadline 的封裝

func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc) {
	return WithDeadline(parent, time.Now().Add(timeout))
}

status.FromError:返回 GRPCStatus 的具體錯(cuò)誤碼,若為非法,則直接返回 codes.Unknown

Server

type SearchService struct{}
func (s *SearchService) Search(ctx context.Context, r *pb.SearchRequest) (*pb.SearchResponse, error) {
	for i := 0; i < 5; i++  {
		if ctx.Err() == context.Canceled {
			return nil, status.Errorf(codes.Canceled, "SearchService.Search canceled")
		}
		time.Sleep(1 * time.Second)
	}
	return &pb.SearchResponse{Response: r.GetRequest() + " Server"}, nil
}
func main() {
	...
}

而在 Server 端,由于 Client 已經(jīng)設(shè)置了截止時(shí)間。Server 勢(shì)必要去檢測(cè)它

否則如果 Client 已經(jīng)結(jié)束掉了,Server 還傻傻的在那執(zhí)行,這對(duì)資源是一種極大的浪費(fèi)

因此在這里需要用 ctx.Err() == context.Canceled 進(jìn)行判斷,為了模擬場(chǎng)景我們加了循環(huán)和睡眠 ??

驗(yàn)證

重新啟動(dòng) server.go 和 client.go,得到結(jié)果:

$ go run client.go
2018/10/06 17:45:55 client.Search err: deadline
exit status 1

總結(jié)

本章節(jié)比較簡單,你需要知道以下知識(shí)點(diǎn):

  • 怎么設(shè)置 Deadlines
  • 為什么要設(shè)置 Deadlines

你要清楚地明白到,gRPC Deadlines 是很重要的,否則這小小的功能點(diǎn)就會(huì)要了你生產(chǎn)的命。

示例源碼

https://github.com/eddycjy/go-grpc-example

以上就是Go gRPC超時(shí)控制Deadlines用法詳解的詳細(xì)內(nèi)容,更多關(guān)于Go gRPC超時(shí)控制Deadlines的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • Golang中結(jié)構(gòu)體映射mapstructure庫深入詳解

    Golang中結(jié)構(gòu)體映射mapstructure庫深入詳解

    mapstructure用于將通用的map[string]interface{}解碼到對(duì)應(yīng)的 Go 結(jié)構(gòu)體中,或者執(zhí)行相反的操作。很多時(shí)候,解析來自多種源頭的數(shù)據(jù)流時(shí),我們一般事先并不知道他們對(duì)應(yīng)的具體類型。只有讀取到一些字段之后才能做出判斷
    2023-01-01
  • golang 在windows中設(shè)置環(huán)境變量的操作

    golang 在windows中設(shè)置環(huán)境變量的操作

    這篇文章主要介紹了golang 在windows中設(shè)置環(huán)境變量的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
    2021-04-04
  • Go語言中?Print?Printf和Println?的區(qū)別解析

    Go語言中?Print?Printf和Println?的區(qū)別解析

    這篇文章主要介紹了Go語言中?Print?Printf和Println?的區(qū)別,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2023-03-03
  • Go語言中interface語法與使用詳解

    Go語言中interface語法與使用詳解

    Go語言里面設(shè)計(jì)最精妙的應(yīng)該算interface,它讓面向?qū)ο?內(nèi)容組織實(shí)現(xiàn)非常的方便,下面這篇文章主要給大家介紹了關(guān)于Go語言中interface語法與使用的相關(guān)資料,需要的朋友可以參考下
    2022-07-07
  • Golang中Kafka的重復(fù)消費(fèi)和消息丟失問題的解決方案

    Golang中Kafka的重復(fù)消費(fèi)和消息丟失問題的解決方案

    在Kafka中無論是生產(chǎn)者發(fā)送消息到Kafka集群還是消費(fèi)者從Kafka集群中拉取消息,都是容易出現(xiàn)問題的,比較典型的就是消費(fèi)端的重復(fù)消費(fèi)問題、生產(chǎn)端和消費(fèi)端產(chǎn)生的消息丟失問題,下面將對(duì)這兩個(gè)問題出現(xiàn)的場(chǎng)景以及常見的解決方案進(jìn)行講解
    2023-08-08
  • 淺談go中cgo的幾種使用方式

    淺談go中cgo的幾種使用方式

    本文主要介紹了淺談go中cgo的幾種使用方式,文中根據(jù)實(shí)例編碼詳細(xì)介紹的十分詳盡,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-03-03
  • gin項(xiàng)目部署到服務(wù)器并后臺(tái)啟動(dòng)的步驟

    gin項(xiàng)目部署到服務(wù)器并后臺(tái)啟動(dòng)的步驟

    本文主要介紹了gin項(xiàng)目部署到服務(wù)器并后臺(tái)啟動(dòng)的步驟,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-02-02
  • Go語言學(xué)習(xí)教程之goroutine和通道的示例詳解

    Go語言學(xué)習(xí)教程之goroutine和通道的示例詳解

    這篇文章主要通過A?Tour?of?Go中的例子進(jìn)行學(xué)習(xí),以此了解Go語言中的goroutine和通道,文中的示例代碼講解詳細(xì),感興趣的可以了解一下
    2022-09-09
  • Go語言中多字節(jié)字符的處理方法詳解

    Go語言中多字節(jié)字符的處理方法詳解

    這篇文章主要給大家介紹了關(guān)于Go語言中多字節(jié)字符的處理方法,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2018-10-10
  • go中的unsafe包及使用詳解

    go中的unsafe包及使用詳解

    Unsafe code是一種繞過go類型安全和內(nèi)存安全檢查的Go代碼。這篇文章主要介紹了go中的unsafe包,需要的朋友可以參考下
    2019-07-07

最新評(píng)論

大兴区| 木里| 凤阳县| 灵璧县| 上蔡县| 峨眉山市| 灵宝市| 石泉县| 汝州市| 休宁县| 富民县| 北宁市| 南平市| 姚安县| 广州市| 万州区| 库尔勒市| 泽州县| 梧州市| 两当县| 类乌齐县| 新巴尔虎右旗| 沂源县| 南乐县| 隆化县| 兴义市| 普陀区| 泌阳县| 苍南县| 长治市| 建昌县| 兴文县| 丹寨县| 准格尔旗| 黔江区| 蒲江县| 尤溪县| 剑川县| 布尔津县| 任丘市| 建昌县|