go grpc 异步调用

在 Go 中，使用 gRPC 异步调用可以通过创建 gRPC 客户端时指定相应的选项来实现。具体来说，需要使用 WithStreamInterceptor 方法和 WithUnaryInterceptor 方法来分别设置流和单向拦截器，从而实现异步调用。

例如，在创建 gRPC 客户端时，可以使用以下代码来设置异步调用：

conn, err := grpc.Dial(address, grpc.WithInsecure(), grpc.WithStreamInterceptor(grpc_testing.AsyncStreamClientInterceptor), grpc.WithUnaryInterceptor(grpc_testing.AsyncUnaryClientInterceptor))

然后，可以在客户端代码中使用异步调用，例如：

stream, err := client.SomeMethod(ctx)
if err != nil {
    // 处理错误
}

done := make(chan bool)
go func() {
    for {
        res, err := stream.Recv()
        if err == io.EOF {
            done <- true
            return
        }
        if err != nil {
            // 处理错误
        }
        // 处理结果
    }
}()

// 发送请求
err = stream.Send(&pb.Request{})
if err != nil {
    // 处理错误
}

// 等待异步结果
<-done

在上面的示例代码中，使用了 gRPC 的流式 API 来进行异步调用。通过使用 goroutine 来处理异步结果，可以在等待结果时继续执行其他操作。