zookeeper watch 节点
2016-08-16 11:27
120 查看
zjtest7-redis:/root/zk# cat a1.pl use ZooKeeper; use AnyEvent; use AE; use Data::Dumper; use IO::Socket; sub check_port { ( $server, $port ) = ('127.0.0.1','3306'); $sock = IO::Socket::INET->new(PeerAddr => $server, PeerPort => $port, Proto => 'tcp'); if ($sock) {return 1} else {return 0 }; }; my @ip_list=(); my $zk = ZooKeeper->new(hosts => '120.55.118.6:2181,120.55.118.6:2182,120.55.118.6:2183') ; #my $zk = ZooKeeper->new(hosts => '120.55.118.6:2182,120.55.118.6:2183') ; print "zk status\n"; print Dumper($zk->get('/mysql/0001')); print "zk status\n"; zjtest7-redis:/root/zk# perl a1.pl zk status $VAR1 = '192.168.32.6'; $VAR2 = { 'dataLength' => 12, 'cversion' => 0, 'mtime' => '1471311976986', 'czxid' => '21474837517', 'ephemeralOwner' => '240533560774754452', 'pzxid' => '21474837517', 'version' => 1, 'mzxid' => '21474837518', 'ctime' => '1471311976969', 'aversion' => 0, 'numChildren' => 0 }; zk status /*************************************** my $zk_value = $zk->get('/mysql/0001', watcher => sub { ###事件状态 my $event = shift; print "触发了事件."; print $event->{'type'}."\n"; print "事件状态."; print $event->{'state'}."\n"; $cv->send($event) } zookeeper watch 节点
相关文章推荐
- zookeeper watch 节点
- Google开源OCR项目Tesseract安装版在Windows下的使用测试记录
- hadoop配置lzo
- openstack 常用命令
- Eclipse快捷键大全
- . ERROR! The server quit without updating PID file
- 软件设计听课笔记
- 线程数据共享-ThreadLocal
- 并查集笔试题
- javaScript笔记(二十一) 事件对象
- 二叉树与树的理解
- aac格式解析
- HDU 1255(线段树,扫描线,矩形的面积交)
- poj1083-Moving Tables-贪心
- String s=new String("abc")创建了几个对象?
- PCB布线规则
- Pyhton的发展历程
- html导入css样式的方法
- 核心动画-关键帧动画易混淆属性记录
- 8-15日记