redisson如何序列化

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.serializer.SerializerFeature;

import io.netty.buffer.ByteBuf;

import io.netty.buffer.ByteBufAllocator;

import io.netty.buffer.ByteBufInputStream;

import io.netty.buffer.ByteBufOutputStream;

import org.redisson.client.codec.BaseCodec;

import org.redisson.client.protocol.Decoder;

import org.redisson.client.protocol.Encoder;

import java.io.IOException;

public class FastjsonCodec extends BaseCodec {

 private final Encoder encoder = in -> {

 ByteBuf out = ByteBufAllocator.DEFAULT.buffer();

 try {

 ByteBufOutputStream os = new ByteBufOutputStream(out);

 JSON.writeJSONString(os, in,SerializerFeature.WriteClassName);

 return os.buffer();

 } catch (IOException e) {

 out.release();

 throw e;

 } catch (Exception e) {

 out.release();

 throw new IOException(e);

 }

 };

 private final Decoder<Object> decoder = (buf, state) ->

 JSON.parseObject(new ByteBufInputStream(buf), Object.class);

 @Override

 public Decoder<Object> getValueDecoder() {

 return decoder;

 }

 @Override

 public Encoder getValueEncoder() {

 return encoder;

 }

}