zoukankan      html  css  js  c++  java
  • zk客户端及锁的使用

    1.生成zk客户端对象

    private CuratorFramework buildClient() {
            logger.info("zookeeper registry center init, server lists is: {}.", zookeeperConfig.getServerList());
    
            CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.builder().ensembleProvider(new DefaultEnsembleProvider(checkNotNull(zookeeperConfig.getServerList(),
                    "zookeeper quorum can't be null")))
                    .retryPolicy(new ExponentialBackoffRetry(zookeeperConfig.getBaseSleepTimeMs(), zookeeperConfig.getMaxRetries(), zookeeperConfig.getMaxSleepMs())).namespace(zookeeperConfig.getNameSpace());
    
            //these has default value
            if (0 != zookeeperConfig.getSessionTimeoutMs()) {
                builder.sessionTimeoutMs(zookeeperConfig.getSessionTimeoutMs());
            }
            if (0 != zookeeperConfig.getConnectionTimeoutMs()) {
                builder.connectionTimeoutMs(zookeeperConfig.getConnectionTimeoutMs());
            }
            if (StringUtils.isNotBlank(zookeeperConfig.getDigest())) {
                builder.authorization("digest", zookeeperConfig.getDigest().getBytes(StandardCharsets.UTF_8)).aclProvider(new ACLProvider() {
    
                    @Override
                    public List<ACL> getDefaultAcl() {
                        return ZooDefs.Ids.CREATOR_ALL_ACL;
                    }
    
                    @Override
                    public List<ACL> getAclForPath(final String path) {
                        return ZooDefs.Ids.CREATOR_ALL_ACL;
                    }
                });
            }
            zkClient = builder.build();
            zkClient.start();
            try {
                zkClient.blockUntilConnected();
            } catch (final Exception ex) {
                throw new ServiceException(ex);
            }
            return zkClient;
        }
    

    2.zk客户端封装,生成锁对象

    String znodeLock = getMasterStartUpLockPath();
     InterProcessMutex mutex = new InterProcessMutex(getZkClient(), znodeLock);
    

    3.锁对象,同步获取锁,异步获取锁

    // 同步锁
    mutex.acquire();
    
    // 异步锁
    boolean flag = mutex.acquire(1,TimeUnit.SECONDS);
    
  • 相关阅读:
    博弈论基础与习题(未完)
    三视图求最多方块数
    二维前缀和应用
    卡特兰数
    UVa 11806 Cheerleaders(容斥定理)
    逃出升天
    求排列的逆序数
    求2进制下1的个数
    字符串哈希基础与应用
    网络流基础与应用
  • 原文地址:https://www.cnblogs.com/PythonOrg/p/14596405.html
Copyright © 2011-2022 走看看