程序包 org.apache.dubbo.rpc.protocol.tri

类 TripleUtil

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.TripleUtil

public class TripleUtil
extends Object

字段概要

字段

修饰符和类型	字段	说明
static io.netty.util.AttributeKey<AbstractClientStream>	CLIENT_STREAM_KEY
static io.netty.util.AttributeKey<AbstractServerStream>	SERVER_STREAM_KEY

构造器概要

构造器

构造器	说明
TripleUtil()

方法概要

修饰符和类型	方法	说明
static String	convertHessianFromWrapper(String serializeType)
static String	convertHessianToWrapper(String serializeType)
static byte[]	decodeASCIIByte(CharSequence value)
static Object	decodeObjFromHeader(URL url, CharSequence value, MultipleSerialization serialization)
static byte[]	encodeBase64(byte[] in)
static String	encodeBase64ASCII(byte[] in)
static String	encodeWrapper(URL url, Object obj, String serializeType, MultipleSerialization serialization)
static AbstractClientStream	getClientStream(io.netty.channel.ChannelHandlerContext ctx)
static AbstractServerStream	getServerStream(io.netty.channel.ChannelHandlerContext ctx)
static byte[]	pack(Object obj)
static void	responseErr(io.netty.channel.ChannelHandlerContext ctx, GrpcStatus status)
static void	responsePlainTextError(io.netty.channel.ChannelHandlerContext ctx, int code, GrpcStatus status)
static boolean	supportContentType(String contentType)	must starts from application/grpc
static <T> T	unpack(byte[] data, Class<T> clz)
static <T> T	unpack(InputStream is, Class<T> clz)
static Object[]	unwrapReq(URL url, TripleWrapper.TripleRequestWrapper wrap, MultipleSerialization multipleSerialization)
static Object	unwrapResp(URL url, TripleWrapper.TripleResponseWrapper wrap, MultipleSerialization serialization)
static TripleWrapper.TripleRequestWrapper	wrapReq(URL url, String serializeType, Object req, String type, MultipleSerialization multipleSerialization)
static TripleWrapper.TripleRequestWrapper	wrapReq(URL url, RpcInvocation invocation, MultipleSerialization serialization)
static TripleWrapper.TripleResponseWrapper	wrapResp(URL url, String serializeType, Object resp, MethodDescriptor desc, MultipleSerialization multipleSerialization)

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

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

字段详细资料

SERVER_STREAM_KEY

public static final io.netty.util.AttributeKey<AbstractServerStream> SERVER_STREAM_KEY

CLIENT_STREAM_KEY

public static final io.netty.util.AttributeKey<AbstractClientStream> CLIENT_STREAM_KEY

构造器详细资料

TripleUtil

public TripleUtil()

方法详细资料

getServerStream

public static AbstractServerStream getServerStream(io.netty.channel.ChannelHandlerContext ctx)

getClientStream

public static AbstractClientStream getClientStream(io.netty.channel.ChannelHandlerContext ctx)

supportContentType

public static boolean supportContentType(String contentType)

must starts from application/grpc

responseErr

public static void responseErr(io.netty.channel.ChannelHandlerContext ctx,
                               GrpcStatus status)

responsePlainTextError

public static void responsePlainTextError(io.netty.channel.ChannelHandlerContext ctx,
                                          int code,
                                          GrpcStatus status)

unwrapResp

public static Object unwrapResp(URL url,
                                TripleWrapper.TripleResponseWrapper wrap,
                                MultipleSerialization serialization)

unwrapReq

public static Object[] unwrapReq(URL url,
                                 TripleWrapper.TripleRequestWrapper wrap,
                                 MultipleSerialization multipleSerialization)

wrapResp

public static TripleWrapper.TripleResponseWrapper wrapResp(URL url,
                                                           String serializeType,
                                                           Object resp,
                                                           MethodDescriptor desc,
                                                           MultipleSerialization multipleSerialization)

wrapReq

public static TripleWrapper.TripleRequestWrapper wrapReq(URL url,
                                                         String serializeType,
                                                         Object req,
                                                         String type,
                                                         MultipleSerialization multipleSerialization)

wrapReq

public static TripleWrapper.TripleRequestWrapper wrapReq(URL url,
                                                         RpcInvocation invocation,
                                                         MultipleSerialization serialization)

unpack

public static <T> T unpack(byte[] data,
                           Class<T> clz)

unpack

public static <T> T unpack(InputStream is,
                           Class<T> clz)

pack

public static byte[] pack(Object obj)

encodeWrapper

public static String encodeWrapper(URL url,
                                   Object obj,
                                   String serializeType,
                                   MultipleSerialization serialization)
                            throws IOException

抛出:

IOException

encodeBase64ASCII

public static String encodeBase64ASCII(byte[] in)

encodeBase64

public static byte[] encodeBase64(byte[] in)

decodeObjFromHeader

public static Object decodeObjFromHeader(URL url,
                                         CharSequence value,
                                         MultipleSerialization serialization)
                                  throws com.google.protobuf.InvalidProtocolBufferException

抛出:

com.google.protobuf.InvalidProtocolBufferException

decodeASCIIByte

public static byte[] decodeASCIIByte(CharSequence value)

convertHessianToWrapper

public static String convertHessianToWrapper(String serializeType)

convertHessianFromWrapper

public static String convertHessianFromWrapper(String serializeType)