码迷,mamicode.com
首页 > 其他好文 > 详细

zookeeper初探

时间:2017-10-17 15:30:26      阅读:154      评论:0      收藏:0      [点我收藏+]

标签:mkdir   val   应用   exist   ring   rand   apache   /tmp   ade   

  1. 安装三台linux虚拟机,安装好java环境,并配置好网络以及host文件,分别改好hostname为node0、node1、node2
    技术分享
  2. 上传下载好的zookeeper文件到node0的/usr/local目录下,解压,然后将解压后的文件复制到另外两台机器中,使用scp -r /usr/local/zookeeper-3.4.10 root@node1:/usr/local/命令
  3. 同时操作三台机器,将解压后的文件重命名为zookeeper,并进入该目中的conf文件夹,拷贝一份zoo_sample.cfg并命名为zoo.cfg,使用命令:cp zoo_sample.cfg zoo.cfg
  4. 修改zoo.cfg文件,在文档末尾添加如下内容:
    技术分享
  5. zookeeper默认将数据存储在/tmp/zookeeper/目录中,所以需要去到/tmp目录下建立一个zookeeper目录。使用命令mkdir /tmp/zookeeper,然后进入该目录,创建myid文件,编辑内容,三台机器的内容不一,分别为1、2、3,即上一步中配置的server的值。
    技术分享
  6. 进入/usr/local/zookeeper/bin目录,输入./zkServer.sh start命令,启动zookeeper服务,然后输入jps观察启动情况:
    技术分享
  7. 执行./zkServer.sh status观察zookeeper的运行状态,会发现,3台机器中会有一台leader和两台follower,至于哪台机器是leader,是由zookeeper自己选举出来的。但是,如果leader机器挂了,会出现什么情况?下一步来做这个实验。
    技术分享
  8. 在leader机器上关闭zookeeper服务,首先输入jps观察leader的pid,然后使用kill -9 pid命令杀掉它,再次使用jps观察状况。然后使用./zkServer status查看状态,会发现zookeeper会自动再选举一个leader。
    技术分享
  9. 下面看看zookeeper到底能做什么。再复制一台虚拟机出来,装好jdk和zookeeper,并将用户名更改为node3
  10. 进入zookeeper/bin目录下,输入./zkCli -server node0:2181进行连接。
  11. 简单操作zookeeper,zookeeper就像一个数据库,里边可以存放数据,其七字真言“一致、有头、数据树”,一致是说,在所有的节点中,数据都是一致的,无论你连接到哪一个节点上,所看到的数据都是一样的,并且,修改任意一个节点上的数据,都会同步到其他所有的节点上;有头是说这些节点会有一个leader,当leader挂掉后,会自动再选举一个leader;数据树是说每个节点中都有一个数据的目录树,树的节点上存的就是数据。zookeeper是将数据存在了内存当中,所以读取的速度会很快。
    技术分享
  12. zookeeper应用场
    1. 配置一致:顾名思义,如hadoop服务需要修改配置文件,但如果集群机器特别多,需要一个个修改很麻烦,可以将配置文件放到zookeeper里,这样修改一个,其他的就都可以修改过来了。
    2. HA(High Available):高可用集群
    3. pub/sub
    4. naming service
    5. load balance
    6. 分布式锁
    7. ...
  13. 使用java操作zookeeper
    1. 新建maven项目,添加zookeeper依赖
      1 <dependencies>
      2         <dependency>
      3             <groupId>org.apache.zookeeper</groupId>
      4             <artifactId>zookeeper</artifactId>
      5             <version>3.4.10</version>
      6         </dependency>
      7 </dependencies>
    2. 编写java代码
       1 public class ZkClient implements Watcher {
       2 
       3     static CountDownLatch connected = new CountDownLatch(1);
       4     static final String CONN_STR = "192.168.217.170:2181,192.168.217.171:2181,192.168.217.172:2181";
       5 
       6     public void test() throws Exception {
       7         ZooKeeper zoo = null;
       8 
       9         zoo = new ZooKeeper(CONN_STR, 5000, this);
      10         System.out.println(zoo.getState());
      11 
      12         connected.await();
      13 
      14         if (zoo.exists("/skyer", false) != null) {
      15             zoo.delete("/skyer", -1);
      16         }
      17 
      18         zoo.create("/skyer", "192.168.56.1:2000".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
      19         System.out.println("ok");
      20 
      21         byte[] data = zoo.getData("/skyer", false, null);
      22         System.out.println(new String(data));
      23 
      24         zoo.create("/e", "e".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
      25 
      26         Thread.sleep(10000);
      27         zoo.close();
      28     }
      29 
      30     public static void main(String[] args) throws Exception {
      31         new ZkClient().test();
      32     }
      33 
      34     public void process(WatchedEvent event) {
      35         System.out.println("event:" + event);
      36         if (event.getState() == KeeperState.SyncConnected) {
      37             connected.countDown();
      38             System.out.println("connected!");
      39         }
      40     }
      41 
      42 }
  14. 下面延时一个HA的过程,编写java代码
     1 public class TankMaster {
     2     
     3     static String status = "ACTIVE";
     4     
     5     public static void main(String[] args) throws Exception {
     6         String CONN_STR = "192.168.217.170:2181,192.168.217.171:2181,192.168.217.172:2181";
     7         ZooKeeper zk = new ZooKeeper(CONN_STR, 5000, null);
     8         
     9         String IP = "202.106.29.138";
    10         String port = new Random().nextInt(500) + "";
    11         System.out.println(port);
    12 
    13         if (zk.exists("/tankMaster", new MasterWatcher()) != null) {
    14             status = "STANDBY";
    15         } else {
    16             zk.create("/tankMaster", (IP + ":" + port).getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
    17             status = "ACTIVE";
    18             // 启动server
    19             System.out.println("启动就是active");
    20         }
    21         Thread.sleep(Integer.MAX_VALUE);
    22     }
    23     
    24     static class MasterWatcher implements Watcher {
    25         public void process(WatchedEvent event) {
    26             if (event.getType() == EventType.NodeDeleted) {
    27                 status = "ACTIVE";
    28                 System.out.println("切换为active");
    29             }
    30         }
    31     }
    32 
    33 }
  15. 运行上述程序,观看控制台输出
    技术分享
  16. 不要停止上述程序,再次运行该程序,观察控制台输出
    技术分享
  17. 停止步骤15运行的程序,观察步骤16的控制台输出
    技术分享

zookeeper初探

标签:mkdir   val   应用   exist   ring   rand   apache   /tmp   ade   

原文地址:http://www.cnblogs.com/skyer5217/p/7680513.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!