前言

本文介绍上一篇文章中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方法等常规方法。