使用Jute进行序列化

灰太狼 2021-10-24 00:22 299阅读 0赞

Zookeeper在网络传输时使用的是Jute进行序列化和反序列化，官方也提出过要使用类似于Apache Avro、Thrift或是Google的protobuf这样的组件来替换Jute，但考虑到新老版本组件的兼容性，官方对替换序列化组件工作的推进持保守和观望态度。

下面来看看如何使用Jute来完成对象的序列化和反序列化，以MockReqHeader类为例，需要实现Record接口。

package com.teriste.entity;
    
    import org.apache.jute.InputArchive;
    import org.apache.jute.OutputArchive;
    import org.apache.jute.Record;
    
    import java.io.IOException;
    
    public class MockReqHeader implements Record{
    
        private long sessionId;
    
        private String type;
    
        public MockReqHeader(){
    
        }
    
        public MockReqHeader(long sessionId,String type){
            this.sessionId=sessionId;
            this.type=type;
        }
    
        public long getSessionId() {
            return sessionId;
        }
    
        public void setSessionId(long sessionId) {
            this.sessionId = sessionId;
        }
    
        public String getType() {
            return type;
        }
    
        public void setType(String type) {
            this.type = type;
        }
    
        public void serialize(OutputArchive a_, String tag) throws IOException{
            a_.startRecord(this,tag);
            a_.writeLong(sessionId,"sessionId");
            a_.writeString(type,"type");
            a_.endRecord(this,tag);
        }
    
        public void deserialize(InputArchive a_, String tag) throws IOException{
            a_.startRecord(tag);
            sessionId=a_.readLong("sessionId");
            type=a_.readString("type");
            a_.endRecord(tag);
        }
    
        @Override
        public String toString() {
            return "MockReqHeader{" +
                    "sessionId=" + sessionId +
                    ", type='" + type + '\'' +
                    '}';
        }
    }

下面来测试序列化和反序列化：

package com.teriste.web;
    
    import com.teriste.entity.MockReqHeader;
    import org.apache.jute.BinaryInputArchive;
    import org.apache.jute.BinaryOutputArchive;
    import org.apache.zookeeper.server.ByteBufferInputStream;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    public class JuteTest {
    
        /**
         * 实体类要使用Jute进行序列化和反序列化步骤
         * 1.需要实现Record接口的serialize和deserialize方法
         * 2.构建一个序列化器BinaryOutputArchive
         * 3.序列化
         * 调用实体类的serialize方法，将对象序列化到指定的tag中去，比如这里将对象序列化到header中
         * 4.反序列化
         * 调用实体类的deserialize方法，从指定的tag中反序列化出数据内容
         */
        @Test
        public void serialTest() throws IOException{
            //对象序列化
            ByteArrayOutputStream baos=new ByteArrayOutputStream();
            BinaryOutputArchive boa=BinaryOutputArchive.getArchive(baos);
            new MockReqHeader(0x22342eccb43a12al,"ping").serialize(boa,"header");
            //TCP忘了传输对象
            ByteBuffer bb=ByteBuffer.wrap(baos.toByteArray());
            //反序列化
            ByteBufferInputStream bbis=new ByteBufferInputStream(bb);
            BinaryInputArchive bia=BinaryInputArchive.getArchive(bbis);
            MockReqHeader header2=new MockReqHeader();
            header2.deserialize(bia,"header");
            System.out.println(header2);
            bbis.close();
            baos.close();
    
        }
    }

![20190818102011280.png][]

**Record****接口**

Jute定义了自己独特的序列化格式Record，Zookeeper中所需要进行网络传输或是本地磁盘存储的类型定义，都实现了该接口，其结构简单明了，操作灵活多变，是Jute序列化的核心。Record定义了两个基本的方法，分别是serialize和deserialize，分别用于序列化和反序列化。其中archive是底层真正的序列化器和反序列化器，并且每个archive中可以包含对多个对象的序列化和反序列化，因此两个接口中都标记了参数tag，用于序列化器和反序列化器标识对象自己的标记。

**OutputArchive****和InputArchive**

OutputArchive和InputArchive分别是Jute底层的序列化器和反序列化器定义。有BinaryOutputArchive/BinaryInputArchive、CsvOutputArchive/CsvInputArchive和XmlOutputArchive/XmlInputArchive三种实现，无论哪种实现都是基于OutputStream和InoutStream进行操作。

BinaryOutputArchive对数据对象的序列化和反序列化，主要用于进行网络传输和本地磁盘的存储，是Zookeeper底层最主要的序列化方式。CsvOutputArchive对数据的序列化，更多的是方便数据的可视化展示，因此被用在toString方法中。XmlOutputArchive则是为了将数据对象以xml格式保存和还原，但目前在Zookeeper中基本没使用到。

参考书籍《从Paxos到Zookeeper++分布式一致性原理与实践》

[20190818102011280.png]: /images/20211023/22c2d092fd184cea9f5f4e634cc12f8c.png