搜索

首页  >  文章  >  后端开发  >  php的zookeeper扩展怎么安装

php的zookeeper扩展怎么安装

藏色散人
藏色散人原创
2021-03-08 10:31:042478浏览

php安装 zookeeper扩展的方法：首先下载zookeeper；然后指定一下安装目录；最后通过“make && make install”安装zookeeper即可。

php的zookeeper扩展怎么安装

本文操作环境：Windows7系统、PHP7.1、Dell G3电脑。

ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

ZooKeeper的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。

要在php中使用zookeeper，先要安装php zookeeper扩展，要安装php zookeeper扩展，得先安装zookeeper

1、安装zookeeper

在这里面下载最新版的稳定版

http://mirror.bit.edu.cn/apache/zookeeper/stable/

cd /download

wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz //这个是已经安装好的工具，下面我们还需要自己编译安装一下，因为后面安装php的扩展时用得到

tar -zxvf zookeeper-3.4.12.tar.gz

cd zookeeper-3.4.12/src/c/

./configure --prefix=/usr/local/zookeeper  //指定一下安装目录

make && make install

就这样安装完了

2、安装php zookeeper的扩展  在 http://pecl.php.net/package/zookeeper中找

cd /download

wget http://pecl.php.net/get/zookeeper-0.6.2.tgz

tar -zxvf zookeeper-0.6.2.tgz

 cd zookeeper-0.6.2

./configure --with-libzookeeper-dir=/usr/local/zookeeper //要指定依赖

make && make install

配置php.ini

extension="/usr/local/Cellar/php/7.2.6/pecl/20170718/zookeeper.so"

重启php-fpm即可。

【推荐：《PHP视频教程》】

3、启动zookeeper前要安装jdk  已经安装的可以忽略

在http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html里面下载

然后傻瓜式安装，这里不说了

4、启动zookeeper

cd /download/zookeeper-3.4.12/bin

 ./zkServer.sh start

./zkCli.sh -server 127.0.0.1:2181

cli方式开启

注意：

如果报错：

cd ../conf

cp zoo_sample.cfg zoo.cfg

复制一下文件

5、php代码测试

测试代码

  1. <?php
 
/**
 
 * 
 
 */
 
class zookeeperDemo
 
