zookeeper手把手教程（三）

1. java API的使用

  1. 導入jar包
<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.8</version>
</dependency>

權限控制模式(ZooDefs.Ids.==ANYONE_ID_UNSAFE/AUTH_IDS/OPEN_ACL_UNSAFE/CREATOR_ALL_ACL/READ_ACL_UNSAFE==)

  • scheme 授權對象
  • ip :192.168.1.1
  • Digest :username:password
  • world :開放式的權限控制模式，數(shù)據(jù)節(jié)點的訪問權限隊所有用戶開放哎垦。world:anyone
  • super :超級用戶漏设，可以對zookeeper上的數(shù)據(jù)節(jié)點進行操作
package com.frame.test.gp.zookeeperAPI;

import org.apache.zookeeper.Watcher;

import com.frame.test.gp.zookeeperAPI.ZookeeperAPIDemo;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;
import java.security.NoSuchAlgorithmException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;

public class AuthControlDemo implements Watcher {
    private final static String CONNECTSTRING="192.168.202.133:2181,192.168.202.134:2181,192.168.202.135:2181";
    private static CountDownLatch countDownLatch=new CountDownLatch(1);
    private static CountDownLatch countDownLatch2=new CountDownLatch(1);

    private static ZooKeeper zookeeper;
    private static Stat stat=new Stat();
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException, NoSuchAlgorithmException {
        zookeeper=new ZooKeeper(CONNECTSTRING, 5000, new AuthControlDemo());
        countDownLatch.await();


        ACL acl=new ACL(ZooDefs.Perms.CREATE, new Id("digest","root:root"));
        ACL acl2=new ACL(ZooDefs.Perms.CREATE, new Id("ip","192.168.1.1"));

        List<ACL> acls=new ArrayList<>();
        acls.add(acl);
        //acls.add(acl2);
        zookeeper.create("/auth1","123".getBytes(),acls,CreateMode.PERSISTENT);
        zookeeper.addAuthInfo("digest","root:root".getBytes());

        zookeeper.create("/auth1","123".getBytes(), ZooDefs.Ids.CREATOR_ALL_ACL,CreateMode.PERSISTENT);

        zookeeper.create("/auth1/auth1-1","123".getBytes(),ZooDefs.Ids.CREATOR_ALL_ACL,CreateMode.PERSISTENT);

        ZooKeeper zooKeeper1= new ZooKeeper(CONNECTSTRING, 5000, new AuthControlDemo());
        countDownLatch.wait();;
        zooKeeper1.delete("/auth1",-1);

        // acl (create /delete /admin /read/write)
        //權限模式： ip/Digest（username:password）/world/super

    }
    public void process(WatchedEvent watchedEvent) {
        //如果當前的連接狀態(tài)是連接成功的鸳碧，那么通過計數(shù)器去控制
        if(watchedEvent.getState()==Event.KeeperState.SyncConnected){
            if(Event.EventType.None==watchedEvent.getType()&&null==watchedEvent.getPath()){
                countDownLatch.countDown();
                System.out.println(watchedEvent.getState()+"-->"+watchedEvent.getType());
            }
        }

    }
}
  1. 節(jié)點的增刪改查瞻离，以及事件監(jiān)聽
package com.frame.test.gp.zookeeperAPI;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

/**
 * @author Administrator
 * @CREATE 2017/8/5 21:21
 */
public class ZookeeperAPIDemo implements Watcher {
    private static final String CONNECTSTRING = "192.168.202.133:2181,192.168.202.134:2181,192.168.202.135:2181";

    private static ZooKeeper zookeeper;
    //concurrent 原子并發(fā)包的工具套利，需要查看
    private static CountDownLatch countDownLatch = new CountDownLatch(1);

    private static Stat stat = new Stat();

    public static ZooKeeper getConnection() throws IOException, InterruptedException {
        zookeeper = new ZooKeeper(ZookeeperAPIDemo.CONNECTSTRING, 5000, new ZookeeperAPIDemo());
        countDownLatch.await();
        return zookeeper;
    }

