gRPC Java 服务器：有没有办法获取从客户端收到的原始消息字节？

debugcn 发表于 Dev

塞尔吉·弗拉迪金

由于 Protobuf 消息序列化格式不是跨平台和软件版本的确定性，仅使用toByteArray()方法将消息序列化回来不一定会产生原始字节。有没有其他方法可以使用 gRPC Java 服务器访问它们？

塞尔吉·弗拉迪金

看起来正确的方法是使用服务器拦截器：

ServerBuilder.forPort(port)
        .addService(
            ServerInterceptors.intercept(
                ServerInterceptors.useInputStreamMessages(
                    new MyMegaCoolService().bindService()
                ),
                new ServerInterceptor() {
                    @Override public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
                        ServerCall<ReqT,RespT> call,
                        Metadata headers,
                        ServerCallHandler<ReqT,RespT> next
                    ) {
                        ServerCall.Listener<ReqT> listener = next.startCall(call, headers);
                        return new ForwardingServerCallListener
                            .SimpleForwardingServerCallListener<ReqT>(listener) {
                            @Override public void onMessage(ReqT msg) {
                                InputStream in = (InputStream)msg;

                                assert in.markSupported();
                                in.mark(MAX_MESSAGE_SIZE);

                                readMessage(in);

                                try {
                                    in.reset();
                                }
                                catch (IOException e) {
                                    throw new IllegalStateException(e);
                                }

                                super.onMessage(msg);
                            }
                        };
                    }
                }
            )
        )
        .build();

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。