| 限定符和类型 | 方法和说明 |
|---|---|
<T> Future<T> |
RpcClient.sendRequest(RpcRequest rpcRequest,
Type responseType,
RpcCallback<T> callback) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
Interceptor.handleRequest(RpcRequest rpcRequest)
This method is called in two scenarios:
Before the client sends the request;
Before the server processes the request.
|
boolean |
CurrentLimitInterceptor.handleRequest(RpcRequest request) |
boolean |
AbstractInterceptor.handleRequest(RpcRequest request) |
| 限定符和类型 | 方法和说明 |
|---|---|
RpcRequest |
RpcRequest.addRefCnt() |
static RpcRequest |
RpcRequest.getRpcRequest() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
AbstractProtocol.decodeHttpRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest,
RpcRequest rpcRequest) |
void |
Protocol.decodeHttpRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest,
RpcRequest rpcRequest)
根据http request生成rpc request
|
void |
AbstractProtocol.decodeRequest(Object packet,
RpcRequest rpcRequest) |
void |
Protocol.decodeRequest(Object packet,
RpcRequest rpcRequest)
服务端反序列化rpc请求
|
io.netty.handler.codec.http.FullHttpRequest |
AbstractProtocol.encodeHttpRequest(RpcRequest rpcRequest) |
io.netty.handler.codec.http.FullHttpRequest |
Protocol.encodeHttpRequest(RpcRequest rpcRequest)
根据rpc request构建http request
|
io.netty.handler.codec.http.FullHttpResponse |
AbstractProtocol.encodeHttpResponse(RpcRequest rpcRequest,
RpcResponse rpcResponse) |
io.netty.handler.codec.http.FullHttpResponse |
Protocol.encodeHttpResponse(RpcRequest rpcRequest,
RpcResponse rpcResponse)
根据rpc response生成http response
|
io.netty.buffer.ByteBuf |
AbstractProtocol.encodeRequest(RpcRequest rpcRequest) |
io.netty.buffer.ByteBuf |
Protocol.encodeRequest(RpcRequest rpcRequest)
客户端序列化请求对象
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
HttpRpcProtocol.decodeHttpRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest,
RpcRequest rpcRequest) |
io.netty.handler.codec.http.FullHttpRequest |
HttpRpcProtocol.encodeHttpRequest(RpcRequest rpcRequest) |
io.netty.handler.codec.http.FullHttpResponse |
HttpRpcProtocol.encodeHttpResponse(RpcRequest rpcRequest,
RpcResponse rpcResponse) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
HuluRpcProtocol.decodeRequest(Object packet,
RpcRequest rpcRequest) |
io.netty.buffer.ByteBuf |
HuluRpcProtocol.encodeRequest(RpcRequest rpcRequest) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
NSHeadRpcProtocol.decodeRequest(Object in,
RpcRequest request) |
io.netty.buffer.ByteBuf |
NSHeadRpcProtocol.encodeRequest(RpcRequest request) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
SofaRpcProtocol.decodeRequest(Object packet,
RpcRequest rpcRequest) |
io.netty.buffer.ByteBuf |
SofaRpcProtocol.encodeRequest(RpcRequest rpcRequest) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
BaiduRpcProtocol.decodeRequest(Object packet,
RpcRequest rpcRequest) |
io.netty.buffer.ByteBuf |
BaiduRpcProtocol.encodeRequest(RpcRequest rpcRequest) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
CurrentLimiter.isAllowable(RpcRequest request) |
boolean |
CounterCurrentLimiter.isAllowable(RpcRequest request) |
boolean |
TokenBucketCurrentLimiter.isAllowable(RpcRequest request) |
Copyright © 2018 Baidu, Inc.. All rights reserved.