public class SofaRpcProtocol extends AbstractProtocol
meta_size]
[body_size(64)][message_size(64)],
24 bytes in total
body_size and meta_size are NOT in
network byte order (little endian)
notEnoughDataException| Constructor and Description |
|---|
SofaRpcProtocol() |
| Modifier and Type | Method and Description |
|---|---|
SofaRpcDecodePacket |
decode(io.netty.channel.ChannelHandlerContext ctx,
DynamicCompositeByteBuf in,
boolean isDecodingRequest)
客户端/服务端解析请求包成header+body buffer
|
Request |
decodeRequest(Object packet)
服务端反序列化rpc请求
|
RpcResponse |
decodeResponse(Object packet,
io.netty.channel.ChannelHandlerContext ctx)
客户端反序列化rpc响应
|
protected io.netty.buffer.ByteBuf |
encode(SofaRpcEncodePacket packet) |
io.netty.buffer.ByteBuf |
encodeRequest(Request request)
客户端序列化请求对象
|
io.netty.buffer.ByteBuf |
encodeResponse(Request request,
Response response)
服务端序列化返回结果。
|
protected SofaRpcProto.SofaCompressType |
getSofaCompressType(int compressType) |
protected int |
getStandardCompressType(SofaRpcProto.SofaCompressType sofaCompressType) |
boolean |
isCoexistence()
该协议是否可以和其他协议共存。
|
afterResponseSent, createRequest, createResponse, getRequest, getResponse, returnChannelBeforeResponse, supportHeartbeatpublic SofaRpcDecodePacket decode(io.netty.channel.ChannelHandlerContext ctx, DynamicCompositeByteBuf in, boolean isDecodingRequest) throws BadSchemaException, TooBigDataException, NotEnoughDataException
Protocolin - 输入byte bufBadSchemaException - header格式不对TooBigDataException - body太大NotEnoughDataException - 可读长度不够，由于粘包拆包问题。public io.netty.buffer.ByteBuf encodeRequest(Request request) throws Exception
Protocolrequest - 待发送给服务端的对象Exception - 序列化异常public RpcResponse decodeResponse(Object packet, io.netty.channel.ChannelHandlerContext ctx) throws Exception
Protocolpacket - header & body的bufctx - netty channel contextException - 反序列化异常public Request decodeRequest(Object packet) throws Exception
Protocolpacket - header & body的bufExceptionpublic io.netty.buffer.ByteBuf encodeResponse(Request request, Response response) throws Exception
Protocolresponse - 服务端要返回给客户端的对象Exception - 序列化异常public boolean isCoexistence()
ProtocolisCoexistence in interface ProtocolisCoexistence in class AbstractProtocolprotected io.netty.buffer.ByteBuf encode(SofaRpcEncodePacket packet) throws Exception
Exceptionprotected SofaRpcProto.SofaCompressType getSofaCompressType(int compressType)
protected int getStandardCompressType(SofaRpcProto.SofaCompressType sofaCompressType)
Copyright © 2020 Baidu, Inc.. All rights reserved.