Apache ZooKeeper - 使用原生的API操作ZK_ACL权限

古城微笑少年丶 2022-12-25 10:51 137阅读 0赞

### 文章目录 ###

*  Pre
 *  Code
 *   *  创建world模式的节点
     *  使用授权模式创建节点
     *  使用授权模式获取节点数据

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center]

--------------------

# Pre #

[Apache ZooKeeper - ZK的ACL权限控制( Access Control List )][Apache ZooKeeper - ZK_ACL_ Access Control List]

[Apache ZooKeeper - 使用原生的API操作ZK\_CRUD][Apache ZooKeeper - _API_ZK_CRUD]

--------------------

# Code #

## 创建world模式的节点 ##

package com.artisan.zk.originalClient;
    
    import lombok.SneakyThrows;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.zookeeper.CreateMode;
    import org.apache.zookeeper.KeeperException;
    import org.apache.zookeeper.ZooDefs;
    import org.apache.zookeeper.data.ACL;
    import org.apache.zookeeper.data.Id;
    import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;
    import org.junit.Test;
    
    import java.security.NoSuchAlgorithmException;
    import java.util.ArrayList;
    import java.util.List;
    
    
    /** * @author 小工匠 * @version 1.0 * @description: TODO * @date 2020/12/1 11:19 * @mark: show me the code , change the world */
    
    @Slf4j
    public class AclOperationStanAloneModeTest  extends  StandAloneBaseTest{ 
    
        private  static final  String  NODE_NAME = "/artisan-acl-node";
    
    
        /** * 创建world模式的节点 */
        @SneakyThrows
        @Test
        public void testCreateNodeWithACL(){ 
    
            List<ACL>aclList = new ArrayList<>();
            ACL acl = new ACL();
    
            Id id = new Id();
            id.setId("anyone");
            id.setScheme("world");
    
            // 权限
            int perms = ZooDefs.Perms.ADMIN | ZooDefs.Perms.READ ;
    
            // 绑定
            acl.setId(id);
            acl.setPerms(perms);
    
            aclList.add(acl);
    
            String s = getZooKeeper().create(NODE_NAME, "artisan".getBytes(), aclList, CreateMode.PERSISTENT);
            log.info("path {} created " ,s);
        }
    }

![在这里插入图片描述][20201201165939279.png]

登录ZK Client查看数据

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70]

--------------------

## 使用授权模式创建节点 ##

/** * * 使用授权模式创建节点 */
        @SneakyThrows
        @Test
        public void createWithAclTest2() { 
    
            String namePWD = "artisan:artisanPWD";
            // 对连接添加授权信息
            getZooKeeper().addAuthInfo("digest",namePWD.getBytes());
    
            List<ACL> acLList = new ArrayList<ACL>();
            ACL acl = new ACL();
    
            Id id = new Id();
            id.setId(namePWD);
            id.setScheme("auth");
    
            int perms = ZooDefs.Perms.ADMIN  |  ZooDefs.Perms.READ |ZooDefs.Perms.WRITE;
            acl.setId(id);
            acl.setPerms(perms);
    
            acLList.add(acl);
    
            String s = getZooKeeper().create("/artisanNode2", "artisan".getBytes(), acLList, CreateMode.PERSISTENT);
            log.info("create path: {}",s);
        }

![在这里插入图片描述][20201201170151868.png]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 1]

如果要手工查看 可以这儿样

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 2]

如果用代码访问 如下

--------------------

## 使用授权模式获取节点数据 ##

@Test
        public void getDataWithAcl() throws KeeperException, InterruptedException { 
    
            String namePWD = "artisan:artisanPWD";
    
            // 对连接添加授权信息
            getZooKeeper().addAuthInfo("digest",namePWD.getBytes());
    
    
            byte[] data = getZooKeeper().getData("/artisanNode2", false, null);
    
            log.info("GET_DATA : {}",new String(data));
        }
    
    
        public static void main(String[] args) throws NoSuchAlgorithmException { 
            String sId = DigestAuthenticationProvider.generateDigest("artisan:artisanPWD");
            System.out.println(sId);
            // -Dzookeeper.DigestAuthenticationProvider.superDigest=artisan:d3gLrY2XgzvXZbJObw+wiWIQDko=
        }

![在这里插入图片描述][20201201170605304.png]

是不是明白了？？？

![在这里插入图片描述][20201201153122796.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/1539d4cd8ccf4f6882b822e51517ab77.png
[Apache ZooKeeper - ZK_ACL_ Access Control List]: https://artisan.blog.csdn.net/article/details/109759787
[Apache ZooKeeper - _API_ZK_CRUD]: https://artisan.blog.csdn.net/article/details/110101131
[20201201165939279.png]: /images/20221120/77caff26cc774b2882723286dacd8331.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70]: /images/20221120/57565b11e3f34489894df89e34f20522.png
[20201201170151868.png]: /images/20221120/1f7d0c4b33644321a599aa975a3470fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 1]: /images/20221120/04932350a64d45adb8c61593f5e900c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbmdzaGFuZ3dlaQ_size_16_color_FFFFFF_t_70 2]: /images/20221120/6776827297ac410390f197496b3baa58.png
[20201201170605304.png]: /images/20221120/294bd30f1fc2445bba523d812e568020.png
[20201201153122796.png]: /images/20221120/bcffdb8625d84a7f96b63465445f1981.png