Java，gRPC和上下文传播(Java, gRPC and Context propagation)

有没有人有客户端(存根)和服务器之间使用gRPC在java中的io.grpc.Context传播的工作示例？

我的理解是，这是不可能的，我必须使用元数据。 我对么？

在线我只找到了使用标题而不是上下文的例子。

谢谢！

Does anyone have a working example of io.grpc.Context propagation between client (stub) and server using gRPC in java?

My understanding is that it's not possible and I must use Metadata instead. Am I correct?

Online I have found only examples using Header rather than Context.

Thanks!

原文：https://stackoverflow.com/questions/49236643

更新时间：2019-12-22 15:34

最满意答案

io.grpc.Context仅用于本地传播，就像线程之间或甚至在同一线程中一样。 gRPC有目的地不会自动传播项目。 您可以使用ClientInterceptor将Context中的值复制到Metadata 。

io.grpc.Context is for local propagation only, like between threads or even on the same thread. gRPC purposefully does not propagate items from it automatically. You can use a ClientInterceptor to copy a value from the Context to the Metadata.

2018-03-13

相关问答

grpc.ServicerContext只是一个接口 ; 在您的测试代码中，您应该能够编写自己的实现并将其传递给正在测试的服务器。 确实，目前我们没有在grpc_testing提供一个grpc.ServicerContext实现，该实现已准备好供测试使用并传递给待测系统，但也不完全清楚我们可以提供一个可以简单实现且价值grpc.ServicerContext实现到大量的测试。 在测试中服务人员如何使用grpc.ServicerContext对象有一个很大的行为空间，另外还有作者编写服务器测试的另一

...

这绝对是一个网络错误。 我刚刚创建了https://github.com/netty/netty-tcnative/issues/141 ，并将着眼于减少MSVC带来的依赖项列表。 现在，尝试自己构建openssl [静态/动态]并查看它是否适合您。 This is definitely a netty-tcnative bug. I've just created https://github.com/netty/netty-tcnative/issues/141 and will be loo

...

使用gRPC流API，您一次只能写一个项目。 如果在上一个完成之前启动另一个WriteAsync()操作，则会出现异常。 您还需要在从方法处理程序返回之前完成所有写入操作(在本例中为Feed方法)。 一次只允许一次写入的原因是确保gRPC的流量控制运行良好。 在您的情况下，Rx API似乎无法确保，因此解决此问题的一种方法是使用中间缓冲区。 With the gRPC streaming API, you are only allowed to write one item at a time.

...

我认为unfoldr正是你想要的： Prelude> import Data.List(unfoldr)

Prelude Data.List> :t unfoldr

unfoldr :: (b -> Maybe (a, b)) -> b -> [a]

Prelude Data.List> let nrs = unfoldr (\n -> Just (n,n+1)) 1

Prelude Data.List> take 10 nrs

[1,2,3,4,5,6,7,8,9,10]

它的工作方式如下：

...

io.grpc.Context仅用于本地传播，就像线程之间或甚至在同一线程中一样。 gRPC有目的地不会自动传播项目。 您可以使用ClientInterceptor将Context中的值复制到Metadata 。 io.grpc.Context is for local propagation only, like between threads or even on the same thread. gRPC purposefully does not propagate items from

...

我正在读取错误的文件作为构建SslContext的证书文件。 用正确的证书文件替换错误的输入解决了问题。 I was reading the wrong file as the certificate file for building the SslContext. Replacing the incorrect input with the right certificate file fixed the issue.

提供ServerContext ，以及为您获得的每个RPC添加上下文。 它允许您调整RPC的某些方面，例如处理身份验证，或将响应中的元数据添加回客户端。 显然，您可能需要或不需要该参数，具体取决于您的需求。 我们不希望为此特别添加一个选项，因为这样会使代码和工具复杂化，所以代码生成器和函数签名会强制您始终拥有该参数。 现在这不是什么大问题，因为在C ++中，您可以特别要求编译器忽略特定实例中的参数，例如使用以下内容： Status SayHello(ServerContext* context

...

现在我懂了。 响应作为迭代器返回。 所以它应该作为迭代器处理。 Now I get it. Response is returned as an iterator. So it should be handle as iterator.

您需要ServerCall.Listener.onComplete()和ServerCall.Listener.onCancel() 。 onComplete()在ServerCall.close()成功处理后调用。 onCancel()用于任何通信错误或取消。 请注意，在应用程序调用ServerCall.close()后可以接收onCancel() ServerCall.close() 。 You want ServerCall.Listener.onComplete() and ServerC

...

我终于找到了自己的方式： https ： //github.com/grpc/grpc-go/blob/master/Documentation/grpc-metadata.md 所以基本上， grpc.SetHeader() + grpc.SendHeader()和grpc.SetTrailer()完全是我想要的。 在客户端，需要将grpc.Header()和grpc.Trailer()函数传递给RPC调用，并且它们的参数是要填充的metadata.MD对象。 在客户端，定义您的接收元数据： v

...