将zookeeper curator与springboot项目进行整合(重点)

第一步：用java类进行配置

package com.lpy;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
//需要springboot去扫描,   springboot是通过java类来进行配置的
@Component
public class ZookeeperCuratorClient {
	//zookeeper客户端
	private CuratorFramework client =null;
	//日志(中间件的工具类都需要添加日志)
	final static Logger log=LoggerFactory.getLogger(ZookeeperCuratorClient.class);
	
	public static final String ZOOKEEPER_SERVER="192.168.4.245:2181";
	
	public void init() {
		if(client!=null) {
			return;
		}
		//第一步：创建重试策略
		RetryPolicy retryPolicy=new ExponentialBackoffRetry(1000,5);
		//第二步：创建zookeeper客户端
		client=CuratorFrameworkFactory.builder().connectString(ZOOKEEPER_SERVER)
												.sessionTimeoutMs(10000)
												.retryPolicy(retryPolicy)
												.namespace("admin").build();
		//第三步：启动客户端
		client.start();
		
		//测试
		try {
			String testNodeData = new String(client.getData().forPath("/bgm/..."));
			log.info("测试的节点数据为:{}",testNodeData);
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}

}
package com.lpy;
import