带入gRPC：gRPC Deadlines

crossoverJie 发布于2019-07-01 10:50 / 2171人阅读

摘要：带入原文地址带入项目地址前言在前面的章节中，已经介绍了的基本用法。今天将介绍的用法，这一个必备技巧。第一个形参为父上下文，第二个形参为调整的截止时间。实际上是对于的封装返回的具体错误码，若为非法，则直接返回而在端，由于已经设置了截止时间。

带入gRPC：gRPC Deadlines

原文地址：带入gRPC：gRPC Deadlines
项目地址：https://github.com/EDDYCJY/go...

前言

在前面的章节中，已经介绍了 gRPC 的基本用法。那你想想，让它这么裸跑真的没问题吗？

那么，肯定是有问题了。今天将介绍 gRPC Deadlines 的用法，这一个必备技巧。内容也比较简单

Deadlines

Deadlines 意指截止时间，在 gRPC 中强调 TL;DR（Too long, Don"t read）并建议始终设定截止日期，为什么呢？

为什么要设置

当未设置 Deadlines 时，将采用默认的 DEADLINE_EXCEEDED（这个时间非常大）

如果产生了阻塞等待，就会造成大量正在进行的请求都会被保留，并且所有请求都有可能达到最大超时

这会使服务面临资源耗尽的风险，例如内存，这会增加服务的延迟，或者在最坏的情况下可能导致整个进程崩溃

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：会返回最终上下文截止时间。第一个形参为父上下文，第二个形参为调整的截止时间。若父级时间早于子级时间，则以父级时间为准，否则以子级时间为最终截止时间

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：很常见的另外一个方法，是便捷操作。实际上是对于 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 已经设置了截止时间。Server 势必要去检测它

否则如果 Client 已经结束掉了，Server 还傻傻的在那执行，这对资源是一种极大的浪费

因此在这里需要用 ctx.Err() == context.Canceled 进行判断，为了模拟场景我们加了循环和睡眠

服务器托管云服务器 grpc Deadlines 带入

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/29542.html

带入gRPC：gRPC Client and Server

摘要：带入原文地址带入项目地址前言本章节将使用来编写和，让其互相通讯。带入gRPC：gRPC Client and Server 原文地址：带入gRPC：gRPC Client and Server 项目地址：go-grpc-example 前言本章节将使用 Go 来编写 gRPC Server 和 Client，让其互相通讯。在此之上会使用到如下库： google.golang.or...

TZLLOG 2019-07-01 10:45 评论0 收藏0
带入gRPC：gRPC Streaming, Client and Server

摘要：带入原文地址带入项目地址前言本章节将介绍的流式，分为三种类型服务器端流式客户端流式双向流式流任何技术，因为有痛点，所以才有了存在的必要性。这一次性涉及的数据量确实大在同步完成后，也有人马上会去查阅数据，为了新的一天筹备。带入gRPC：gRPC Streaming, Client and Server 原文地址：带入gRPC：gRPC Streaming, Client and Ser...

wayneli 2019-07-01 10:45 评论0 收藏0
带入gRPC：gRPC Client and Server

摘要：原文地址带入项目地址前言本章节将使用来编写和，让其互相通讯。原文地址：带入gRPC：gRPC Client and Server 项目地址：go-grpc-example 前言本章节将使用 Go 来编写 gRPC Server 和 Client，让其互相通讯。在此之上会使用到如下库： google.golang.org/grpc github.com/golang/protobu...

ivydom 2019-08-26 12:21 评论0 收藏0
带入gRPC：分布式链路追踪 gRPC-Opentracing-Zipkin

摘要：带入分布式链路追踪原文地址带入分布式链路追踪项目地址前言在实际应用中，你做了那么多端，写了个方法。想看看方法的指标，却无处下手本文将通过搭建一个分布式链路追踪系统来实现查看整个系统的链路性能等指标带入gRPC：分布式链路追踪 gRPC + Opentracing + Zipkin 原文地址：带入gRPC：分布式链路追踪 gRPC + Opentracing + Zipkin项目地址：...

BicycleWarrior 2019-07-01 10:51 评论0 收藏0
带入gRPC：对 RPC 方法做自定义认证

摘要：带入对方法做自定义认证原文地址带入对方法做自定义认证项目地址前言在前面的章节中，我们介绍了两种证书算一种可全局认证的方法证书认证基于的证书认证而在实际需求中，常常会对某些模块的方法做特殊认证或校验。带入gRPC：对 RPC 方法做自定义认证原文地址：带入gRPC：对 RPC 方法做自定义认证项目地址：https://github.com/EDDYCJY/go... 前言在前面的章...

wh469012917 2019-07-01 10:49 评论0 收藏0