com.baidu.brpc.protocol

类 AbstractProtocol

java.lang.Object

com.baidu.brpc.protocol.AbstractProtocol

所有已实现的接口:

Protocol

直接已知子类:

BaiduRpcProtocol, HttpRpcProtocol, HuluRpcProtocol, NSHeadRpcProtocol, SofaRpcProtocol

public abstract class AbstractProtocol
extends Object
implements Protocol

An abstract protocol used to simplify tcp protocol implementations. Http protocol implementations extended this class need to override most methods, or implements Protocol interface directly.

字段概要

字段

限定符和类型	字段和说明
protected static NotEnoughDataException	notEnoughDataException

构造器概要

构造器

构造器和说明
AbstractProtocol()

方法概要

限定符和类型	方法和说明
void	afterResponseSent(Request request, Response response, io.netty.channel.ChannelFuture channelFuture) do something if needed after server channel writeAndFlush
void	beforeRequestSent(Request request, RpcClient rpcClient, BrpcChannelGroup channelGroup) do something if needed before client send request
Request	createRequest() create a new request instance
Response	createResponse() create a new response instance
Request	getRequest() get a reusable request instance from threadLocal or pool the request instance must be reset before reuse
Response	getResponse() get a reusable response instance from threadLocal or pool the response instance must be reset before reuse
Request	initRequest(RpcClient rpcClient, Map<String,RpcMethodInfo> rpcMethodMap, Object instance, Method method, Object[] args) 初始化请求
boolean	returnChannelBeforeResponse() 连接被归还入池的时机

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.baidu.brpc.protocol.Protocol

decode, decodeRequest, decodeResponse, encodeRequest, encodeResponse

字段详细资料

notEnoughDataException

protected static NotEnoughDataException notEnoughDataException

构造器详细资料

AbstractProtocol

public AbstractProtocol()

方法详细资料

createRequest

public Request createRequest()

从接口复制的说明: Protocol

create a new request instance

指定者:

createRequest 在接口中 Protocol

createResponse

public Response createResponse()

从接口复制的说明: Protocol

create a new response instance

指定者:

createResponse 在接口中 Protocol

getRequest

public Request getRequest()

从接口复制的说明: Protocol

get a reusable request instance from threadLocal or pool the request instance must be reset before reuse

指定者:

getRequest 在接口中 Protocol

getResponse

public Response getResponse()

从接口复制的说明: Protocol

get a reusable response instance from threadLocal or pool the response instance must be reset before reuse

指定者:

getResponse 在接口中 Protocol

initRequest

public Request initRequest(RpcClient rpcClient,
                           Map<String,RpcMethodInfo> rpcMethodMap,
                           Object instance,
                           Method method,
                           Object[] args)

从接口复制的说明: Protocol

初始化请求

指定者:

initRequest 在接口中 Protocol

参数:

rpcClient - 客户端

rpcMethodMap - rpc方法元信息

instance - 调用者实例

method - 被调用的方法

args - 方法参数

返回:

rpc请求实例

beforeRequestSent

public void beforeRequestSent(Request request,
                              RpcClient rpcClient,
                              BrpcChannelGroup channelGroup)

从接口复制的说明: Protocol

do something if needed before client send request

指定者:

beforeRequestSent 在接口中 Protocol

returnChannelBeforeResponse

public boolean returnChannelBeforeResponse()

从接口复制的说明: Protocol

连接被归还入池的时机

指定者:

returnChannelBeforeResponse 在接口中 Protocol

返回:

true代表请求发送后立即归还连接，无需等待响应

afterResponseSent

public void afterResponseSent(Request request,
                              Response response,
                              io.netty.channel.ChannelFuture channelFuture)

从接口复制的说明: Protocol

do something if needed after server channel writeAndFlush

指定者:

afterResponseSent 在接口中 Protocol

channelFuture - the return value of writeAndFlush