Go中如何检测grpc服务器关闭时的错误？

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《Go中如何检测grpc服务器关闭时的错误？》，聊聊，我们一起来看看吧！

我正在尝试在 go grpc 客户端代码中检测 grpc 服务器关闭，例如

import (
     pb "mysample.com/api/rpc"
     "google.golang.org/grpc"
)
var stream pb.searchproductservice_marketstreamclient
for {
    r, err := stream.recv()
    if err == io.eof {
        log.println("info: server close")
        break
    } else if err != nil {
        log.println("err: grpc code:", grpc.code(err))
        if err != nil {
          log.fatal(err)
        }
    }
    outs := printorderbook(r)
    fmt.println(outs)
    if outf != nil {
        outf.writestring(time.now().format("030405.000 ") +
            outs + "\n")
    }
}

输出消息是

mysample.go:122: Err: grpc code: Unavailable
panic: rpc error: code = Unavailable desc = transport is closing

我试图在 go 的源代码和 $gopath/src/ 中搜索“transport is close”，但我找不到这样的短语。有没有什么聪明的方法来处理这种更深层次的错误？

解决方案

gRPC 始终需要正确返回错误，如果不处理错误，连接将进入 TRANSIENT_FAILURE 状态，并且您无法使用此客户端连接请求任何查询。正确捕获错误并使用 grpc 错误代码返回它。您可以在此处找到更深入的站点 https://www.grpc.io/docs/guides/error/ 并使用此内置包 grpc：google.golang.org/grpc/status

conn *grpc.ClientConn conn.GetState() 将给出当前连接状态

以上就是《Go中如何检测grpc服务器关闭时的错误？》的详细内容，更多关于的资料请关注golang学习网公众号！