首页 后端开发 PHP问题 php的zookeeper扩展怎么安装

php的zookeeper扩展怎么安装

Mar 08, 2021 am 10:31 AM
zookeeper

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中文网其他相关文章!

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您听不到任何人,如何修复音频
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.聊天命令以及如何使用它们
4 周前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

Java API 开发中使用 ZooKeeper 进行分布式锁处理 Java API 开发中使用 ZooKeeper 进行分布式锁处理 Jun 17, 2023 pm 10:36 PM

随着现代应用程序的不断发展和对高可用性和并发性的需求日益增长,分布式系统架构变得越来越普遍。在分布式系统中,多个进程或节点同时运行并共同完成任务,进程之间的同步变得尤为重要。由于分布式环境下许多节点可以同时访问共享资源,因此,在分布式系统中,如何处理并发和同步问题成为了一项重要的任务。在此方面,ZooKeeper已经成为了一个非常流行的解决方案。ZooKee

在Beego中使用ZooKeeper和Curator进行分布式协调和管理 在Beego中使用ZooKeeper和Curator进行分布式协调和管理 Jun 22, 2023 pm 09:27 PM

随着互联网的迅速发展,分布式系统已经成为了许多企业和组织中的基础设施之一。而要让一个分布式系统能够正常运行,就需要对其进行协调和管理。在这方面,ZooKeeper和Curator是两个非常值得使用的工具。ZooKeeper是一个非常流行的分布式协调服务,它可以帮助我们在一个集群中协调各个节点之间的状态和数据。Curator则是一个对ZooKeeper进行封装

php如何使用PHP的Zookeeper扩展? php如何使用PHP的Zookeeper扩展? Jun 02, 2023 pm 09:01 PM

PHP是一种非常流行的编程语言,广泛应用于Web应用程序和服务器端开发。Zookeeper是一个分布式的协调服务,用于管理、协调和监控分布式应用程序和服务。在PHP应用程序中使用Zookeeper可以提高应用程序的性能和可靠性。本文将介绍如何使用PHP的Zookeeper扩展。一、安装Zookeeper扩展使用Zookeeper扩展需要安装Zookeeper

分布式锁用 Redis 还是 Zookeeper? 分布式锁用 Redis 还是 Zookeeper? Aug 22, 2023 pm 03:48 PM

分布式锁的实现方式通常有:数据库、缓存(比如:Redis)、Zookeeper、etcd,实际开发中,使用的最多还是Redis和Zookeeper,所以,本文就只聊这两种。

在Beego中使用ZooKeeper实现服务注册和发现 在Beego中使用ZooKeeper实现服务注册和发现 Jun 22, 2023 am 08:21 AM

在微服务架构中,服务的注册和发现是一个非常重要的问题。为了解决这个问题,我们可以使用ZooKeeper作为服务注册中心。在本文中,我们将介绍如何在Beego框架中使用ZooKeeper来实现服务注册和发现。一、ZooKeeper简介ZooKeeper是一个分布式的,开源的分布式协调服务,它是ApacheHadoop的子项目之一。ZooKeeper的主要作用

【建议收藏】灵魂拷问!Zookeeper的31连环炮 【建议收藏】灵魂拷问!Zookeeper的31连环炮 Aug 28, 2023 pm 04:45 PM

ZooKeeper 是一个开源的分布式协调服务。它是一个为分布式应用提供一致性服务的软件,分布式应用程序可以基于 Zookeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列等功能。

Redis实现分布式锁的ZooKeeper对比 Redis实现分布式锁的ZooKeeper对比 Jun 20, 2023 pm 03:19 PM

随着互联网技术的迅速发展,分布式系统在现代应用中已经得到广泛应用,特别是在大型互联网企业中更是必不可少。但是在分布式系统中,各个节点之间要保持一致性是非常困难的,因此分布式锁机制成为了解决这个问题的基础之一。在分布式锁的实现中,Redis和ZooKeeper都是比较流行的工具,本文将对它们进行一些对比和分析。Redis实现分布式锁Redis是开源的内存数据存

SpringBoot中如何整合Dubbo zookeeper SpringBoot中如何整合Dubbo zookeeper May 17, 2023 pm 02:16 PM

dockerpullzookeeperdockerrun--namezk01-p2181:2181--restartalways-d2e30cac00aca表明zookeeper已成功启动Zookeeper和Dubbo•ZooKeeperZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。DubboDubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,

See all articles