zookeeper的相关操作

一.watch事件

1.为父节点设置watch事件(一次性的，借助工具可以弄成可以多次)

1.用stat为父节点设置watch事件,创建触发NodeCreated事件
    WatchedEvent state:SyncConnected type:NodeCreated path:/testWatch

2.用ls为父节点设置watch事件,创建子节点触发NodeChildrenChanged事件
    WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/testZnode

3.用ls为父节点设置watch事件,修改子节点不触发事件,要用get为它的子节点设置watch事件才行(把子节点当作父节点来看)
    get /testWatch/sonnode watch

4.用stat为父节点设置watch事件,修改触发NodeDataChanged事件
    WatchedEvent state:SyncConnected type:NodeDataChanged path:/testZnode

5.用stat为父节点设置watch事件,删除触发NodeDeleted事件
    WatchedEvent state:SyncConnected type:NodeDeleted path:/testWatch

6.用ls为父节点设置watch事件,删除子节点触发NodeChildrenChanged事件
    WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/testZnode

2、watch使用场景

为节点设置watch事件，当主配置(主节点上)更新时，客户端(java程序端)监听到watch事件后，就将配置更新为主节点上一样的配置，这样配置就同步了。

二.acl访问控制权限(access control permission)

1.acl构成： [scheme:id:permissions]

例如：world:anyone:cdrwa

scheme: 权限模式(world/auth/digest/id/super)
id: 用户(username:password)
permissions: 权限表达式(crdwa分别代表 创建/读取/删除/写入/管理)

2.操作

1.setAcl /testNode world:anyone:crdwa 
    [zk: localhost:2181(CONNECTED) 6] setAcl /testZnode/testAcl world:anyone:crda

2.getAcl /testNode
    [zk: localhost:2181(CONNECTED) 8] getAcl /testZnode/testAcl
    'world,'anyone
    : cdra

3.设置用户权限(用户名：myname 密码：password), 提示无效(需要登陆用户)
    [zk: localhost:2181(CONNECTED) 1] setAcl /testZnode/testAcl2 auth:myname:mypassword:crda
    Acl is not valid : /testZnode/testAcl2

4.登陆一下
    [zk: localhost:2181(CONNECTED) 0] addauth digest myname:mypassword

5.在重新设置，成功了
    [zk: localhost:2181(CONNECTED) 1] setAcl /testZnode/testAcl2 auth:myname:password:crda
    cZxid = 0x1900000fc6
    ctime = Mon May 14 12:43:22 CST 2018
    mZxid = 0x1900000fc6
    mtime = Mon May 14 12:43:22 CST 2018
    pZxid = 0x1900000fc6
    cversion = 0
    dataVersion = 0
    aclVersion = 1
    ephemeralOwner = 0x0
    dataLength = 3
    numChildren = 0

6.再去改节点的内容，提示认证无效，不能修改
    [zk: localhost:2181(CONNECTED) 2] set /testZnode/testAcl2 666
    Authentication is not valid : /testZnode/testAcl2

7.其它模式操作类似()
    world: setAcl /testZnode/testAcl2 world:anyone:crdwa
    auth: setAcl /testZnode/testAcl2 auth:myname:mypassword:crda
    digest: setAcl /testZnode/testAcl2 digest:myname:jd2ErFo0AbcSSSfXUZWfus8DYaM=:crda
    id: setAcl /testZnode/testAcl2 ip:192.168.0.16:crdwa
    super: setAcl /testZnode/testAcl2 world:anyone:crdwa

    注意点：
    1.auth使用明文
    2.digest使用密文,但使用addauth登陆还是用明文登陆，会自动转换成密文
    3.使用addauth添加用户后，就不能更改用户了

8.使用super有点特别，需要额外操作
    1.修改zkServer.sh，增加super管理员
    找到这行修改 nohup $JAVA "-Dzookeeper.log.dir=${ZOO_LOG_DIR}" "-Dzookeeper.root.logger=${ZOO_LOG4J_PROP}" \
    在${ZOO_LOG4J_PROP}"后 \前添加 "-Dzookeeper.DigestAuthenticationProvider.superDigest=myname:jd2ErFo0AbcSSSfXUZWfus8DYaM="
    (这个类从源码中找到的，这里的意思是设置super用户名为myname,密码为mypassword)
    2.重启zkServer.sh

