Skip to content

Latest commit

 

History

History
140 lines (102 loc) · 4.59 KB

agileway-codec.MD

File metadata and controls

140 lines (102 loc) · 4.59 KB
Raw

Agileway-Codec

目前市面上支持很多的序列化框架 1）需要Schema的有：

需要Schema的不必说了，性能好，兼容多种语言，是特色，但是开发效率低下。

下面来对比一下这些不需要Schema的序列化框架：

框架 无参构造函数 循环引用 对象为 null 是否需要预先知道对象类型 大对象（4M） 跨语言
Kryo 支持 需要将 reference 选项打开 支持 不需要，关闭 register 支持 支持，较复杂
Java 支持 支持 支持 不需要 支持 支持
Jackson 支持 不支持 支持 不需要 支持 支持
Hessian 支持 支持 支持 不需要 支持 支持
FST 支持 支持 支持 不需要 支持 支持
FSE 支持 支持 支持 不需要 支持 不支持
XSON 支持 支持 支持 不需要 支持 不支持

虽然有这么多的框架可以先选择，但是他们在使用上毕竟有着不小的区别。 每一种类库肯定有一下自身的特性在里面，给使用也带来了不小的学习成本。

所以开发Codec模块来将它们统一。

核心APIs：

public interface Codec<T> {
    @Nullable
    byte[] encode(@Nullable T obj) throws CodecException;

    @Nullable
    T decode(@Nullable byte[] bytes) throws CodecException;


    @Nullable
    T decode(@Nullable byte[] bytes, Class<T> targetType) throws CodecException;

    boolean canSerialize(Class<?> type);

    Class<T> getTargetType();

    void setTargetType(Class<T> targetType);
}

测试用例：

import com.jn.agileway.codec.Codec;
import com.jn.agileway.codec.CodecException;
import com.jn.agileway.codec.serialization.fst.FstCodec;
import com.jn.agileway.codec.serialization.hessian.HessianCodec;
import com.jn.agileway.codec.serialization.kryo.KryoCodec;
import com.jn.agileway.codec.serialization.protostuff.ProtostuffCodec;
import org.junit.Assert;
import org.junit.Test;

import java.util.Date;

public class CodecTests {
    private static Pojo pojo = createPojo();

    private static Pojo createPojo() {
        Pojo pojo = new Pojo();
        pojo.setAttribute("zhangsan", "zhangsan");
        pojo.setAttribute("pojo", pojo);
        pojo.setHost("localhost");
        pojo.setId("234234=-23423wrfq23342341212312");
        pojo.setExpired(false);
        pojo.setStartTimestamp(new Date());

        return pojo;
    }

    @Test
    public void testHessian() throws CodecException {
        Codec<Pojo> codec = new HessianCodec();
        byte[] bytes = codec.encode(pojo);
        Pojo pojo2 = codec.decode(bytes);
        Assert.assertEquals(pojo, pojo2);

        Pojo pojo3 = codec.decode(bytes, Pojo.class);
        Assert.assertEquals(pojo, pojo3);
    }

    @Test
    public void testKryo() throws CodecException {
        Codec<Pojo> codec = new KryoCodec<>();
        byte[] bytes = codec.encode(pojo);
        Pojo pojo2 = codec.decode(bytes);
        Assert.assertEquals(pojo, pojo2);

        Pojo pojo3 = codec.decode(bytes, Pojo.class);
        Assert.assertEquals(pojo, pojo3);
    }


    @Test
    public void testProtostuff() throws CodecException {
        Codec<Pojo> codec = new ProtostuffCodec<Pojo>();
        byte[] bytes = codec.encode(pojo);

        Pojo pojo3 = codec.decode(bytes, Pojo.class);
        Assert.assertEquals(pojo, pojo3);
    }

    @Test
    public void testFst() throws CodecException {
        Codec<Pojo> codec = new FstCodec<>();
        byte[] bytes = codec.encode(pojo);
        Pojo pojo2 = codec.decode(bytes);
        Assert.assertEquals(pojo, pojo2);

        Pojo pojo3 = codec.decode(bytes, Pojo.class);
        Assert.assertEquals(pojo, pojo3);
    }

}