import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
private ConnectionStateListener createConnectionStateListener() {
	return new ConnectionStateListener() {
		@Override
		public void stateChanged(CuratorFramework client,
				ConnectionState newState) {
			LOGGER.log(Level.INFO,
					"Curator Connection state is changed to " + newState);
			if (newState == ConnectionState.CONNECTED) {
				zkConnected.set(true);
			} else if (newState == ConnectionState.SUSPENDED
					|| newState == ConnectionState.LOST) {
				zkConnected.set(false);
			} else if (newState == ConnectionState.RECONNECTED) {
				zkConnected.set(true);
			}
		}
	};
}
 

import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
public static CuratorFramework createZookeeperConnection(String connectString,
		int sessionTimeoutMs, int connectionTimeoutMs, ConnectionStateListener cnxnListener,
		int retrycount, int retryWaitTime, long sessionId, byte[] sessionPwd) throws Exception {
	
	RetryPolicy	retryPolicy = new RetryNTimes(retrycount , retryWaitTime);
		
	ZookeeperFactory factory = new ZooKeeperFactory(sessionId, sessionPwd);
	
	CuratorFramework client = CuratorFrameworkFactory.builder().zookeeperFactory(factory)
			.sessionTimeoutMs(sessionTimeoutMs)
			.connectionTimeoutMs(connectionTimeoutMs)
			.connectString(connectString).retryPolicy(retryPolicy).build();
			
	client.getConnectionStateListenable().addListener(cnxnListener);
	client.start();
	
	return client;
}
 

import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
private ConnectionStateListener createConnectionStateListener() {
	return new ConnectionStateListener() {
		@Override
		public void stateChanged(CuratorFramework client,
				ConnectionState newState) {
			if (LOGGER.isInfoEnabled())
				LOGGER.info(
						"Curator Connection state is changed to "
								+ newState);

			if (newState == ConnectionState.CONNECTED) {
				m_zkConnected.set(true);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper connected is set to true.");
				new Thread(new OnConnectedTask()).start();

			} else if (newState == ConnectionState.SUSPENDED
					|| newState == ConnectionState.LOST) {
				m_zkConnected.set(false);
				m_rebalanceable.set(false);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper connection is lost and it's now unrebalanceable.");

			} else if (newState == ConnectionState.RECONNECTED) {
				noticeZkReconnected();
				m_zkConnected.set(true);
				m_rebalanceable.set(true);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper is reconnected and it's rebalanceable again.");
			}
		}
	};
}