<?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);
}
现在运行该脚本。$ php zookeeperdemo1.php
此处应该会每隔2秒产生一个点。现在切换到ZooKeeper客户端,并更新“/test”值。[zk: 127.0.0.1:2181(CONNECTED) 20] set /test foo
这样就会静默触发PHP脚本中的“Insider Watcher”消息。
怎么会这样的?进入while结构后,为什么还能执行watcher方法。请各位看官发表讨论。

解决方案 »

  1.   

    分布式应用?
    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,包含一个简单的原语集,是Hadoop和Hbase的重要组件。目前提供Java和C的接口。你说是颠覆常识,也是可以理解的
      

  2.   

    不是谈分布式,分布式只是我业务需要而已。颠覆的地方是 -- 在PHP中,死循环的结构有机会执行循环外明显与循环无关的逻辑 -- 这是多线程的表现哦 -- 于是我们猜测这个zookeeper扩展是以多线程的方式在php环境中运行的。
      

  3.   

    Watcher gets consumed so we need to set a new one
    你做这个,应该比我还要清楚php Zookeeper 时时都在侦听 php 的行为
      

  4.   

    我不做这个,是刚打算做这个。我的意思是,如果有人写调试一段php代码,发现在死循环的过程中,有机会执行与循环完全没关系的代码,不会感到奇怪吗?
      

  5.   

    php中有个pcntl 能 fork出多进程执行