ProtoBuf gRPC分析请求头怎么配置

今天小编给大家分享一下ProtoBuf gRPC分析请求头怎么配置的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。

ProtoBuf + gRPC 分析请求头

概念

Protobuf是Google protocol buffer的简称，是一种语言中立、平台无关、易于扩展的结构化数据序列化技术，可用于数据传输、存储等领域。 与Protoful类似的序列化技术还有XML、JSON、Thrift等，但Protoful更快、更小、更简单，且具备良好的兼容性。

目前经常运用在 安卓直播弹幕等业务场景中

配置请求头

方法1

只设置客户端请求时附带的header

类 io.grpc.stub.MetadataUtils，其中有个方法

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/1789")  public static > T attachHeaders(      T stub,      final Metadata extraHeaders) {    return stub.withInterceptors(newAttachHeadersInterceptor(extraHeaders));  }

**
自己封装后

private static > T attachHeaders(T stub, final Map headerMap) {    Metadata extraHeaders = new Metadata();    if (headerMap != null) {        for (String key : headerMap.keySet()) {            Metadata.Key customHeadKey = Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER);            extraHeaders.put(customHeadKey, headerMap.get(key));        }    }    return MetadataUtils.attachHeaders(stub, extraHeaders);}

**

方法2

支持设置客户端请求的header以及获取服务端返回结果中的header

• 官方demo

• 官方完整Demo

1. 设置拦截器

class HeaderClientInterceptor implements ClientInterceptor {    private static final String TAG = "HeaderClientInterceptor";    private Map mHeaderMap;    public HeaderClientInterceptor(Map headerMap) {        mHeaderMap = headerMap;    }    @Override    public  ClientCall interceptCall(MethodDescriptor method,                                                               CallOptions callOptions, Channel next) {        return new SimpleForwardingClientCall(next.newCall(method, callOptions)) {            @Override            public void start(Listener responseListener, Metadata headers) {                /* put custom header */                if (mHeaderMap != null) {                    for (String key : mHeaderMap.keySet()) {                        Metadata.Key customHeadKey = Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER);                        headers.put(customHeadKey, mHeaderMap.get(key));                    }                }                Logger.i(TAG, "header send to server:" + headers);                super.start(new SimpleForwardingClientCallListener(responseListener) {                    @Override                    public void onHeaders(Metadata headers) {                        /**                         * if you don't need receive header from server,                         * you can use {@link io.grpc.stub.MetadataUtils attachHeaders}                         * directly to send header                         */                        Logger.i(TAG, "header received from server:" + headers);                        super.onHeaders(headers);                    }                }, headers);            }        };    }}

_

2. 使用

Map headerMap = new HashMap<>();//...ClientInterceptor interceptor = new HeaderClientInterceptor(headerMap);//...ManagedChannel managedChannel = ManagedChannelBuilder.forAddress(host, port).usePlaintext(true).build();Channel channel = ClientInterceptors.intercept(managedChannel, interceptor);// then create stub here by this channel

**

所以

要实现添加header 那么必须实现 ClientInterceptor 接口类中的 interceptCall 的方法

• 而且还要有一个 添加Header的具体方法

• 不管 grpc 怎么混淆都离不开这种配置模式

例如这种
注意他们的类型，很明显这种情况可以快速推论

• z1.c.v.p.a.d.b.f.a.a() 大概率就是混淆后的 interceptCall

• z1.c.v.p.a.d.b.f.a.c() 是添加请求头的函数

以上就是"ProtoBuf gRPC分析请求头怎么配置"这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注行业资讯频道。