php联接zookeeper实例
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了php联接zookeeper实例,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含3606字,纯文字阅读大概需要6分钟。
内容图文
![php联接zookeeper实例](/upload/InfoBanner/zyjiaocheng/227/e1832578a3ec49dcac69d02f0888732f.jpg)
1、安装成功zookeeper后,在zookeeper 的bin目录下有启动相应的启动脚本
启动Server
./zkServer.sh start
启动client:(*注:cli需要安装java)
zkCli.sh
2、PHP实例:
<?php
class ZookeeperDemo extends Zookeeper { public function watcher( $i, $type, $key ) { echo "Insider Watcher\n" ; // Watcher gets consumed so we need to set a new one $this->get( '/test', array ($this, 'watcher' ) ); }}$zoo = new ZookeeperDemo( '127.0.0.1:2181' );$zoo->get( '/test', array ($zoo, 'watcher' ) );while ( true ) { echo '.' ; sleep(2);}leader与worker任务的分配:
class Worker extends Zookeeper {
const CONTAINER = '/cluster' ; protected $acl = array( array ( 'perms' => Zookeeper:: PERM_ALL, 'scheme' => 'world' , 'id' => 'anyone' ) ); private $isLeader = false; private $znode ; public function __construct( $host = '', $watcher_cb = null , $recv_timeout = 10000 ) { parent:: __construct( $host, $watcher_cb, $recv_timeout ); } public function register() { if( ! $this->exists( self ::CONTAINER ) ) { $this->create( self ::CONTAINER , null, $this-> acl ); } $this->znode = $this->create( self ::CONTAINER . '/w-' , null , $this->acl, Zookeeper::EPHEMERAL | Zookeeper::SEQUENCE ); $this-> znode = str_replace( self ::CONTAINER .'/' , '' , $this-> znode ); printf( "I'm registred as: %s\n", $this-> znode ); $watching = $this->watchPrevious(); if( $watching == $this-> znode ) { printf( "Nobody here, I'm the leader\n" ); $this->setLeader( true ); } else { printf( "I'm watching %s\n" , $watching ); } } public function watchPrevious() { $workers = $this->getChildren( self ::CONTAINER ); sort( $workers ); $size = sizeof( $workers ); for( $i = 0 ; $i < $size ; $i++ ) { if( $this-> znode == $workers[ $i ] ) { if ( $i > 0 ) { $this->get( self ::CONTAINER . '/' . $workers[ $i - 1 ], array ( $this, 'watchNode' ) ); return $workers[ $i - 1 ]; } return $workers[ $i ]; } } throw new Exception( sprintf( "Something went very wrong! I can't find myself: %s/%s", self ::CONTAINER , $this-> znode ) ); } public function watchNode( $i, $type, $name ) { $watching = $this->watchPrevious(); if( $watching == $this-> znode ) { printf( "I'm the new leader!\n" ); $this->setLeader( true ); } else { printf( "Now I'm watching %s\n" , $watching ); } } public function isLeader() { return $this-> isLeader ; } public function setLeader($flag) { $this-> isLeader = $flag; } public function run() { $this->register(); while( true ) { if( $this->isLeader() ) { $this->doLeaderJob(); } else { $this->doWorkerJob(); } sleep( 2 ); } } public function doLeaderJob() { echo "Leading\n" ; } public function doWorkerJob() { echo "Working\n" ; }}$worker = new Worker( '127.0.0.1:2181' );$worker->run();可以启动3个php进程,查看脚本的运行。进程1:
[[email protected] zookeeper]# php -f worker.php
I'm registred as: w-0000000010
Nobody here, I'm the leader
Leading
进程2:
[[email protected] zookeeper]$ php -f worker.php
I'm registred as: w-0000000011
I'm watching w-0000000010
Working
进程3:
[[email protected] zookeeper]$ php -f worker.php
I'm registred as: w-0000000012
I'm watching w-0000000011
Working
ctrl + c 关闭leader进程后,会发现进程2与3会选举出新的leader
内容总结
以上是互联网集市为您收集整理的php联接zookeeper实例全部内容,希望文章能够帮你解决php联接zookeeper实例所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。