Curator的分布式Barrier怎么實(shí)現(xiàn)

這篇文章主要介紹“Curator的分布式Barrier怎么實(shí)現(xiàn)”的相關(guān)知識，小編通過實(shí)際案例向大家展示操作過程，操作方法簡單快捷，實(shí)用性強(qiáng)，希望這篇“Curator的分布式Barrier怎么實(shí)現(xiàn)”文章能幫助大家解決問題。

創(chuàng)新互聯(lián)是一家成都做網(wǎng)站、成都網(wǎng)站建設(shè)，提供網(wǎng)頁設(shè)計(jì)，網(wǎng)站設(shè)計(jì)，網(wǎng)站制作，建網(wǎng)站，按需網(wǎng)站開發(fā)，網(wǎng)站開發(fā)公司，自2013年創(chuàng)立以來是互聯(lián)行業(yè)建設(shè)者，服務(wù)者。以提升客戶品牌價值為核心業(yè)務(wù)，全程參與項(xiàng)目的網(wǎng)站策劃設(shè)計(jì)制作，前端開發(fā)，后臺程序制作以及后期項(xiàng)目運(yùn)營并提出專業(yè)建議和思路。

分布式Barrier，直接看代碼好了：

package curator.barrier;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.barriers.DistributedBarrier;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class BarrierDemo {

	public static void main(String[] args) throws Exception {
		final List<DistributedBarrier> barriers = new ArrayList<DistributedBarrier>(3);
		ExecutorService service = Executors.newCachedThreadPool();

		for (int i = 0; i < 3; i++) {
			Runnable run = new Runnable() {
				public void run() {
					try {
						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();

						DistributedBarrier barrier = new DistributedBarrier(client, "/barrier");
						barriers.add(barrier);
						barrier.setBarrier(); // 設(shè)置barrier
						System.out.println(" : setBarrier...");
						barrier.waitOnBarrier();// 等待其他進(jìn)程移除barrier,此后所有的waitOnBarrier進(jìn)程都將解除阻塞.
						System.err.println(" : run ing...");
					} catch (Exception e) {
					}
				}
			};
			service.execute(run);
		}
		Thread.currentThread().sleep(5000);
		for (DistributedBarrier b : barriers) {
			b.removeBarrier();
		}
		System.in.read();
	}

}

關(guān)于“Curator的分布式Barrier怎么實(shí)現(xiàn)”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點(diǎn)。

當(dāng)前標(biāo)題：Curator的分布式Barrier怎么實(shí)現(xiàn)
標(biāo)題鏈接：http://muchs.cn/article28/geohcp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供小程序開發(fā)、品牌網(wǎng)站制作、自適應(yīng)網(wǎng)站、App設(shè)計(jì)、搜索引擎優(yōu)化、品牌網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)