import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public static ChannelHandler createDecoder(ClassResolver classResolver)
{
    CodecConfig codecConfig = GridRuntime.config().getNetworkConfig().getCodecConfig();
    String type = DEFAULT_CODEC;
    Class<? extends GridCodec> codecClass = null;
    if (codecConfig.getType() != null)
    {
        type = codecConfig.getType().toLowerCase();
        codecClass = codecConfig.getCodecClass();
    }
    if (NETTY_CODEC.equals(type))
    {
        return new ObjectDecoder(Integer.MAX_VALUE, classResolver);
    }
    if (codecMap.containsKey(type) && codecClass == null)
    {
        codecClass = codecMap.get(type);
    }
    if (codecClass == null)
        throw new GridException("Cannot find codec " + type);
    GridCodec codec = ReflectUtils.newInstance(codecClass);
    codec.initialize(codecConfig.getParameters());
    return new GridObjectDecoder(classResolver, codec);
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
@Override
protected void initChannel(SocketChannel socketChannel) throws Exception {
    socketChannel.pipeline().addLast(new ObjectEncoder());
    ClassLoader classLoader = this.getClass().getClassLoader();
    ClassResolver classResolver = ClassResolvers.weakCachingResolver(classLoader);
    socketChannel.pipeline().addLast(new ObjectDecoder(classResolver));
    socketChannel.pipeline().addLast(new ClientHandler());
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
@Override
public Object decode(InputStream in, ClassResolver classResolver) throws Exception
{
	FSTObjectInput fin = conf.getObjectInput(in);
	Object result = fin.readObject();
	in.close();
    return result;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
@Override
public Object decode(InputStream in, ClassResolver classResolver) throws Exception
{
	HessianInput hi = new HessianInput(in);
	Object result = hi.readObject();
	hi.close();
    return result;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
@Override
public Object decode(InputStream in, ClassResolver classResolver) throws Exception
{
	ObjectInputStream ois = new ObjectInputStream(in);
	Object result = ois.readObject();
	ois.close();
    return result;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
@Override
public Object decode(InputStream in, ClassResolver classResolver) throws Exception
{
	Kryo kryo = getKryo();
	Input input = new Input(in);
	Object ret = kryo.readClassAndObject(input);
	input.close();
	return ret;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public DatagramPacketObjectDecoder(ClassResolver resolver) {
    delegateDecoder = new ObjectDecoder(resolver);
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public ObjectDecoder(ClassResolver classResolver) {
    super(classResolver);
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
CompactObjectInputStream(InputStream in, ClassResolver classResolver) throws IOException {
    super(in);
    this.classResolver = classResolver;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public GridObjectDecoder(ClassResolver classResolver, GridCodec codec)
{
    this(Integer.MAX_VALUE, classResolver);
    this.codec = codec;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public JavaSerializer(ClassResolver resolver) {
    this.resolver = resolver;
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
/**
 * Creates a new decoder whose maximum object size is {@code 1048576} bytes.
 * If the size of the received object is greater than {@code 1048576} bytes,
 * a {@link StreamCorruptedException} will be raised.
 */
public StreamMessageDecoder(ClassResolver classResolver) {
    this(classResolver, 1048576);
}
 

import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public Object decode(InputStream in, ClassResolver classResolver) throws Exception;