成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

帶入gRPC：gRPC Deadlines

crossoverJie / 2352人閱讀

摘要：帶入原文地址帶入項(xiàng)目地址前言在前面的章節(jié)中，已經(jīng)介紹了的基本用法。今天將介紹的用法，這一個必備技巧。第一個形參為父上下文，第二個形參為調(diào)整的截止時間。實(shí)際上是對于的封裝返回的具體錯誤碼，若為非法，則直接返回而在端，由于已經(jīng)設(shè)置了截止時間。

帶入gRPC：gRPC Deadlines

原文地址：帶入gRPC：gRPC Deadlines
項(xiàng)目地址：https://github.com/EDDYCJY/go...

前言

在前面的章節(jié)中，已經(jīng)介紹了 gRPC 的基本用法。那你想想，讓它這么裸跑真的沒問題嗎？

那么，肯定是有問題了。今天將介紹 gRPC Deadlines 的用法，這一個必備技巧。內(nèi)容也比較簡單

Deadlines

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

為什么要設(shè)置

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

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

這會使服務(wù)面臨資源耗盡的風(fēng)險，例如內(nèi)存，這會增加服務(wù)的延遲，或者在最壞的情況下可能導(dǎo)致整個進(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：會返回最終上下文截止時間。第一個形參為父上下文，第二個形參為調(diào)整的截止時間。若父級時間早于子級時間，則以父級時間為準(zhǔn)，否則以子級時間為最終截止時間

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：很常見的另外一個方法，是便捷操作。實(shí)際上是對于 WithDeadline 的封裝

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

status.FromError：返回 GRPCStatus 的具體錯誤碼，若為非法，則直接返回 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è)置了截止時間。Server 勢必要去檢測它

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

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

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/29542.html

相關(guān)文章

  • 帶入gRPC：gRPC Client and Server

    摘要：帶入原文地址帶入項(xiàng)目地址前言本章節(jié)將使用來編寫和，讓其互相通訊。 帶入gRPC：gRPC Client and Server 原文地址：帶入gRPC：gRPC Client and Server 項(xiàng)目地址：go-grpc-example 前言 本章節(jié)將使用 Go 來編寫 gRPC Server 和 Client，讓其互相通訊。在此之上會使用到如下庫： google.golang.or...

    TZLLOG 評論0 收藏0

  • 帶入gRPC：gRPC Streaming, Client and Server

    摘要：帶入原文地址帶入項(xiàng)目地址前言本章節(jié)將介紹的流式，分為三種類型服務(wù)器端流式客戶端流式雙向流式流任何技術(shù)，因?yàn)橛型袋c(diǎn)，所以才有了存在的必要性。這一次性涉及的數(shù)據(jù)量確實(shí)大在同步完成后，也有人馬上會去查閱數(shù)據(jù)，為了新的一天籌備。 帶入gRPC：gRPC Streaming, Client and Server 原文地址：帶入gRPC：gRPC Streaming, Client and Ser...

    wayneli 評論0 收藏0

  • 帶入gRPC：gRPC Client and Server

    摘要：原文地址帶入項(xiàng)目地址前言本章節(jié)將使用來編寫和，讓其互相通訊。 原文地址：帶入gRPC：gRPC Client and Server 項(xiàng)目地址：go-grpc-example 前言 本章節(jié)將使用 Go 來編寫 gRPC Server 和 Client，讓其互相通訊。在此之上會使用到如下庫： google.golang.org/grpc github.com/golang/protobu...

    ivydom 評論0 收藏0

  • 帶入gRPC：分布式鏈路追蹤 gRPC-Opentracing-Zipkin

    摘要：帶入分布式鏈路追蹤原文地址帶入分布式鏈路追蹤項(xiàng)目地址前言在實(shí)際應(yīng)用中，你做了那么多端，寫了個方法。想看看方法的指標(biāo)，卻無處下手本文將通過搭建一個分布式鏈路追蹤系統(tǒng)來實(shí)現(xiàn)查看整個系統(tǒng)的鏈路性能等指標(biāo) 帶入gRPC：分布式鏈路追蹤 gRPC + Opentracing + Zipkin 原文地址：帶入gRPC：分布式鏈路追蹤 gRPC + Opentracing + Zipkin項(xiàng)目地址：...

    BicycleWarrior 評論0 收藏0

  • 帶入gRPC：對 RPC 方法做自定義認(rèn)證

    摘要：帶入對方法做自定義認(rèn)證原文地址帶入對方法做自定義認(rèn)證項(xiàng)目地址前言在前面的章節(jié)中，我們介紹了兩種證書算一種可全局認(rèn)證的方法證書認(rèn)證基于的證書認(rèn)證而在實(shí)際需求中，常常會對某些模塊的方法做特殊認(rèn)證或校驗(yàn)。 帶入gRPC：對 RPC 方法做自定義認(rèn)證 原文地址：帶入gRPC：對 RPC 方法做自定義認(rèn)證項(xiàng)目地址：https://github.com/EDDYCJY/go... 前言 在前面的章...

    wh469012917 評論0 收藏0

發(fā)表評論

0條評論

閱讀需要支付1元查看
<