类 TripleUtil
- java.lang.Object
-
- org.apache.dubbo.rpc.protocol.tri.TripleUtil
-
public class TripleUtil extends Object
-
-
字段概要
字段 修饰符和类型 字段 说明 static io.netty.util.AttributeKey<AbstractClientStream>CLIENT_STREAM_KEYstatic io.netty.util.AttributeKey<AbstractServerStream>SERVER_STREAM_KEY
-
构造器概要
构造器 构造器 说明 TripleUtil()
-
方法概要
所有方法 静态方法 具体方法 修饰符和类型 方法 说明 static StringconvertHessianFromWrapper(String serializeType)static StringconvertHessianToWrapper(String serializeType)static byte[]decodeASCIIByte(CharSequence value)static ObjectdecodeObjFromHeader(URL url, CharSequence value, MultipleSerialization serialization)static byte[]encodeBase64(byte[] in)static StringencodeBase64ASCII(byte[] in)static StringencodeWrapper(URL url, Object obj, String serializeType, MultipleSerialization serialization)static AbstractClientStreamgetClientStream(io.netty.channel.ChannelHandlerContext ctx)static AbstractServerStreamgetServerStream(io.netty.channel.ChannelHandlerContext ctx)static byte[]pack(Object obj)static voidresponseErr(io.netty.channel.ChannelHandlerContext ctx, GrpcStatus status)static voidresponsePlainTextError(io.netty.channel.ChannelHandlerContext ctx, int code, GrpcStatus status)static booleansupportContentType(String contentType)must starts from application/grpcstatic <T> Tunpack(byte[] data, Class<T> clz)static <T> Tunpack(InputStream is, Class<T> clz)static Object[]unwrapReq(URL url, TripleWrapper.TripleRequestWrapper wrap, MultipleSerialization multipleSerialization)static ObjectunwrapResp(URL url, TripleWrapper.TripleResponseWrapper wrap, MultipleSerialization serialization)static TripleWrapper.TripleRequestWrapperwrapReq(URL url, String serializeType, Object req, String type, MultipleSerialization multipleSerialization)static TripleWrapper.TripleRequestWrapperwrapReq(URL url, RpcInvocation invocation, MultipleSerialization serialization)static TripleWrapper.TripleResponseWrapperwrapResp(URL url, String serializeType, Object resp, MethodDescriptor desc, MultipleSerialization multipleSerialization)
-
-
-
字段详细资料
-
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
-
-
方法详细资料
-
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)
-
-