zookeeper初探

Posted 2020-10-11

1. 安装三台linux虚拟机，安装好java环境，并配置好网络以及host文件，分别改好hostname为node0、node1、node2
   
2. 上传下载好的zookeeper文件到node0的/usr/local目录下，解压，然后将解压后的文件复制到另外两台机器中，使用scp -r /usr/local/zookeeper-3.4.10 [email protected]:/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的控制台输出