    /**
    *代碼不復雜日裙，每個都試驗一下昂拂，配合到客戶端操作驗證結(jié)果
    */
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        zookeeper = getConnection();
        //創(chuàng)建節(jié)點
        String result =zookeeper.create("/node1","123".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
        zookeeper.getData("/node1",new ZookeeperAPIDemo(),stat);
        System.out.println("創(chuàng)建成功:"+result);

        //修改節(jié)點
        zookeeper.setData("/node1","666".getBytes(),-1);
        System.out.println(zookeeper.getData("/node1",new ZookeeperAPIDemo(),stat));

        //刪除節(jié)點格侯，先從子節(jié)點刪除联四，不然會報錯朝墩，
        zookeeper.delete("/node1",-1);

        //創(chuàng)建持久化節(jié)點和子節(jié)點
        String path="/node11";
        zookeeper.create(path,"123".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
        TimeUnit.SECONDS.sleep(1);

        Stat stat=zookeeper.exists(path+"/node1",true);
        if (stat == null){
            zookeeper.create(path+"/node1","123".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
            TimeUnit.SECONDS.sleep(1);
        }

        //修改子路徑
        zookeeper.setData(path+"/node1","mic123".getBytes(),-1);
        TimeUnit.SECONDS.sleep(1);

    }

    @Override
    public void process(WatchedEvent watchedEvent) {
        //如果當前的連接狀態(tài)時成功的收苏，那么通過計數(shù)器去控制
        if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
            if (Event.EventType.None == watchedEvent.getType() && null == watchedEvent.getPath()) {
                countDownLatch.countDown();
                System.out.println("process:"+watchedEvent.getState() + "-->" + watchedEvent.getType());
            } else if (watchedEvent.getType() == Event.EventType.NodeDataChanged) {
                try {
                    System.out.println("數(shù)據(jù)變更觸發(fā)路徑：" + watchedEvent.getPath() + "->改變后的值" + zookeeper.getData(watchedEvent.getPath(), true, stat));
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            } else if (watchedEvent.getType() == Event.EventType.NodeChildrenChanged){  //子節(jié)點數(shù)據(jù)變化會觸發(fā)
                try {
                    System.out.println("子節(jié)點數(shù)據(jù)變更路徑："+watchedEvent.getPath()+"->節(jié)點的值："+ zookeeper.getData(watchedEvent.getPath(),true,stat));
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }else if (watchedEvent.getType()==Event.EventType.NodeCreated){   //創(chuàng)建子節(jié)點的時候回觸發(fā)
                try {
                    System.out.println("節(jié)點創(chuàng)建路徑："+watchedEvent.getPath()+"->節(jié)點的值："+ zookeeper.getData(watchedEvent.getPath(),true,stat));
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }else if (watchedEvent.getType()== Event.EventType.NodeDeleted){  //子節(jié)點刪除會觸發(fā)
                System.out.println("節(jié)點刪除路徑："+watchedEvent.getPath());
            }
            System.out.println("process:"+watchedEvent.getType());
        }
    }

}

連接狀態(tài)

  • KeeperStat.Expired 在一定時間內(nèi)客戶端沒有收到服務器的通知，則認為當前的會話已經(jīng)過期
  • KeeperStat.Disconnected 斷開連接的狀態(tài)
  • KeeperStat.SyncConnected 客戶端和服務器端在某一個節(jié)點上建立連接懦鼠，并且完成一次version屹堰、直到同步扯键。
  • KeeperStat.authFailed 授權失敗

事件類型

  • NodeCreated 節(jié)點被創(chuàng)建的時候忧陪，觸發(fā)
  • NodeChildrenChanged 表示子節(jié)點被創(chuàng)建、刪除延蟹、子節(jié)點的數(shù)據(jù)發(fā)生變化
  • NodeDataChanged 節(jié)點數(shù)據(jù)發(fā)生變化
  • NodeDeleted 節(jié)點被刪除
  • Node 客戶端和服務器端連接狀態(tài)發(fā)生變化的時候阱飘，事件類型就是None

2. zkclient

package com.frame.test.gp.zookeeperAPI;

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;

import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * @author Administrator
 * @CREATE 2017/8/8 20:51
 */
public class zkClientApiOperatorDemo {
    private final static String CONNECTSTRING="192.168.202.133:2181,192.168.202.134:2181,192.168.202.135:2181";

    private static ZkClient getInstance(){

        return new ZkClient(CONNECTSTRING);
    }

    public static void main(String[] args) throws InterruptedException {
        ZkClient zkClient=getInstance();
        //zkclient 提供遞歸創(chuàng)建父節(jié)點功能
        zkClient.createPersistent("/zkclient/zkclient1",true);
        System.out.println("success");

        //刪除節(jié)點
        //zkClient.delete("/auth1");
        //遞歸刪除節(jié)點
        //zkClient.deleteRecursive("/zkclient");

        //獲取父節(jié)點下的子節(jié)點
        List<String> list =zkClient.getChildren("/zkclient");
        System.out.println(list);

        //訂閱數(shù)據(jù)修改事件
        zkClient.subscribeDataChanges("/zkclient", new IZkDataListener() {
            @Override
            public void handleDataChange(String dataPath, Object data) throws Exception {
                System.out.println(dataPath+"->"+data);
            }

            @Override
            public void handleDataDeleted(String dataPath) throws Exception {
                System.out.println("delete path"+dataPath);
            }
        });

        //修改節(jié)點數(shù)據(jù)
        zkClient.writeData("/zkclient","zkclient-data");
        TimeUnit.SECONDS.sleep(2);

        zkClient.deleteRecursive("/zkclient");
        TimeUnit.SECONDS.sleep(2);


    }
}

3. curator

  • Curator是Netflix公司開源的zookeeper客戶端;
  • curator-frameword 提供了fluent風格的api
  • curator-replice 提供了實現(xiàn)封裝
  • curator鏈接的重試策略
  • ExponentialBackOffRetry() 衰減重試
  • RetryNtimes 指定最大重試次數(shù)
  • RetryOneTime 僅重試一次
  • RetryunitilElapsed 一直重試直到規(guī)定的時間
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.9.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-client</artifactId>
    <version>2.9.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.9.0</version>
</dependency>

==pom同時存在zookeeper/zkclient/guava斥杜，就會報錯，啟動不了==

package com.frame.test.gp.zookeeperAPI.curator;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

/**
 * @author Administrator
 * @CREATE 2017/8/8 22:17
 */
public class CuratorClientUtils {

    private static CuratorFramework curatorFramework;

    private final static String CONNECTSTRING = "192.168.202.133:2181,192.168.202.134:2181,192.168.202.135:2181";

    public static CuratorFramework getInstance() {
        //fluent 風格
         curatorFramework=CuratorFrameworkFactory.builder().connectString(CONNECTSTRING).sessionTimeoutMs(5000).retryPolicy(
                new ExponentialBackoffRetry(1000,3)).build();
        //normal
        //curatorFramework = CuratorFrameworkFactory.newClient(CONNECTSTRING, 5000, 5000, new ExponentialBackoffRetry(1000, 3));
        curatorFramework.start();
        return curatorFramework;
    }
}


package com.frame.test.gp.zookeeperAPI.curator;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.BackgroundCallback;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.curator.framework.api.transaction.CuratorTransactionResult;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat;

import java.util.Collection;
import java.util.Collections;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author Administrator
 * @CREATE 2017/8/8 21:25
 */
public class CuratorCreateSessionDemo {
    public static void main(String[] args) throws Exception {

        CuratorFramework curatorFramework = CuratorClientUtils.getInstance();
        System.out.println("連接成功.......");
        /**
         *【curator使用異沉ば伲】KeeperErrorCode = Unimplemented for /***
         *Curator的版本過高造成蔗喂，換成低一點版本即可 （version從3.0.0到2.9.1）
         */

        //新增節(jié)點，所有操作都可以在zkCli.sh 中驗證高帖。
        String result = curatorFramework.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).forPath("/curator/curator1/curator11", "123".getBytes());
        System.out.println(result);

        //刪除子節(jié)點
        curatorFramework.delete().forPath("/curator/curator1/curator11");

        //遞歸刪除節(jié)點
        //curatorFramework.delete().deletingChildrenIfNeeded().forPath("/curator");

        //查詢數(shù)據(jù)缰儿，以及狀態(tài)
        Stat stat = new Stat();
        byte[] bytes = curatorFramework.getData().storingStatIn(stat).forPath("/curator");
        System.out.println(new String(bytes) + "-->state:" + stat);  //值 前面章節(jié)講過散址；

        //更新
        Stat stat1 = curatorFramework.setData().forPath("/curator", "123".getBytes());
        System.out.println(stat1);


        /**
         * 特性:
         * 異步操作
         */
        ExecutorService executorService = Executors.newFixedThreadPool(1);
        CountDownLatch countDownLatch=new CountDownLatch(1);
        curatorFramework.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).inBackground(new BackgroundCallback() {
            @Override
            public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
                //創(chuàng)建節(jié)點是有線程池處理的乖阵，異步操作
                System.out.println(Thread.currentThread().getName() + "->resultCode:" + event.getResultCode() + "->" + event.getType());
                countDownLatch.countDown();
            }
        }, executorService).forPath("/sync", "123".getBytes());
        countDownLatch.await();
        executorService.shutdown();


        /**
         * 事務操作(curator獨有的)
         */
        //在同一個事務，先創(chuàng)建一個transaction節(jié)點预麸，然后又修改trans這個節(jié)點的值瞪浸。 這樣就會報錯，修改的不是同一個節(jié)點吏祸。然后ls / 对蒲，發(fā)現(xiàn)zookeeper客戶端并沒有創(chuàng)建這個節(jié)點
        /*Collection<CuratorTransactionResult> resultCollection=curatorFramework.inTransaction().create().forPath("/transaction","transaction".getBytes()).and().setData().forPath("/trans","transaction roll back".getBytes()).and().commit();
        for (CuratorTransactionResult curatorTransactionResult:resultCollection){
            System.out.println(curatorTransactionResult.getForPath()+"->"+curatorTransactionResult.getType());
        }*/

        //在同一個事務，先創(chuàng)建一個transaction節(jié)點贡翘，然后又修改transaction這個節(jié)點的值蹈矮。這樣查看數(shù)據(jù)的值發(fā)現(xiàn)更新了
        Collection<CuratorTransactionResult> resultCollection1=curatorFramework.inTransaction().create().forPath("/transaction","transaction".getBytes()).and().setData().forPath("/transaction","transaction update ".getBytes()).and().commit();
        for (CuratorTransactionResult curatorTransactionResult:resultCollection1){
            System.out.println(curatorTransactionResult.getForPath()+"->"+curatorTransactionResult.getType());
        }
    }
}


package com.frame.test.gp.zookeeperAPI.curator;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.framework.recipes.cache.PathChildrenCache;
import org.apache.zookeeper.CreateMode;

import java.util.concurrent.TimeUnit;

/**
 * @author Administrator
 * @CREATE 2017/8/8 23:31
 */
public class CuratorEventDemo {
    /**
     * 三種watcher來做節(jié)點的監(jiān)聽
     * pathCache  監(jiān)視一個路徑下子節(jié)點的創(chuàng)建、刪除床估、節(jié)點數(shù)據(jù)更新
     * NodeCache  監(jiān)視一個節(jié)點的創(chuàng)建、更新诱渤、刪除
     * TreeCache  pathCache + NOdeCache(監(jiān)視路徑下的創(chuàng)建丐巫、更新、刪除事件)勺美，緩存路徑下所有子節(jié)點的數(shù)據(jù)
     */

