上下文数据 / Bean 的作用域
本节描述您如何保存请求上下文数据 / 每个请求的数据。
目录
附加主题
警告语
在 grpc-java 中，消息发送 / 请求处理中的不同阶段可能在不同的线程中运行。 流式调用中也是这样。 避免在 ServerIntercetor 和 grpc 服务方法实现中(在整个 gRPC 上下文中)使用 ThreadLocal。 归根到底来说，每个单个信息都可能会在不同的线程中运行。 如果您想要在会话中存储数据，请使用 grpc 的 Context 或 grpcRequest 作用域。
grpcRequest 作用域
该项目添加了一个grpcRequest，该功能类似于 Spring Web 的request 作用域。 它只适用于单个的请求。
首先需要用 @Scope 注解定义 Bean：
@Bean
@Scope(scopeName = "grpcRequest", proxyMode = ScopedProxyMode.TARGET_CLASS)
//@Scope(scopeName = GrpcRequestScope.GRPC_REQUEST_SCOPE_NAME, proxyMode = ScopedProxyMode.TARGET_CLASS)
ScopedBean myScopedBean() {
return new ScopedBean();
}
proxyMode = TARGET_CLASS是必须的，除非在另一个grpcRequest作用域中配置了它. 请注意，这个proxyMode不适用于 final 修饰的类和方法。
之后，您就可以像以前那样使用 Bean：
@Autowired
private ScopedBean myScopedBean;
@Override
public void grpcMethod(Request request, StreamObserver<Response> responseObserver) {
responseObserver.onNext(myScopedBean.magic(request));
responseObserver.onCompleted();
}