{
 
private $zookeeper;
 
function __construct($address)
 
{
 
$this->zookeeper = new Zookeeper($address);
 
}
 
/*
 
 * get 
 
 */
 
public function get($path)
 
{
 
if (!$this->zookeeper->exists($path)) {
 
return null;
 
}
 
return $this->zookeeper->get($path);
 
}
 
 
 
public function getChildren($path) {
 
if (strlen($path) > 1 && preg_match(&#39;@/$@&#39;, $path)) {
 
// remove trailing /
 
$path = substr($path, 0, -1);
 
}
 
return $this->zookeeper->getChildren($path);
 
}
 
/*
 
 * set 值
 
 *
 
 *
 
 */
 
public function set($path, $value)
 
{
 
if (!$this->zookeeper->exists($path)) {
 
//创建节点
 
$this->makePath($path);
 
} else {
 
$this->zookeeper->set($path,$value);
 
}
 
 
 
}
 
/*
 
 * 创建路径
 
 */
 
private function makePath($path, $value=&#39;&#39;)
 
{
 
$parts = explode(&#39;/&#39;, $path);
 
$parts = array_filter($parts);//过滤空值
 
$subPath = &#39;&#39;;
 
while (count($parts) > 1) {
 
$subPath .= &#39;/&#39; . array_shift($parts);//数组第一个元素弹出数组
 
if (!$this->zookeeper->exists($subpath)) {
 
$this->makeNode($subPath, $value);
 
}
 
}
 
}
 
/*
 
 * 创建节点
 
 *
 
 */
 
private function makeNode($path, $value, array $params = array())
 
{
 
if (empty($params)) {
 
$params = [
 
[
 
&#39;perms&#39; => Zookeeper::PERM_ALL,
 
&#39;scheme&#39; => &#39;world&#39;,
 
&#39;id&#39; => &#39;anyone&#39;
 
]
 
];
 
}
 
return $this->zookeeper->create($path, $value, $params);
 
}
 
/*
 
 * 删除
 
 **/
 
public function deleteNode($path)
 
{
 
if (!$this->zookeeper->exists($path)) {
 
return null;
 
} else {
 
return $this->zookeeper->delete($path);
 
}
 
}
 
 
 
}
 
$zk = new zookeeperDemo(&#39;localhost:2181&#39;);
 
//var_dump($zk->get(&#39;/zookeeper&#39;));
 
var_dump($zk->getChildren(&#39;/foo&#39;));
 
//var_dump($zk->deleteNode("/foo"));
 
 
 
?>
测试代码2、
 
<?php
 
/**
 
 * PHP Zookeeper
 
 *
 
 * PHP Version 5.3
 
 *
 
 * The PHP License, version 3.01
 
 *
 
 * @category Libraries
 
 * @package PHP-Zookeeper
 
 * @author Lorenzo Alberton <l.alberton@quipo.it>
 
 * @copyright 2012 PHP Group
 
 * @license http://www.php.net/license The PHP License, version 3.01
 
 * @link https://github.com/andreiz/php-zookeeper
 
 */
 
/**
 
 * Example interaction with the PHP Zookeeper extension
 
 *
 
 * @category Libraries
 
 * @package PHP-Zookeeper
 
 * @author Lorenzo Alberton <l.alberton@quipo.it>
 
 * @copyright 2012 PHP Group
 
 * @license http://www.php.net/license The PHP License, version 3.01
 
 * @link https://github.com/andreiz/php-zookeeper
 
 */
 
class Zookeeper_Example
 
{
 
/**
 
 * @var Zookeeper
 
 */
 
private $zookeeper;
 
/**
 
 * @var Callback container
 
 */
 
private $callback = array();
 
/**
 
 * Constructor
 
 *
 
 * @param string $address CSV list of host:port values (e.g. "host1:2181,host2:2181")
 
 */
 
public function __construct($address) {
 
$this->zookeeper = new Zookeeper($address);
 
}
 
/**
 
 * Set a node to a value. If the node doesn&#39;t exist yet, it is created.
 
 * Existing values of the node are overwritten
 
 *
 
 * @param string $path The path to the node
 
 * @param mixed $value The new value for the node
 
 *
 
 * @return mixed previous value if set, or null
 
 */
 
public function set($path, $value) {
 
if (!$this->zookeeper->exists($path)) {
 
$this->makePath($path);
 
$this->makeNode($path, $value);
 
} else {
 
$this->zookeeper->set($path, $value);
 
}
 
}
 
/**
 
 * Equivalent of "mkdir -p" on ZooKeeper
 
 *
 
 * @param string $path The path to the node
 
 * @param string $value The value to assign to each new node along the path
 
 *
 
 * @return bool
 
 */
 
public function makePath($path, $value = &#39;&#39;) {
 
$parts = explode(&#39;/&#39;, $path);
 
$parts = array_filter($parts);
 
$subpath = &#39;&#39;;
 
while (count($parts) > 1) {
 
$subpath .= &#39;/&#39; . array_shift($parts);
 
if (!$this->zookeeper->exists($subpath)) {
 
$this->makeNode($subpath, $value);
 
}
 
}
 
}
 
/**
 
 * Create a node on ZooKeeper at the given path
 
 *
 
 * @param string $path The path to the node
 
 * @param string $value The value to assign to the new node
 
 * @param array $params Optional parameters for the Zookeeper node.
 
 * By default, a public node is created
 
 *
 
 * @return string the path to the newly created node or null on failure
 
 */
 
public function makeNode($path, $value, array $params = array()) {
 
if (empty($params)) {
 
$params = array(
 
array(
 
&#39;perms&#39; => Zookeeper::PERM_ALL,
 
&#39;scheme&#39; => &#39;world&#39;,
 
&#39;id&#39; => &#39;anyone&#39;,
 
)
 
);
 
}
 
return $this->zookeeper->create($path, $value, $params);
 
}
 
/**
 
 * Get the value for the node
 
 *
 
 * @param string $path the path to the node
 
 *
 
 * @return string|null
 
 */
 
public function get($path) {
 
if (!$this->zookeeper->exists($path)) {
 
return null;
 
}
 
return $this->zookeeper->get($path);
 
}
 
/**
 
 * List the children of the given path, i.e. the name of the directories
 
 * within the current node, if any
 
 *
 
 * @param string $path the path to the node
 
 *
 
 * @return array the subpaths within the given node
 
 */
 
public function getChildren($path) {
 
if (strlen($path) > 1 && preg_match(&#39;@/$@&#39;, $path)) {
 
// remove trailing /
 
$path = substr($path, 0, -1);
 
}
 
return $this->zookeeper->getChildren($path);
 
}
 
 
 
/**
 
 * Delete the node if it does not have any children
 
 * 
 
 * @param string $path the path to the node
 
 * 
 
 * @return true if node is deleted else null
 
 */
 
 
 
public function deleteNode($path)
 
{
 
if(!$this->zookeeper->exists($path))
 
{
 
return null;
 
}
 
else
 
{
 
return $this->zookeeper->delete($path);
 
}
 
}
 
 
 
/**
 
 * Wath a given path
 
 * @param string $path the path to node
 
 * @param callable $callback callback function
 
 * @return string|null
 
 */
 
public function watch($path, $callback)
 
{
 
if (!is_callable($callback)) {
 
return null;
 
}
 
 
 
if ($this->zookeeper->exists($path)) {
 
if (!isset($this->callback[$path])) {
 
$this->callback[$path] = array();
 
}
 
if (!in_array($callback, $this->callback[$path])) {
 
$this->callback[$path][] = $callback;
 
return $this->zookeeper->get($path, array($this, &#39;watchCallback&#39;));
 
}
 
}
 
}
 
 
 
/**
 
 * Wath event callback warper
 
 * @param int $event_type
 
 * @param int $stat
 
 * @param string $path
 
 * @return the return of the callback or null
 
 */
 
public function watchCallback($event_type, $stat, $path)
 
{
 
if (!isset($this->callback[$path])) {
 
return null;
 
}
 
 
 
foreach ($this->callback[$path] as $callback) {
 
$this->zookeeper->get($path, array($this, &#39;watchCallback&#39;));
 
return call_user_func($callback);
 
}
 
}
 
 
 
/**
 
 * Delete watch callback on a node, delete all callback when $callback is null
 
 * @param string $path
 
 * @param callable $callback
 
 * @return boolean|NULL
 
 */
 
public function cancelWatch($path, $callback = null)
 
{
 
if (isset($this->callback[$path])) {
 
if (empty($callback)) {
 
unset($this->callback[$path]);
 
$this->zookeeper->get($path); //reset the callback
 
return true;
 
} else {
 
$key = array_search($callback, $this->callback[$path]);
 
if ($key !== false) {
 
unset($this->callback[$path][$key]);
 
return true;
 
} else {
 
return null;
 
}
 
}
 
} else {
 
return null;
 
}
 
}
 
}
 
$zk = new Zookeeper_Example(&#39;localhost:2181&#39;);
 
// var_dump($zk->get(&#39;/&#39;));
 
// var_dump($zk->getChildren(&#39;/&#39;));
 
// var_dump($zk->set(&#39;/test&#39;, &#39;abc&#39;));
 
// var_dump($zk->get(&#39;/test&#39;));
 
// var_dump($zk->getChildren(&#39;/&#39;));
 
// var_dump($zk->set(&#39;/foo/001&#39;, &#39;bar1&#39;));
 
// var_dump($zk->set(&#39;/foo/002&#39;, &#39;bar2&#39;));
 
// var_dump($zk->get(&#39;/&#39;));
 
// var_dump($zk->getChildren(&#39;/&#39;));
 
// var_dump($zk->getChildren(&#39;/foo&#39;));
 
 
 
//watch example 一旦/test节点的值被改变，就会调用一次callback
 
function callback() {
 
echo "in watch callback\n";
 
}
 
//$zk->set(&#39;/test&#39;, 1);
 
$ret = $zk->watch(&#39;/test&#39;, &#39;callback&#39;); 
 
//$zk->set(&#39;/test&#39;, 2);//在终端执行
 
while (true) {
 
sleep(1);
 
}
 
 
 
/*
 
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
 
 
 
//ZooKeeper提供了可以绑定在znode的监视器。如果监视器发现znode发生变化，该service会立即通知所有相关的客户端。这就是PH//P脚本如何知道变化的。Zookeeper::get方法的第二个参数是回调函数。当触发事件时，监视器会被消费掉，所以我们需要在回调函
 
//数中再次设置监视器。
 
 
 
 $this->get( &#39;/test&#39;, array($this, &#39;watcher&#39; ) );
 
 
 
 }
 
 
 
}

$zoo = new ZookeeperDemo(&#39;127.0.0.1:2181&#39;);
$zoo->get( &#39;/test&#39;, array($zoo, &#39;watcher&#39; ) );
while( true ) {
 echo &#39;.&#39;;
 sleep(2);
}
*/
/*

// $zc = new Zookeeper();
 
// $zc->connect(&#39;127.0.0.1:2181&#39;);
// var_dump($zc->get(&#39;/zookeeper&#39;));
// exit;
*/
 
?>

代码参考链接：

https://github.com/php-zookeeper/php-zookeeper/blob/master/examples/Zookeeper_Example.php

 

以上是php的zookeeper扩展怎么安装的详细内容。更多信息请关注PHP中文网其他相关文章！

Java php 分布式 html 封装 接口 .net github oracle hbase hadoop zookeeper apache http https
声明：
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
上一篇：php怎么去掉html代码下一篇：php怎么删除整个数组

相关文章

查看更多