1、專案的目錄結構

2、基於zk服務註冊和發現的架構圖

3、服務端(像zk提供服務的訪問地址)

package cn.zk.distribute;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;

public class DistributedSystemServer {

	private ZooKeeper zk = null;

	private void getZkClient() throws Exception {

		// 伺服器在需求中並不需要做任何監聽
		zk = new ZooKeeper(GlobalConstants.zkhosts,
				GlobalConstants.sessionTimeout, null);

	}

	/**
	 * 向zookeeper中的/servers下建立子節點
	 * 
	 * @throws InterruptedException
	 * @throws KeeperException
	 */
	private void connectZK(String serverName, String port) throws Exception {

		// 先創建出父節點
		if (zk.exists(GlobalConstants.parentZnodePath, false) == null) {
			zk.create(GlobalConstants.parentZnodePath, null,
					Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
		}

		// 連線zk建立znode
		zk.create(GlobalConstants.parentZnodePath + "/",
				(serverName + ":" + port).getBytes(), Ids.OPEN_ACL_UNSAFE,
				CreateMode.EPHEMERAL_SEQUENTIAL);
		System.out.println("server " + serverName + " is online ......");

	}

	// 伺服器的具體業務處理功能
	private void handle(String serverName) throws Exception {
		System.out.println("server " + serverName
				+ " is waiting for task process......");
		Thread.sleep(Long.MAX_VALUE);

	}

	public static void main(String[] args) throws Exception {

		DistributedSystemServer server = new DistributedSystemServer();

		// 獲取與zookeeper通訊的客戶端連線
		server.getZkClient();

		// 一啟動就去zookeeper上註冊伺服器資訊，引數1： 伺服器的主機名 引數2：伺服器的監聽埠
		server.connectZK(args[0], args[1]);

		// 進入業務邏輯處理流程
		server.handle(args[0]);

	}

}
 

2、客戶端(獲取zk提供的服務地址，並呼叫服務)

package cn.zk.distribute;

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

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.EventType;

public class DistributedSystemClient {

	private volatile List<String> servers = null;
	private ZooKeeper zk = null;

	// 獲取zk連線
	private void getZkClient() throws Exception {

		// 伺服器在需求中並不需要做任何監聽
		zk = new ZooKeeper(GlobalConstants.zkhosts,
				GlobalConstants.sessionTimeout, new Watcher() {

					@Override
					public void process(WatchedEvent event) {

						if (event.getType() == EventType.None)
							return;

						try {
							// 獲取新的伺服器列表,重新註冊監聽
							updateServers();

						} catch (Exception e) {

							e.printStackTrace();
						}

					}
				});

	}

	/**
	 * 從zk中獲取線上伺服器資訊
	 */
	public void updateServers() throws Exception {

		// 從servers父節點下獲取到所有子節點，並註冊監聽
		List<String> children = zk.getChildren(GlobalConstants.parentZnodePath,
				true);

		ArrayList<String> serverList = new ArrayList<String>();

		for (String child : children) {

			byte[] data = zk.getData(GlobalConstants.parentZnodePath + "/"
					+ child, false, null);

			serverList.add(new String(data));

		}

		// 如果客戶端是一個多執行緒程式，而且各個執行緒都會競爭訪問servers列表，所以，在成員中用volatile修飾了一個servers變數
		// 而在更新伺服器資訊的這個方法中，是用一個臨時List變數來進行更新
		servers = serverList;

		// 將更新之後的伺服器列表資訊列印在控制檯觀察一下
		for (String server : serverList) {

			System.out.println(server);
		}
		System.out.println("===================");

	}

	/**
	 * 業務邏輯
	 * 
	 * @throws InterruptedException
	 */
	private void requestService() throws InterruptedException {
		Thread.sleep(Long.MAX_VALUE);

	}

	public static void main(String[] args) throws Exception {

		DistributedSystemClient client = new DistributedSystemClient();

		// 先構造一個zk的連線
		client.getZkClient();

		// 獲取伺服器列表
		client.updateServers();

		// 客戶端進入業務流程，請求伺服器的服務
		client.requestService();

	}

}
 

3、用到的常量配置資訊

package cn.zk.distribute;

public class GlobalConstants {
	// zk伺服器列表
	public static final String zkhosts = "192.168.2.118:2181";
	// 連線的超時時間
	public static final int sessionTimeout = 2000;
	// 服務在zk下的路徑
	public static final String parentZnodePath = "/servers";

}

4、將服務端，匯出為可以執行的jar檔案

jar的執行

[[email protected] Desktop]# java -jar server.jar 192.168.2.11 4567

5、將客戶端，匯出為可以執行的jar檔案

      步驟與上面的4相同，可以參照上面的步驟過程。

7、原始碼下載

連結：http://pan.baidu.com/s/1eRHHGBK 密碼：9d90