| 限定符和类型 | 方法和说明 |
|---|---|
<T> Future<T> |
RpcClient.sendRequest(Request request,
Type responseType,
RpcCallback<T> callback,
RpcFuture rpcFuture,
boolean isFinalTry) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
Interceptor.handleRequest(Request request)
This method is called in two scenarios:
Before the client sends the request;
Before the server processes the request.
|
boolean |
CurrentLimitInterceptor.handleRequest(Request request) |
boolean |
AbstractInterceptor.handleRequest(Request request) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractRequest |
class |
HttpRequest
Bprc http request implementation, used for http protocols.
|
class |
RpcRequest
Bprc tcp request implementation, used for tcp protocols.
|
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
AbstractRequest.addRefCnt() |
Request |
Request.addRefCnt() |
Request |
HttpRequest.addRefCnt() |
Request |
AbstractProtocol.createRequest() |
Request |
Protocol.createRequest()
create a new request instance
|
Request |
Protocol.decodeRequest(Object packet)
服务端反序列化rpc请求
|
Request |
AbstractProtocol.getRequest() |
Request |
Protocol.getRequest()
get a reusable request instance from threadLocal or pool
the request instance must be reset before reuse
|
Request |
AbstractProtocol.initRequest(RpcClient rpcClient,
Map<String,RpcMethodInfo> rpcMethodMap,
Object instance,
Method method,
Object[] args) |
Request |
Protocol.initRequest(RpcClient rpcClient,
Map<String,RpcMethodInfo> rpcMethodMap,
Object instance,
Method method,
Object[] args)
初始化请求
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
AbstractProtocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture) |
void |
Protocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture)
do something if needed after server channel writeAndFlush
|
void |
AbstractProtocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup) |
void |
Protocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup)
do something if needed before client send request
|
io.netty.buffer.ByteBuf |
Protocol.encodeRequest(Request request)
客户端序列化请求对象
|
io.netty.buffer.ByteBuf |
Protocol.encodeResponse(Request request,
Response response)
服务端序列化返回结果。
|
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
HttpRpcProtocol.createRequest() |
Request |
HttpRpcProtocol.decodeRequest(Object packet) |
Request |
HttpRpcProtocol.getRequest() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
HttpRpcProtocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture) |
void |
HttpRpcProtocol.beforeRequestSent(Request request,
RpcClient rpcClient,
BrpcChannelGroup channelGroup) |
io.netty.buffer.ByteBuf |
HttpRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
HttpRpcProtocol.encodeResponse(Request request,
Response response) |
byte[] |
HttpRpcProtocol.encodeResponseBody(int protocolType,
Request request,
Response response) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
HuluRpcProtocol.decodeRequest(Object packet) |
| 限定符和类型 | 方法和说明 |
|---|---|
io.netty.buffer.ByteBuf |
HuluRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
HuluRpcProtocol.encodeResponse(Request request,
Response response) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
NSHeadRpcProtocol.decodeRequest(Object packet) |
| 限定符和类型 | 方法和说明 |
|---|---|
io.netty.buffer.ByteBuf |
NSHeadRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
NSHeadRpcProtocol.encodeResponse(Request request,
Response response) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
SofaRpcProtocol.decodeRequest(Object packet) |
| 限定符和类型 | 方法和说明 |
|---|---|
io.netty.buffer.ByteBuf |
SofaRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
SofaRpcProtocol.encodeResponse(Request request,
Response response) |
| 限定符和类型 | 方法和说明 |
|---|---|
Request |
BaiduRpcProtocol.decodeRequest(Object packet) |
| 限定符和类型 | 方法和说明 |
|---|---|
io.netty.buffer.ByteBuf |
BaiduRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
BaiduRpcProtocol.encodeResponse(Request request,
Response response) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
CurrentLimiter.isAllowable(Request request) |
boolean |
CounterCurrentLimiter.isAllowable(Request request) |
boolean |
TokenBucketCurrentLimiter.isAllowable(Request request) |
Copyright © 2019 Baidu, Inc.. All rights reserved.