栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

zookeeper源码解析(二)

zookeeper源码解析(二)

2021SC@SDUSC 

前言

本文介绍上一篇文章中DataTree构造函数传入的参数digestCalculator,来看一下它所属的类。

DigestCalculator

该类的对象主要用于计算一个给定的数据节点的digest,关于digest,我想应该是和hash有关的一种说法,我们知道hash将大范围的数据映射到小范围,在加密领域,通常会体现会得到一个固定长度的数字或字符串,称为消息摘要,所以称digest。

而在该类中,主要是使用CRC校验,来保障数据的完整性,这相比于hash函数,不具有保障不被“碰撞”的能力。(碰撞是说两个不同的输入,hash后是同一个值)

该类的构造函数是默认无参构造函数。

该类主要的函数如下:

    long calculateDigest(String path, byte[] data, StatPersisted stat) {

        if (!ZooKeeperServer.isDigestEnabled()) {
            return 0;
        }

        
        if (path.startsWith(ZooDefs.ZOOKEEPER_NODE_SUBTREE)) {
            return 0;
        }

        
        if (path.equals("/")) {
            path = "";
        }

        byte[] b = new byte[60];
        ByteBuffer bb = ByteBuffer.wrap(b);
        bb.putLong(stat.getCzxid());
        bb.putLong(stat.getMzxid());
        bb.putLong(stat.getPzxid());
        bb.putLong(stat.getCtime());
        bb.putLong(stat.getMtime());
        bb.putInt(stat.getVersion());
        bb.putInt(stat.getCversion());
        bb.putInt(stat.getAversion());
        bb.putLong(stat.getEphemeralOwner());

        CRC32 crc = new CRC32();
        crc.update(path.getBytes());
        if (data != null) {
            crc.update(data);
        }
        crc.update(b);
        return crc.getValue();
    }


    long calculateDigest(String path, DataNode node) {
        if (!node.isDigestCached()) {
            node.setDigest(calculateDigest(path, node.getData(), node.stat));
            node.setDigestCached(true);
        }
        return node.getDigest();
    }

calculateDigest函数重载

第一个函数:

输入是数据节点的路径,存储的数据以及数据节点的stat信息(关于stat是什么,见下方StatPersisted的介绍)。

这正是我们计算数据节点的digest所需要的所有信息。

函数主体就是处理了一些边界情况,以及用了循环冗余校验CRC,算CRC值。

第二个函数:

输入是数据节点的路径,数据节点。

其实就是查看节点是否已经计算过digest存储了,有的话就直接提取,没有的话就再调用第一个函数去算。

PS:该类的成员变量只有一个静态变量DIGEST_VERSION(每当算digest的方式不同或者digest要计算的范围不同时,就要修改这个值),该类的其他函数就只有一个,用于返回DIGEST_VERSION。

StatPersisted

该类的对象用于维护数据节点的状态信息,主要描述了节点创建,修改,权限等元信息。

具体地,维护了以下九个属性

//数据节点被创建时的事务id
private long czxid;
//数据节点最后一次修改的事务id
private long mzxid;
//数据节点被创建的时间
private long ctime;
//数据节点最后一次修改的时间
private long mtime;
//节点版本号,节点每修改一次,+1
private int version;
//子节点版本号,子节点每修改一次,+1
private int cversion;
//对数据节点的ACL进行更改的次数
private int aversion;
//临时节点标识,如果这个数据节点是临时节点,那么该字段存储的是创建者的会话id;
//如果不是临时节点,那么该字段存储的是0
private long ephemeralOwner;
//数据节点的父节点的事务id
private long pzxid;

该类的函数主要是上述九个字段的get/set方法,序列化反序列化方法,hashCode,toString方法等常规方法。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/311347.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号