本文介紹了如何在GRPC攔截器中訪問消息請求？的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我想在服務器端為多個方法使用相同的攔截器
因為它們都有相同的請求類型(StateRequest)：
rpc apply (StateRequest) returns (StateResponse) {}
rpc cancel (StateRequest) returns (StateResponse) {}
rpc remove (StateRequest) returns (StateResponse) {}
rpc development (StateRequest) returns (StateResponse) {}
rpc implement (StateRequest) returns (StateResponse) {}
rpc draft (StateRequest) returns (StateResponse) {}
攔截器：
public class ServerUserRoleAuthInterceptor implements ServerInterceptor {
@Override
public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
ServerCall<ReqT, RespT> call,
Metadata headers,
ServerCallHandler<ReqT, RespT> next) {
String callName = call.getMethodDescriptor().getFullMethodName();
logger.info("Call: {}", callName);
// TODO: validate request (`StateRequest` instance)
return next.startCall(call, headers);
}
}
我該怎么做？
推薦答案
您需要在Listener上觀察onMessage(ReqT)回調。
return new SimpleForwardingServerCallListener<ReqT>(next.startCall(call, headers)) {
@Override
public void onMessage(ReqT request) {
// TODO:validate request
super.onMessage(request);
}
};
這篇關于如何在GRPC攔截器中訪問消息請求？的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