    public static void main(String[] args) throws Exception {
        CuratorFramework curatorFramework = CuratorClientUtils.getInstance();

        /**
         * NodeCache
         */
        /*
        NodeCache cache=new NodeCache(curatorFramework,"/curator",false);
        cache.start();

        cache.getListenable().addListener(()-> System.out.println("節(jié)點數(shù)據(jù)發(fā)生變化递胧，變化后的結(jié)果為："+new String(cache.getCurrentData().getData())));

        curatorFramework.setData().forPath("/curator","update".getBytes());*/


        /**
         * PathChildrenCache 監(jiān)聽/event 下的子節(jié)點
         */

        PathChildrenCache childrenCache = new PathChildrenCache(curatorFramework, "/event", true);
        //NORMAL: 初始時為空。
        //BUILD_INITIAL_CACHE: 在這個方法返回之前調(diào)用rebuild()赡茸。
        //POST_INITIALIZED_EVENT: 當Cache初始化數(shù)據(jù)后發(fā)送一個PathChildrenCacheEvent.Type #INITIALIZED事件
        childrenCache.start(PathChildrenCache.StartMode.NORMAL);
        childrenCache.getListenable().addListener((curatorFramework1, pathChildrenCacheEvent) -> {
            switch (pathChildrenCacheEvent.getType()) {
                case CHILD_ADDED:
                    System.out.println("增加子節(jié)點");
                    break;
                case CHILD_REMOVED:
                    System.out.println("刪除子節(jié)點");
                    break;
                case CHILD_UPDATED:
                    System.out.println("更新子節(jié)點");
                    break;
                default:
                    break;
            }
        });

        curatorFramework.create().withMode(CreateMode.PERSISTENT).forPath("/event","events".getBytes());
        TimeUnit.SECONDS.sleep(1);
        System.out.println(1);

        //pathChildrenCache 會遞歸監(jiān)聽子節(jié)點時間,所以子節(jié)點創(chuàng)建打印出來了
        curatorFramework.create().withMode(CreateMode.EPHEMERAL).forPath("/event/event1","1".getBytes());
        TimeUnit.SECONDS.sleep(1);

        curatorFramework.setData().forPath("/event/event1","666".getBytes());
        TimeUnit.SECONDS.sleep(1);

        curatorFramework.delete().deletingChildrenIfNeeded().forPath("/event");
        System.in.read();
    }


}

主要是動手缎脾，大家多動手多學習；--黑白 2017/8/9 0:21

最后編輯于 ：
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末占卧，一起剝皮案震驚了整個濱河市遗菠，隨后出現(xiàn)的幾起案子联喘，更是在濱河造成了極大的恐慌，老刑警劉巖辙纬，帶你破解...
    沈念sama閱讀 217,509評論 6贊 504
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件豁遭，死亡現(xiàn)場離奇詭異，居然都是意外死亡贺拣，警方通過查閱死者的電腦和手機蓖谢，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,806評論 3贊 394
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來譬涡，“玉大人闪幽，你說我怎么就攤上這事∥性龋” “怎么了盯腌？”我有些...
    開封第一講書人閱讀 163,875評論 0贊 354
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵，是天一觀的道長渊跋。 經(jīng)常有香客問我腊嗡，道長，這世上最難降的妖魔是什么拾酝？ 我笑而不...
    開封第一講書人閱讀 58,441評論 1贊 293
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任燕少，我火速辦了婚禮，結(jié)果婚禮上蒿囤，老公的妹妹穿的比我還像新娘客们。我一直安慰自己，他們只是感情好材诽，可當我...
    茶點故事閱讀 67,488評論 6贊 392
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布底挫。 她就那樣靜靜地躺著，像睡著了一般脸侥。 火紅的嫁衣襯著肌膚如雪建邓。 梳的紋絲不亂的頭發(fā)上，一...
    開封第一講書人閱讀 51,365評論 1贊 302
  • 城市分裂傳說
    那天睁枕，我揣著相機與錄音官边，去河邊找鬼。 笑死外遇，一個胖子當著我的面吹牛注簿，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播跳仿，決...
    沈念sama閱讀 40,190評論 3贊 418
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼诡渴，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了菲语？” 一聲冷哼從身側(cè)響起妄辩，我...
    開封第一講書人閱讀 39,062評論 0贊 276
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤惑灵，失蹤者是張志新（化名）和其女友劉穎，沒想到半個月后恩袱，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體泣棋，經(jīng)...
    沈念sama閱讀 45,500評論 1贊 314
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,706評論 3贊 335
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年畔塔，在試婚紗的時候發(fā)現(xiàn)自己被綠了潭辈。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,834評論 1贊 347
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡澈吨，死狀恐怖把敢，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情谅辣，我是刑警寧澤修赞，帶...
    沈念sama閱讀 35,559評論 5贊 345
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站桑阶，受9級特大地震影響柏副，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜蚣录，卻給世界環(huán)境...
    茶點故事閱讀 41,167評論 3贊 328
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一割择、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧萎河，春花似錦荔泳、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,779評論 0贊 22
  • 一樁弒父案玛歌，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至擎椰，卻和暖如春支子，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背达舒。 一陣腳步聲響...
    開封第一講書人閱讀 32,912評論 1贊 269
  • 情欲美人皮
    我被黑心中介騙來泰國打工值朋， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留，地道東北人休弃。 一個月前我還...
    沈念sama閱讀 47,958評論 2贊 370
  • 代替公主和親
    正文 我出身青樓吞歼，卻偏偏與公主長得像圈膏，于是被迫代替她去往敵國和親塔猾。 傳聞我的和親對象是個殘疾皇子，可洞房花燭夜當晚...
    茶點故事閱讀 44,779評論 2贊 354

推薦閱讀更多精彩內(nèi)容

  • 一稽坤、ZooKeeper的背景 1.1 認識ZooKeeper ZooKeeper---譯名為“動物園管理員”丈甸。動物...
    algernoon閱讀 9,071評論 1贊 106
  • ZooKeeper是一個分布式的糯俗，開放源碼的分布式應用程序協(xié)調(diào)服務，它包含一個簡單的原語集睦擂，分布式應用程序可以基于...
    Prize閱讀 243評論 0贊 1
  • ZooKeeper介紹 Zookeeper 分布式服務框架是 Apache Hadoop 的一個子項目得湘，它主要是用...
    Coselding閱讀 11,406評論 1贊 37
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務發(fā)現(xiàn)顿仇，斷路器淘正，智...
    卡卡羅2017閱讀 134,654評論 18贊 139
  • 上海南京路大名鼎鼎，所有到上海的人一定要去步行街瞅一眼臼闻，感受一下摩肩接踵的滋味鸿吆。南京西路更是因為前有恒隆后有梅隴鎮(zhèn)...
    凌均閱讀 527評論 1贊 5