| Modifier and Type | Field and Description |
|---|---|
protected Request |
RpcFuture.request |
| Modifier and Type | Method and Description |
|---|---|
static RpcFuture |
RpcFuture.createRpcFuture(Request request) |
void |
CommunicationClient.execute(Request request,
Response response) |
void |
InterceptCommunicationClient.executeChain(Request request,
Response response) |
void |
CommunicationClient.executeChain(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientTraceInterceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain) |
void |
AbstractInterceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain) |
void |
ServerInvokeInterceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain) |
void |
ServerTraceInterceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain) |
void |
Interceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain)
The around intercept for RPC methods.
|
void |
ClientInvokeInterceptor.aroundProcess(Request request,
Response response,
InterceptorChain chain) |
boolean |
ClientTraceInterceptor.handleRequest(Request request) |
boolean |
AbstractInterceptor.handleRequest(Request request) |
boolean |
ServerTraceInterceptor.handleRequest(Request request) |
boolean |
Interceptor.handleRequest(Request request)
This method is called in two scenarios:
Before the client sends the request;
Before the server processes the request.
|
void |
InterceptorChain.intercept(Request request,
Response response) |
void |
DefaultInterceptorChain.intercept(Request request,
Response response) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractRequest |
class |
HttpRequest
Bprc http request implementation, used for http protocols.
|
class |
RpcRequest
Bprc tcp request implementation, used for tcp protocols.
|
| Modifier and Type | Method and Description |
|---|---|
Request |
Protocol.createRequest()
create a new request instance
|
Request |
AbstractProtocol.createRequest() |
Request |
Protocol.decodeRequest(Object packet)
服务端反序列化rpc请求
|
Request |
Protocol.getRequest()
get a reusable request instance from threadLocal or pool
the request instance must be reset before reuse
|
Request |
AbstractProtocol.getRequest() |
Request |
HttpRequest.retain() |
Request |
Request.retain() |
Request |
AbstractRequest.retain() |
| Modifier and Type | Method and Description |
|---|---|
void |
Protocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture)
do something if needed after server channel writeAndFlush
|
void |
AbstractProtocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture) |
io.netty.buffer.ByteBuf |
Protocol.encodeRequest(Request request)
客户端序列化请求对象
|
io.netty.buffer.ByteBuf |
Protocol.encodeResponse(Request request,
Response response)
服务端序列化返回结果。
|
| Modifier and Type | Method and Description |
|---|---|
Request |
DubboRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
DubboRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
DubboRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
HttpRpcProtocol.createRequest() |
Request |
HttpRpcProtocol.decodeRequest(Object packet) |
Request |
HttpRpcProtocol.getRequest() |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpRpcProtocol.addHostHeader(Request request) |
void |
HttpRpcProtocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture) |
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) |
| Modifier and Type | Method and Description |
|---|---|
Request |
HuluRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
HuluRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
HuluRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
NSHeadRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
NSHeadRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
NSHeadRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
PublicPbrpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
PublicPbrpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
PublicPbrpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
DefaultServerPushProtocol.createRequest() |
Request |
DefaultServerPushProtocol.decodeRequest(Object packet) |
Request |
DefaultServerPushProtocol.getRequest() |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultServerPushProtocol.afterResponseSent(Request request,
Response response,
io.netty.channel.ChannelFuture channelFuture) |
void |
DefaultServerPushProtocol.decodeRequestBody(SPBody body,
Request request) |
io.netty.buffer.ByteBuf |
DefaultServerPushProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
DefaultServerPushProtocol.encodeRequestBody(Request request,
RpcMethodInfo rpcMethodInfo) |
io.netty.buffer.ByteBuf |
DefaultServerPushProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
SofaRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
SofaRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
SofaRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
BaiduRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
BaiduRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
BaiduRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
Request |
StargateRpcProtocol.decodeRequest(Object packet) |
| Modifier and Type | Method and Description |
|---|---|
io.netty.buffer.ByteBuf |
StargateRpcProtocol.encodeRequest(Request request) |
io.netty.buffer.ByteBuf |
StargateRpcProtocol.encodeResponse(Request request,
Response response) |
| Modifier and Type | Method and Description |
|---|---|
void |
InterceptCommunicationServer.execute(Request request,
Response response) |
void |
CommunicationServer.execute(Request request,
Response response) |
void |
BrpcPushProxy.executeWithRetry(Request request,
Response response) |
protected void |
BrpcPushProxy.pushCore(Request request,
Response response) |
protected io.netty.channel.Channel |
BrpcPushProxy.selectChannel(Request request) |
<T> AsyncAwareFuture<T> |
CommunicationServer.sendServerPush(Request request) |
Copyright © 2022 Baidu, Inc.. All rights reserved.