zookeeper 客户端提示：instance must be started before calling this method

灰太狼 2023-10-10 10:38 12阅读 0赞

今天开始使用Curator ZooKeeper开源客户端。由于ZooKeeper原生的客户端比较低层，而且使用起来不方便，Netflix公司对ZooKeeper客户端API进行了封闭，提供一可以替代原生ZooKeeper客户端的框架——Curator，刚学习Curator，正尝试使用Curator编写znode节点的增、删、改、查，真是万事开头难，执行实例时就报错：java.lang.IllegalStateException: instance must be started before calling this method。

解决思路：

1、使用CuratorFramework的工厂函数生成客户端；

2、在操作ZK之前，记得先对客户端执行start()，启动客户端实例；

3、在操作ZK完成后，关闭客户端——close()。

核心代码:

public FileComponent(String zkServers, String root) {
    		this.root = root;
    		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
    		zkClient =   CuratorFrameworkFactory.builder()
                    .connectString(zkServers)
                    .sessionTimeoutMs(5000)
                    .connectionTimeoutMs(5000)
                    .retryPolicy(retryPolicy)
                    .namespace(root)
                    .build();
    		
    		try {
    			init();
    		} catch (Exception e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    
    	// 初始数据方法
    	@SuppressWarnings({ "resource", "unused" })
    	public void init() throws Exception {
    		ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xml);
    		String[] names = applicationContext.getBeanDefinitionNames();
    
    		int totalSize = names.length;
    		int pageSize = 2;
    		pageCount = (totalSize + pageSize - 1) / pageSize;
    
    		for (int i = 0; i < pageCount; i = i + 2) {
    
    			// 创建根节点的临时节点
    			if(zkClient.getState() != CuratorFrameworkState.STARTED){
    				zkClient.start();
    			}
    			zkClient.create().withMode(CreateMode.EPHEMERAL).forPath("/" + names[i + 1], names[i].getBytes());
    			
    			// 内存临时缓存
    			if (!list.contains(names[i + 1])) {
    				list.add(names[i + 1]);
    			}
    		}
    	}