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);
    
  • 相关阅读:
    排序预处理的思想
    枚举
    math细节
    physics 衍射和ganshe
    hearing speaking words
    appium的环境安装
    基于ASP.NET MVC 4.0的音乐商店全套项目教程
    WPF/WinForm 关于窗体大小变化的消息机制处理
    用WPF搭建自己的万能播放器(C#)前篇
    VS2010网站发布到服务器上
  • 原文地址:https://www.cnblogs.com/PythonOrg/p/14596405.html
Copyright © 2011-2022 走看看