com.baidu.brpc.protocol.dubbo

Class DubboRpcProtocol

java.lang.Object

com.baidu.brpc.protocol.AbstractProtocol

com.baidu.brpc.protocol.dubbo.DubboRpcProtocol

All Implemented Interfaces:

Protocol

public class DubboRpcProtocol
extends AbstractProtocol

dubbo protocol with hession2 serialization

Field Summary

Fields

Modifier and Type	Field and Description
protected static byte	FLAG_EVENT
protected static byte	FLAG_REQUEST
protected static byte	FLAG_TWOWAY

Constructor Summary

Constructors

Constructor and Description
DubboRpcProtocol()

Method Summary

Modifier and Type	Method and Description
Object	decode(io.netty.channel.ChannelHandlerContext ctx, DynamicCompositeByteBuf in, boolean isDecodingRequest) 客户端/服务端解析请求包成header+body buffer
Request	decodeRequest(Object packet) 服务端反序列化rpc请求
Response	decodeResponse(Object msg, io.netty.channel.ChannelHandlerContext ctx) 客户端反序列化rpc响应
io.netty.buffer.ByteBuf	encodeRequest(Request request) 客户端序列化请求对象
io.netty.buffer.ByteBuf	encodeResponse(Request request, Response response) 服务端序列化返回结果。
protected byte	getContentTypeId()
boolean	supportHeartbeat() check if the protocol supports heartbeat packet

Methods inherited from class com.baidu.brpc.protocol.AbstractProtocol

afterResponseSent, createRequest, createResponse, getRequest, getResponse, isCoexistence, returnChannelBeforeResponse

Methods inherited from class java.lang.Object

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

Field Detail

FLAG_REQUEST

protected static final byte FLAG_REQUEST

See Also:

Constant Field Values

FLAG_TWOWAY

protected static final byte FLAG_TWOWAY

See Also:

Constant Field Values

FLAG_EVENT

protected static final byte FLAG_EVENT

See Also:

Constant Field Values

Constructor Detail

DubboRpcProtocol

public DubboRpcProtocol()

Method Detail

decode

public Object decode(io.netty.channel.ChannelHandlerContext ctx,
                     DynamicCompositeByteBuf in,
                     boolean isDecodingRequest)
              throws TooBigDataException,
                     NotEnoughDataException,
                     BadSchemaException

Description copied from interface: Protocol

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

in - 输入byte buf

Returns:

header+body buffer

Throws:

TooBigDataException - body太大

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

BadSchemaException - header格式不对

encodeRequest

public io.netty.buffer.ByteBuf encodeRequest(Request request)
                                      throws Exception

Description copied from interface: Protocol

客户端序列化请求对象

Parameters:

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

Throws:

Exception - 序列化异常

decodeResponse

public Response decodeResponse(Object msg,
                               io.netty.channel.ChannelHandlerContext ctx)
                        throws Exception

Description copied from interface: Protocol

客户端反序列化rpc响应

Parameters:

msg - header & body的buf

ctx - netty channel context

Throws:

Exception - 反序列化异常

decodeRequest

public Request decodeRequest(Object packet)
                      throws Exception

Description copied from interface: Protocol

服务端反序列化rpc请求

Parameters:

packet - header & body的buf

Throws:

Exception

encodeResponse

public io.netty.buffer.ByteBuf encodeResponse(Request request,
                                              Response response)
                                       throws Exception

Description copied from interface: Protocol

服务端序列化返回结果。

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

Throws:

Exception - 序列化异常

supportHeartbeat

public boolean supportHeartbeat()

Description copied from interface: Protocol

check if the protocol supports heartbeat packet

Specified by:

supportHeartbeat in interface Protocol

Overrides:

supportHeartbeat in class AbstractProtocol

getContentTypeId

protected byte getContentTypeId()