com.baidu.brpc.protocol.http

类 HttpRpcProtocol

java.lang.Object

com.baidu.brpc.protocol.AbstractProtocol

com.baidu.brpc.protocol.http.HttpRpcProtocol

所有已实现的接口:

Protocol

public class HttpRpcProtocol
extends AbstractProtocol

处理http rpc协议，包括四种序列化格式： 1、http + protoc 2、http + json

构造器概要

构造器

构造器和说明
HttpRpcProtocol(int protocolType, String encoding)

方法概要

限定符和类型	方法和说明
protected void	addHttpHeaders(io.netty.handler.codec.http.HttpHeaders headers, io.netty.handler.codec.http.FullHttpRequest fullHttpRequest)
protected String	buildHttpUri(String serviceName, String methodName)
protected Object	decodeBody(int protocolType, String encoding, byte[] bytes)
void	decodeHttpRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest, RpcRequest rpcRequest) 根据http request生成rpc request
RpcResponse	decodeHttpResponse(io.netty.handler.codec.http.FullHttpResponse httpResponse, io.netty.channel.ChannelHandlerContext ctx) 根据http response构建rpc response
protected byte[]	encodeBody(int protocolType, String encoding, Object body, RpcMethodInfo rpcMethodInfo)
io.netty.handler.codec.http.FullHttpRequest	encodeHttpRequest(RpcRequest rpcRequest) 根据rpc request构建http request
io.netty.handler.codec.http.FullHttpResponse	encodeHttpResponse(RpcRequest rpcRequest, RpcResponse rpcResponse) 根据rpc response生成http response
static String	getContentType(Integer protocolType)
protected Object	makeRequest(int id, String methodName, Object[] args)
protected Object	parseHttpResponse(Object body, RpcMethodInfo rpcMethodInfo)
protected long	parseLogId(String headerLogId, Long channelAttachLogId)
static int	parseProtocolType(String contentType)
protected Object[]	parseRequestParam(Object body, RpcMethodInfo rpcMethodInfo)
boolean	returnChannelBeforeResponse() 连接被归还入池的时机

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

decode, decodeRequest, decodeResponse, encodeRequest, encodeResponse

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

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

构造器详细资料

HttpRpcProtocol

public HttpRpcProtocol(int protocolType,
                       String encoding)

方法详细资料

encodeHttpRequest

public io.netty.handler.codec.http.FullHttpRequest encodeHttpRequest(RpcRequest rpcRequest)
                                                              throws Exception

从接口复制的说明: Protocol

根据rpc request构建http request

指定者:

encodeHttpRequest 在接口中 Protocol

覆盖:

encodeHttpRequest 在类中 AbstractProtocol

返回:

抛出:

Exception

decodeHttpResponse

public RpcResponse decodeHttpResponse(io.netty.handler.codec.http.FullHttpResponse httpResponse,
                                      io.netty.channel.ChannelHandlerContext ctx)

从接口复制的说明: Protocol

根据http response构建rpc response

指定者:

decodeHttpResponse 在接口中 Protocol

覆盖:

decodeHttpResponse 在类中 AbstractProtocol

返回:

decodeHttpRequest

public void decodeHttpRequest(io.netty.handler.codec.http.FullHttpRequest httpRequest,
                              RpcRequest rpcRequest)

从接口复制的说明: Protocol

根据http request生成rpc request

指定者:

decodeHttpRequest 在接口中 Protocol

覆盖:

decodeHttpRequest 在类中 AbstractProtocol

encodeHttpResponse

public io.netty.handler.codec.http.FullHttpResponse encodeHttpResponse(RpcRequest rpcRequest,
                                                                       RpcResponse rpcResponse)

从接口复制的说明: Protocol

根据rpc response生成http response

指定者:

encodeHttpResponse 在接口中 Protocol

覆盖:

encodeHttpResponse 在类中 AbstractProtocol

返回:

returnChannelBeforeResponse

public boolean returnChannelBeforeResponse()

从接口复制的说明: Protocol

连接被归还入池的时机

指定者:

returnChannelBeforeResponse 在接口中 Protocol

覆盖:

returnChannelBeforeResponse 在类中 AbstractProtocol

返回:

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

parseProtocolType

public static int parseProtocolType(String contentType)

getContentType

public static String getContentType(Integer protocolType)

encodeBody

protected byte[] encodeBody(int protocolType,
                            String encoding,
                            Object body,
                            RpcMethodInfo rpcMethodInfo)

decodeBody

protected Object decodeBody(int protocolType,
                            String encoding,
                            byte[] bytes)

addHttpHeaders

protected void addHttpHeaders(io.netty.handler.codec.http.HttpHeaders headers,
                              io.netty.handler.codec.http.FullHttpRequest fullHttpRequest)

makeRequest

protected Object makeRequest(int id,
                             String methodName,
                             Object[] args)

buildHttpUri

protected String buildHttpUri(String serviceName,
                              String methodName)

parseLogId

protected long parseLogId(String headerLogId,
                          Long channelAttachLogId)

parseHttpResponse

protected Object parseHttpResponse(Object body,
                                   RpcMethodInfo rpcMethodInfo)

parseRequestParam

protected Object[] parseRequestParam(Object body,
                                     RpcMethodInfo rpcMethodInfo)