3.使用场景
· 1.使用命名空间的概念(不同权限的节点是不同的空间)，使用开发/测试环境分离·
· 2.使用id模在开发时控制指定ip访问指定节点，防止混乱·

三.四字命令(4个字符缩写的命令)

1.先安装nc命令 yum install nc
2.使用格式 echo [commond] | nc [ip][port]

1.示例操作

1.查看zk的状态信息和mode
    [root@server src]# echo stat | nc 192.168.8.84 2181
    Zookeeper version: 3.4.5-1392090, built on 09/30/2012 17:52 GMT
    Clients:
     /192.168.8.84:43980[0](queued=0,recved=1,sent=0)

    Latency min/avg/max: 0/0/9
    Received: 157
    Sent: 156
    Connections: 1
    Outstanding: 0
    Zxid: 0x1900000fd6
    Mode: follower
    Node count: 54
2.查看是否启动
    [root@server src]# echo ruok | nc 192.168.8.84 2181
    imok
3.列出未经处理的会话和临时节点
    [root@server src]# echo dump | nc 192.168.8.84 2181
    SessionTracker dump:
    org.apache.zookeeper.server.quorum.LearnerSessionTracker@3fe135c2
    ephemeral nodes dump:
    Sessions with Ephemerals (0):
4.查看配置
    [root@server src]# echo conf | nc 192.168.8.84 2181
    clientPort=2181
    dataDir=/usr/local/src/zookeeper-3.4.5/data/version-2
    dataLogDir=/usr/local/src/zookeeper-3.4.5/data/version-2
    tickTime=2000
    maxClientCnxns=60
    minSessionTimeout=4000
    maxSessionTimeout=40000
    serverId=4
    initLimit=10
    syncLimit=5
    electionAlg=3
    electionPort=3888
    quorumPort=2888
    peerType=0
5.查看zk的健康状况
    [root@itcast04 src]# echo mntr | nc 192.168.8.84 2181
    zk_version      3.4.5-1392090, built on 09/30/2012 17:52 GMT
    zk_avg_latency  0
    zk_max_latency  9
    zk_min_latency  0
    zk_packets_received     161
    zk_packets_sent 160
    zk_num_alive_connections        1
    zk_outstanding_requests 0
    zk_server_state follower
    zk_znode_count  54
    zk_watch_count  0
    zk_ephemerals_count     0
    zk_approximate_data_size        1458
    zk_open_file_descriptor_count   33
    zk_max_file_descriptor_count    4096

四.zookeeper分布式锁思路(结合curator)

1.配置zk客户端bean(里面包含了策略)，配置curatorFactorybean(将spring和curator集成在一起)

2. 创建一个分布式锁类(里面维护了一个countDownLatch)，配置成spring的bean
   3.上面分布式锁类包含init初始化方法，getLock，releaseLock，addWatcherToLock方法
   4.在init中用curator创建zk的命名空间和锁的根节点，并使用addWatcherToLock监听这个根节点
   5.使用getLock方法时用curator在上面创建的根节点下创建临时节点(也就是锁，所以创建的节点名要一样，不同的业务锁以这个名称区分)，如果创建不成功(其它的线程在用这把锁)，就用countDownLatch.await挂起线程
   6.在addWatcherToLock方法中使用PathChildrenCache监听zk节点上的事件，如果监听到节点删除事件(有线程释放了锁)，判断删除的节点名是不是上面getLock时创建的节点名，如果是则调用counDownLatch.countDown()方法将前面挂起的线程放开，
   7.使用releaseLock方法时删除上面的临时节点时先判断这个路径(节点)是否存在，存在就删除这个节点
   8.使用这个锁时，在业务类(Service)里注入这个锁类，在进入业务方法时首先调用getLock锁住这个方法，在执行完方法返回前调用releaseLock释放掉这个锁(注意：一定要记得释放，这个业务方法中间出来异常的地方也要调用releaseLock释放掉这个锁)