zookeeper集群的的搭建：点击打开链接

创建Maven项目


pom.xml   添加依赖：

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.9</version>
</dependency>


连接zk创建节点

	@Test
	public void createZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		//warcher shi guan cha zhe dui xiang ,yong yu hui diao
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		//zhuang tai dui xiang,zai getData shi hou, jie shou jie dian de zhuang tai xin xi
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root", "helloworld".getBytes(), acls, CreateMode.PERSISTENT);
		System.out.println("over");
	}



修改(更新)ZNode

@Test
	public void updateZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		//warcher shi guan cha zhe dui xiang ,yong yu hui diao
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		zk.setData("/root", "how are you?".getBytes(), 0);
		System.out.println("over");
	}


读取数据

	@Test
	public void getZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		
		Stat state = new Stat();
		byte[] bytes = zk.getData("/root", null, state);
		System.out.println(new String(bytes));
	}



创建临时节点

	@Test
	public void createEmpheralZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		System.out.println("over");
		// chuang jian lu jing 
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root/mynode", "helloworld".getBytes(), acls, CreateMode.EPHEMERAL);
		System.out.println("over");
		
	}






创建一个顺序性的永久性节点

@Test
	public void createSequenceZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		System.out.println("over");
		// chuang jian lu jing 
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root/mynode", "helloworld".getBytes(), acls, CreateMode.PERSISTENT_SEQUENTIAL);
		System.out.println("over");
		
	}


得到根下（孩子）子节点

@Test
	public void getChildren() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		
		List<String> list = zk.getChildren("/", null);
		for(String s : list){
			System.out.println(s);
		}
	}

删除节点

@Test
	public void deleteZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		zk.delete("/root/mynode0000000002", 0);
	}


全部代码：

import java.util.ArrayList;
import java.util.List;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooDefs.Perms;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Stat;
import org.junit.Test;

public class TestZookeeper {
	
//连接zk创建节点
	@Test
	public void createZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		//warcher shi guan cha zhe dui xiang ,yong yu hui diao
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		//zhuang tai dui xiang,zai getData shi hou, jie shou jie dian de zhuang tai xin xi
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root", "helloworld".getBytes(), acls, CreateMode.PERSISTENT);
		System.out.println("over");
	}
	
	
//修改(更新)ZNode
	
	@Test
	public void updateZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		//warcher shi guan cha zhe dui xiang ,yong yu hui diao
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		zk.setData("/root", "how are you?".getBytes(), 0);
		System.out.println("over");
	}
	
	
//读取数据
	@Test
	public void getZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		
		Stat state = new Stat();
		byte[] bytes = zk.getData("/root", null, state);
		System.out.println(new String(bytes));
	}
	
	
//创建临时节点
	@Test
	public void createEmpheralZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		System.out.println("over");
		// chuang jian lu jing 
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root/mynode", "helloworld".getBytes(), acls, CreateMode.EPHEMERAL);
		System.out.println("over");
		
	}
	
//创建一个顺序话的永久性节点	
	@Test
	public void createSequenceZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		System.out.println("over");
		// chuang jian lu jing 
		ACL acl = new ACL(Perms.ALL,ZooDefs.Ids.ANYONE_ID_UNSAFE);
		List<ACL> acls = new ArrayList<ACL>();
		acls.add(acl);
		zk.create("/root/mynode", "helloworld".getBytes(), acls, CreateMode.PERSISTENT_SEQUENTIAL);
		System.out.println("over");
		
	}	
	
	
//得到根下（孩子）子节点
	@Test
	public void getChildren() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		
		List<String> list = zk.getChildren("/", null);
		for(String s : list){
			System.out.println(s);
		}
	}	
	
	
//删除节点
	
	@Test
	public void deleteZNode() throws Exception{
	
		String conn = "master:2181,slave1:2181,slave2:2181";
		
		ZooKeeper zk = new ZooKeeper(conn , 50000, new Watcher() {
			public void process(WatchedEvent event) {
				System.out.println("over : " + event);
			}
		});
		
		zk.delete("/root/mynode0000000002", 0);
	}
	
}




Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生