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);
            }
        }
    }
    

      

  • 相关阅读:
    http和HTTPS的区别及SSL介绍
    cas系列(三)--HTTP和HTTPS、SSL
    cas系列(一)--cas单点登录基本原理
    修改cas登陆页面-服务器端
    rest例子
    RESTful 架构风格概述
    Java分布式应用技术架构介绍
    tomcat的server.xml详解
    Apache Shiro 快速入门教程,shiro 基础教程 (这篇文章非常好)
    fmt:formatDate标签的输出格式
  • 原文地址:https://www.cnblogs.com/wscit/p/6055485.html
Copyright © 2011-2022 走看看