zoukankan      html  css  js  c++  java
  • 老王讲自制RPC框架.(三.ZOOKEEPER)

    (#)定义
    Zookeeper 分布式服务框架是 Apache Hadoop 的一个子项目,它主要是用来解决分布式应用中经常遇到的一些数据管理问题,如:统一命名服务、状态同步服务、集群
    管理、分布式应用配置项的管理

    (#)使用
    配置zk客户端我就不多说了,这个网上一找一堆,我主要说一下就是,自己玩玩的话,没必要搭建一个集群,用一台基本问题不大,在此假设集群已经搭建完成了
    需要引入zk client的jar包

    (#)code

      private Logger logger = LoggerFactory.getLogger(ServiceRepository.class);
        @Value("${session.timeout}")
        private int SESSION_TIMEOUT;
        @Value("${registry.address}")
        private String CONNECT_STRING;
        @Value("${repository.path}")
        private String RPC_PATH;
        private ZooKeeper zooKeeper = null;
        private CountDownLatch latch = new CountDownLatch(1);
    
    
    
        private void createConnect() {
            releaseConnection();
            try {
                zooKeeper = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT,
                        new Watcher() {
                            public void process(WatchedEvent event) {
                                logger.info("receive message :{}" + event.getState());
                                latch.countDown();
                            }
                        });
                latch.await();
            } catch (IOException e) {
                logger.error("create异常信息:{}", e);
            } catch (InterruptedException e) {
                logger.error("create异常信息:{}", e);
            }
            ;
        }
    
        private void releaseConnection() {
            if (zooKeeper != null) {
                try {
                    zooKeeper.close();
                } catch (InterruptedException e) {
                    logger.error("release异常信息:{}", e);
                }
            }
        }
    
        private boolean createPath(String path, String data) {
            try {
                zooKeeper.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            } catch (KeeperException e) {
                logger.error("create异常信息:{}", e);
            } catch (InterruptedException e) {
                logger.error("create异常信息:{}", e);
            }
            return true;
        }
    
        public String readData(String path) {
            try {
                return new String(zooKeeper.getData(path, false, null));
            } catch (KeeperException e) {
                logger.error("read异常信息:{}", e);
                return "";
            } catch (InterruptedException e) {
                logger.error("read异常信息:{}", e);
                return "";
            }
        }
    
        public boolean writeData(String path, String data) {
            try {
                zooKeeper.setData(path, data.getBytes(), -1);
            } catch (KeeperException e) {
                logger.error("write异常信息:{}", e);
            } catch (InterruptedException e) {
                logger.error("write异常信息:{}", e);
            }
            return false;
        }
    
        public void deleteNode(String path) {
            try {
                zooKeeper.delete(path, -1);
            } catch (KeeperException e) {
                logger.error("delete异常信息:{}", e);
            } catch (InterruptedException e) {
                logger.error("delete异常信息:{}", e);
            }
        }
    }
    

      

  • 相关阅读:
    PC-BSD 9.2 发布,基于 FreeBSD 9.2
    Attic 0.8.1 发布,备份程序
    Apache Lucene 4.5 发布,Java 搜索引擎
    Linux Kernel 3.11.4/3.10.15/3.4.65/3.0.99
    Lucene 查询工具 LQT
    Rubinius 2.0 发布,Ruby 虚拟机
    Golang通过Thrift框架完美实现跨语言调用
    微软再次要求Google审查官方链接 称将进行调查
    TCPDF 6.0.036 发布,PHP 的 PDF 操作包
    libnode 0.4.0 发布,C++ 语言版的 Node.js
  • 原文地址:https://www.cnblogs.com/wscit/p/6055485.html
Copyright © 2011-2022 走看看