com.baidu.brpc.protocol.standard

类 BaiduRpcProtocol

java.lang.Object

com.baidu.brpc.protocol.AbstractProtocol

com.baidu.brpc.protocol.standard.BaiduRpcProtocol

所有已实现的接口:

Protocol

public class BaiduRpcProtocol
extends AbstractProtocol

Notes on Baidu RPC Protocol:

• Header format is ["PRPC"][body_size][meta_size ], 12 bytes in total
• body_size and meta_size are in network byte order (big endian)
• Use service->full_name() and method_name to identify the service and method to call
• attachment_size is set iff request/response has attachment
• The following fields of rpc are not supported yet:
  • chunk_info

Created by huwenwei on 2017/9/22.

构造器概要

构造器

构造器和说明
BaiduRpcProtocol()

方法概要

限定符和类型	方法和说明
BaiduRpcDecodePacket	decode(DynamicCompositeByteBuf in) 客户端/服务端解析请求包成header+body buffer
void	decodeRequest(Object packet, RpcRequest rpcRequest) 服务端反序列化rpc请求
RpcResponse	decodeResponse(Object packet, io.netty.channel.ChannelHandlerContext ctx) 客户端反序列化rpc响应
protected io.netty.buffer.ByteBuf	encode(BaiduRpcEncodePacket packet)
io.netty.buffer.ByteBuf	encodeRequest(RpcRequest rpcRequest) 客户端序列化请求对象
io.netty.buffer.ByteBuf	encodeResponse(RpcResponse rpcResponse) 服务端序列化返回结果。

从类继承的方法 com.baidu.brpc.protocol.AbstractProtocol

decodeHttpRequest, decodeHttpResponse, encodeHttpRequest, encodeHttpResponse, returnChannelBeforeResponse

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

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

构造器详细资料

BaiduRpcProtocol

public BaiduRpcProtocol()

方法详细资料

encodeRequest

public io.netty.buffer.ByteBuf encodeRequest(RpcRequest rpcRequest)
                                      throws Exception

从接口复制的说明: Protocol

客户端序列化请求对象

指定者:

encodeRequest 在接口中 Protocol

覆盖:

encodeRequest 在类中 AbstractProtocol

参数:

rpcRequest - 待发送给服务端的对象

抛出:

Exception - 序列化异常

decodeResponse

public RpcResponse decodeResponse(Object packet,
                                  io.netty.channel.ChannelHandlerContext ctx)
                           throws Exception

从接口复制的说明: Protocol

客户端反序列化rpc响应

指定者:

decodeResponse 在接口中 Protocol

覆盖:

decodeResponse 在类中 AbstractProtocol

参数:

packet - header & body的buf

ctx - netty channel context

抛出:

Exception - 反序列化异常

decode

public BaiduRpcDecodePacket decode(DynamicCompositeByteBuf in)
                            throws BadSchemaException,
                                   TooBigDataException,
                                   NotEnoughDataException

从接口复制的说明: Protocol

客户端/服务端解析请求包成header+body buffer

指定者:

decode 在接口中 Protocol

覆盖:

decode 在类中 AbstractProtocol

参数:

in - 输入byte buf

返回:

header+body buffer

抛出:

BadSchemaException - header格式不对

TooBigDataException - body太大

NotEnoughDataException - 可读长度不够，由于粘包拆包问题。

decodeRequest

public void decodeRequest(Object packet,
                          RpcRequest rpcRequest)
                   throws Exception

从接口复制的说明: Protocol

服务端反序列化rpc请求

指定者:

decodeRequest 在接口中 Protocol

覆盖:

decodeRequest 在类中 AbstractProtocol

参数:

packet - header & body的buf

抛出:

Exception

encodeResponse

public io.netty.buffer.ByteBuf encodeResponse(RpcResponse rpcResponse)
                                       throws Exception

从接口复制的说明: Protocol

服务端序列化返回结果。

指定者:

encodeResponse 在接口中 Protocol

覆盖:

encodeResponse 在类中 AbstractProtocol

参数:

rpcResponse - 服务端要返回给客户端的对象

抛出:

Exception - 序列化异常

encode

protected io.netty.buffer.ByteBuf encode(BaiduRpcEncodePacket packet)
                                  throws Exception

抛出:

Exception