Nodejs客户端连接Zookeeper - 学习记录(四)

  • 2019-05-26 13:22:42
  • 479
  • 0

官网文档地址:


https://www.npmjs.com/package/node-zookeeper-client



NPM 安装node-zookeeper-client 模块:


npm install node-zookeeper-client


创建zookeeper.js 文件:


var Zookeeper = require('node-zookeeper-client');
var CONNECTION_STRING = "127.0.0.1:2181";
var OPTIONS = {
  sessionTimeout:5000
}
var zk = Zookeeper.createClient(CONNECTION_STRING,OPTIONS);
zk.on('connected',function(){
console.log("zk=====" zk);
zk.close();
});
zk.connect();


运作zookeeper.js 


node zookeeper.js





var Zookeeper = require('node-zookeeper-client');
var CONNECTION_STRING = "127.0.0.1:2181";
var OPTIONS = {
  sessionTimeout:5000
}
var zk = Zookeeper.createClient(CONNECTION_STRING,OPTIONS);
zk.on('connected',function(){
console.log("zk=====" zk);
zk.close();
});
//获取根节点下的子节点
zk.getChildren('/',function(error,children,stat){
     if(error){
        console.log(error.stack);
        return ;
     }
     console.log(children);
})
zk.connect();




//判断节点是否已存在
 zk.exists('/phpnode',function(error,stat){
    if(stat){
         console.log("节点存在");
    }else{
        console.log("节点不存在");
    }
 })


//创建节点
 zk.create('/phpnode',new Buffer('hello'),function(error,path){
    console.log(path);
 })


 //获取节点数据
zk.getData('/phpnode',function(error,data,stat){
    console.log(data.toString());
});


//节点删除
 zk.remove('/phpnode',function(error){
    if(!error){
        console.log('node 节点删除成功');
     }
 })


回复
举报
全部回复(0)

参与讨论