今天小编给大家分享一下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. 使用
MapheaderMap = 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()大概率就是混淆后的interceptCallz1.c.v.p.a.d.b.f.a.c()是添加请求头的函数
以上就是“ProtoBuf gRPC分析请求头怎么配置”这篇文章的所有内容,感谢各位的阅读!相信大家阅读完这篇文章都有很大的收获,小编每天都会为大家更新不同的知识,如果还想学习更多的知识,请关注创新互联行业资讯频道。
当前题目:ProtoBufgRPC分析请求头怎么配置
当前网址:http://www.jxjierui.cn/article/pcjose.html


咨询
建站咨询
