本文整理汇总了Java中io.netty.handler.codec.serialization.ClassResolver类的典型用法代码示例。如果您正苦于以下问题:Java ClassResolver类的具体用法?Java ClassResolver怎么用?Java ClassResolver使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ClassResolver类属于io.netty.handler.codec.serialization包,在下文中一共展示了ClassResolver类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createDecoder
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);
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:25,代码来源:CodecFactory.java
示例2: initChannel
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());
}
开发者ID:Exslims,项目名称:MercuryTrade,代码行数:9,代码来源:ClientChannelInitializer.java
示例3: decode
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;
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:9,代码来源:FSTCodec.java
示例4: decode
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;
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:9,代码来源:HessianCodec.java
示例5: decode
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;
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:9,代码来源:GenericCodec.java
示例6: decode
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;
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:10,代码来源:KryoCodec.java
示例7: DatagramPacketObjectDecoder
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public DatagramPacketObjectDecoder(ClassResolver resolver) {
delegateDecoder = new ObjectDecoder(resolver);
}
开发者ID:HydAu,项目名称:Camel,代码行数:4,代码来源:DatagramPacketObjectDecoder.java
示例8: ObjectDecoder
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public ObjectDecoder(ClassResolver classResolver) {
super(classResolver);
}
开发者ID:HydAu,项目名称:Camel,代码行数:4,代码来源:ObjectDecoder.java
示例9: CompactObjectInputStream
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
CompactObjectInputStream(InputStream in, ClassResolver classResolver) throws IOException {
super(in);
this.classResolver = classResolver;
}
开发者ID:pulsarIO,项目名称:jetstream,代码行数:5,代码来源:StreamMessageDecoder.java
示例10: GridObjectDecoder
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public GridObjectDecoder(ClassResolver classResolver, GridCodec codec)
{
this(Integer.MAX_VALUE, classResolver);
this.codec = codec;
}
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:6,代码来源:GridObjectDecoder.java
示例11: JavaSerializer
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public JavaSerializer(ClassResolver resolver) {
this.resolver = resolver;
}
开发者ID:kompics,项目名称:kompics,代码行数:4,代码来源:JavaSerializer.java
示例12: StreamMessageDecoder
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);
}
开发者ID:pulsarIO,项目名称:jetstream,代码行数:9,代码来源:StreamMessageDecoder.java
示例13: decode
import io.netty.handler.codec.serialization.ClassResolver; //导入依赖的package包/类
public Object decode(InputStream in, ClassResolver classResolver) throws Exception;
开发者ID:liulhdarks,项目名称:darks-grid,代码行数:2,代码来源:GridCodec.java
注:本文中的io.netty.handler.codec.serialization.ClassResolver类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论