'zookeeper'

+const model = require('../../../lib/model');
+const {DegradeServer} = require('../../models');
+const zookeeperHelpers = require('../../zookeeper-helpers');
+
+class ZookeeperModel extends model {
+    constructor(ctx) {
+        super(ctx);        
+    }
+    async getConfigAll() {
+        return await DegradeServer.findAll();
+    }
+    async setPath(path, val) {
+        let degradeServer = await DegradeServer.findAll();
+        let results = [];
+
+        (degradeServer || []).each(item => {
+            results.push(await zookeeperHelpers.creator(`${item.ip}:${item.port}`, path, val, true));
+        });
+
+        return results[0]; // return Boolean
+    }
+    async getPath(path) {
+        let degradeServer = await DegradeServer.findAll();
+
+        if (degradeServer[0]) {
+            return await zookeeperHelpers.getter(`${item.ip}:${item.port}`, path);
+        }
+
+        return null;
+    }
+}
+
+module.exports = ZookeeperModel;

+'usu strict';
+
+const _ = require('lodash');
+const zookeeper = require('node-zookeeper-client');
+
+const _exists = (client, path) => new Promise((resolve, reject) => {
+    client.exists(path, (err, stat) => {
+        if (err) {
+            console.log('path %s exits error', path, err.stack);
+            resolve(false);
+        } else {
+            resolve(stat ? true : false);
+        }
+    });
+});
+
+const exists = (server, path) => new Promise((resolve, reject) => {
+    const client = zookeeper.createClient(server);
+
+    client.once('connected', function () {
+        _exists(client, path).then(stat => {
+            resolve(stat);
+            client.close();
+        });
+    });
+
+    client.connect();
+});
+
+const creator = (server, path, value, iscover) => new Promise((resolve, reject) => {
+    const client = zookeeper.createClient(server);
+
+    client.once('connected', function () {
+        _exists(client, path).then(stat => {
+            if (stat && iscover) {
+                client.setData(path, new Buffer(val.toString()), function(err, data, stat) {
+                    if (err) {
+                        console.log('update path %s data error');
+                        resolve(false);
+                    } else {
+                        console.log('path %s data change to', path, val);
+                        resolve(true);
+                    }
+                });
+            } else if (stat) {
+                resolve(true);
+            } else {
+                client.mkdirp(path, new Buffer(value), (err, path) => {
+                    if (err) {
+                        console.log('Node %s create err', path, err.stack);
+                        resolve(false);
+                    } else {
+                        console.log('Node %s is created', path);
+                        resolve(true);
+                    }
+                });
+            }
+            client.close();
+        });
+    });
+
+    client.connect();
+});
+
+const getter = (server, path) => new Promise((resolve, reject) => {
+    const client = zookeeper.createClient(server);
+
+    client.once('connected', function () {
+        _exists(client, path).then(stat => {
+            if (stat) {
+                client.getData(
+                    path,
+                    (err, data, statData) => {
+                        if (err) {
+                            console.log('Got path %s data error', path, err.stack);
+                        }
+
+                        client.close();
+
+                        resolve(data && data.toString('utf8'));
+                    }
+                )
+            } else {
+                // 不存在的路径
+                console.log('no path %s, we will create it with value "false" automatic', path);
+                client.close();
+                resolve();
+            }
+        })
+    });
+
+    client.connect();
+});
+
+const setter = (server, path, val) => new Promise((resolve, reject) => {
+    const client = zookeeper.createClient(server);
+
+    client.once('connected', function () {
+        _exists(client, path).then(stat => {
+            if (stat) {
+                client.setData(path, new Buffer(val.toString()), function(err, data, stat) {
+                    if (err) {
+                        console.log('update path %s data error');
+                        resolve(false);
+                    } else {
+                        console.log('path %s data change to', path, val);
+                        resolve(true);
+                    }
+
+                    client.close();
+                });
+            } else {
+                resolve(false);
+            }
+        });
+    });
+
+    client.connect();
+});
+
+
+module.exports = {
+    exists,
+    creator,
+    setter,
+    getter
+};