zookeeper使用Jute进行序列化及反序列化

比眉伴天荒 2022-10-13 10:29 155阅读 0赞

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

\`import lombok.Data;  
import org.apache.jute.\*;  
import org.apache.zookeeper.server.ByteBufferInputStream;  
import java.io.ByteArrayOutputStream;  
import java.io.IOException;  
import java.nio.ByteBuffer;

/\*\*

*  工作服务器信息  
    */  
    @Data  
    public class RunningData implements Record \{  
    /*\*
    
     *      服务器编号
    
    */  
    private Long cid;  
    /*\*
    
     *  服务器名  
        \*/  
        private String name;
    
    @Override  
    public void serialize(OutputArchive archive, String tag) throws IOException \{  
    archive.startRecord(this, tag);  
    archive.writeLong(cid, “cid”);  
    archive.writeString(name, “name”);  
    archive.endRecord(this, tag);  
    \}
    
    @Override  
    public void deserialize(InputArchive archive, String tag) throws IOException \{  
    archive.startRecord(tag);  
    this.cid = archive.readLong(“cid”);  
    this.name = archive.readString(“name”);  
    archive.endRecord(tag);  
    \}
    
    public static void main(String\[\] args) throws IOException \{  
    RunningData rd=new RunningData();  
    rd.setCid(1L);  
    rd.setName(“hello”);
    
        //序列化上面的对象
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         BinaryOutputArchive boa = BinaryOutputArchive.getArchive(baos);
         rd.serialize(boa, "header");
         byte[] bs=baos.toByteArray();
        
         //反序列化  bs  字节数组
         ByteBuffer bb = ByteBuffer.wrap(bs);
         ByteBufferInputStream bbis = new ByteBufferInputStream(bb);
         BinaryInputArchive bia = BinaryInputArchive.getArchive(bbis);
         RunningData header = new RunningData();
         header.deserialize(bia, "create");
        
         System.out.println(    header.toString()  );
    
    \}  
    \}\`

运行结果为:  
`RunningData(cid=1, name=hello)`

### Jute中的常用操作: ###

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中基本没使用到。

来源: http://www.hyycinfo.com/yc\_article/5874000