本篇內(nèi)容主要講解“zookeeper的選舉法怎么用”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“zookeeper的選舉法怎么用”吧!

十余年的監(jiān)利網(wǎng)站建設經(jīng)驗，針對設計、前端、開發(fā)、售后、文案、推廣等六對一服務，響應快，48小時及時工作處理。成都營銷網(wǎng)站建設的優(yōu)勢是能夠根據(jù)用戶設備顯示端的尺寸不同，自動調(diào)整監(jiān)利建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設計，從而大程度地提升瀏覽體驗。創(chuàng)新互聯(lián)建站從事“監(jiān)利網(wǎng)站設計”,“監(jiān)利網(wǎng)站推廣”以來，每個客戶項目都認真落實執(zhí)行。

Curator的實現(xiàn)有2個種：

LeaderLatch：

       這種是有阻塞的，就是大家一起上，誰先上了，就一直阻塞著，直到方法執(zhí)行完成。如果執(zhí)行結束，那么其他的兄弟就選一個出來。我覺得這種適合主備，比如開2 個 job，一個掛了另一個就上。

代碼，這種代碼最好是開2個eclipse看效果，順序打開，看效果，再領悟：

package curator.selector;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.leader.LeaderLatch;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class LeaderLatchDemo {

	public static void main(String[] args) throws Exception {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		CuratorFramework client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(2000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("text").build();
		client.start();
		// 選舉Leader 啟動
		LeaderLatch latch = new LeaderLatch(client,"/path");
		latch.start();
		latch.await();
		System.err.println("我啟動了");
		Thread.currentThread().sleep(1000000);
		latch.close();
		client.close();
	}
}

LeaderSelector：

      這種復雜一點，他有個leaderSelector.autoRequeue();就是自動搶，比如打印一個helloworld，第一個打印完，第2個打印，然后第3個打印。然后第一個再打印，大家一起搶。有點動態(tài)選舉的味道。

代碼：

package curator.selector;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.leader.LeaderSelector;
import org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class LeaderSelectorDemo {

	public static void main(String[] args) throws Exception {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		final CuratorFramework client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("text").build();
		client.start();
		
		final LeaderSelector leaderSelector = new LeaderSelector(client, "/led", new LeaderSelectorListenerAdapter(){

			@Override
			public void takeLeadership(CuratorFramework client) throws Exception {
				System.err.println("work ing...");
				Thread.currentThread().sleep(3000);
				System.err.println("end");
			}
			
		});
		leaderSelector.autoRequeue();
		leaderSelector.start();
		System.in.read();
	}
}

到此，相信大家對“zookeeper的選舉法怎么用”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關內(nèi)容可以進入相關頻道進行查詢，關注我們，繼續(xù)學習！