PHP 用の Zookeeper 拡張機能をインストールする方法
Zookeeper 拡張機能を PHP でインストールする方法: 最初に Zookeeper をダウンロードし、次にインストール ディレクトリを指定し、最後に「make && make install」を通じて 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 拡張機能は後で説明します。 prefix=/usr /local/zookeeper //インストール ディレクトリを指定します
make && make install
インストールが完了しました
2. http: にある php Zookeeper 拡張機能をインストールします。 //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 installConfigure php.iniextension="/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
エラーが報告された場合:
5、PHP コード テスト
テスト コード
<?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('@/$@', $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='')
{
$parts = explode('/', $path);
$parts = array_filter($parts);//过滤空值
$subPath = '';
while (count($parts) > 1) {
$subPath .= '/' . array_shift($parts);//数组第一个元素弹出数组
if (!$this->zookeeper->exists($subpath)) {
$this->makeNode($subPath, $value);
}
}
}
/*
* 创建节点
*
*/
private function makeNode($path, $value, array $params = array())
{
if (empty($params)) {
$params = [
[
'perms' => Zookeeper::PERM_ALL,
'scheme' => 'world',
'id' => 'anyone'
]
];
}
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('localhost:2181');
//var_dump($zk->get('/zookeeper'));
var_dump($zk->getChildren('/foo'));
//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'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 = '') {
$parts = explode('/', $path);
$parts = array_filter($parts);
$subpath = '';
while (count($parts) > 1) {
$subpath .= '/' . 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(
'perms' => Zookeeper::PERM_ALL,
'scheme' => 'world',
'id' => 'anyone',
)
);
}
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('@/$@', $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, 'watchCallback'));
}
}
}
/**
* 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, 'watchCallback'));
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('localhost:2181');
// var_dump($zk->get('/'));
// var_dump($zk->getChildren('/'));
// var_dump($zk->set('/test', 'abc'));
// var_dump($zk->get('/test'));
// var_dump($zk->getChildren('/'));
// var_dump($zk->set('/foo/001', 'bar1'));
// var_dump($zk->set('/foo/002', 'bar2'));
// var_dump($zk->get('/'));
// var_dump($zk->getChildren('/'));
// var_dump($zk->getChildren('/foo'));
//watch example 一旦/test节点的值被改变，就会调用一次callback
function callback() {
echo "in watch callback\n";
}
//$zk->set('/test', 1);
$ret = $zk->watch('/test', 'callback');
//$zk->set('/test', 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( '/test', array($this, 'watcher' ) );
}
}
$zoo = new ZookeeperDemo('127.0.0.1:2181');
$zoo->get( '/test', array($zoo, 'watcher' ) );
while( true ) {
echo '.';
sleep(2);
}
*/
/*
// $zc = new Zookeeper();
// $zc->connect('127.0.0.1:2181');
// var_dump($zc->get('/zookeeper'));
// exit;
*/
?>コード参照リンク:
https:/ /github.com/php-zookeeper/php-zookeeper/blob/master/examples/Zookeeper_Example.php
以上がPHP 用の Zookeeper 拡張機能をインストールする方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
ホットツール
メモ帳++7.3.1
使いやすく無料のコードエディター
SublimeText3 中国語版
中国語版、とても使いやすい
ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境
ドリームウィーバー CS6
ビジュアル Web 開発ツール
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
ホットトピック
7517
15
1378
52
79
11
21
66
Java API開発における分散ロック処理のためのZooKeeperの使用
Jun 17, 2023 pm 10:36 PM
最新のアプリケーションが進化し続け、高可用性と同時実行性のニーズが高まるにつれて、分散システム アーキテクチャがより一般的になってきています。分散システムでは、複数のプロセスまたはノードが同時に実行され、一緒にタスクを完了するため、プロセス間の同期が特に重要になります。分散環境では多くのノードが同時に共有リソースにアクセスできるため、分散システムでは同時実行性と同期の問題にどのように対処するかが重要な課題となっています。この点で、ZooKeeper は非常に人気のあるソリューションになっています。ズーキー
Beego での分散調整と管理のための ZooKeeper と Curator の使用
Jun 22, 2023 pm 09:27 PM
インターネットの急速な発展に伴い、分散システムは多くの企業や組織のインフラストラクチャの 1 つになりました。分散システムが適切に機能するには、調整して管理する必要があります。この点で、ZooKeeper と Curator は使用する価値のある 2 つのツールです。 ZooKeeper は、クラスター内のノード間のステータスとデータを調整するのに役立つ、非常に人気のある分散調整サービスです。 Curator は ZooKeeper のカプセル化です
PHP の Zookeeper 拡張機能を使用するにはどうすればよいですか?
Jun 02, 2023 pm 09:01 PM
PHP は、Web アプリケーションやサーバーサイド開発で広く使用されている非常に人気のあるプログラミング言語です。 Zookeeper は、分散アプリケーションとサービスを管理、調整、監視するために使用される分散調整サービスです。 PHP アプリケーションで Zookeeper を使用すると、アプリケーションのパフォーマンスと信頼性が向上します。この記事では、PHP 用の Zookeeper 拡張機能の使用方法を紹介します。 1. Zookeeper 拡張機能をインストールする Zookeeper 拡張機能を使用するには、Zookeeper をインストールする必要があります。
分散ロックには Redis または Zookeeper を使用する必要がありますか?
Aug 22, 2023 pm 03:48 PM
分散ロックの実装方法には通常、データベース、キャッシュ (Redis など)、Zookeeper などが含まれますが、実際の開発では Redis と Zookeeper が最も一般的に使用されるため、この記事ではこの 2 つについてのみ説明します。
ZooKeeper を使用して Beego でサービスの登録と検出を実装する
Jun 22, 2023 am 08:21 AM
マイクロサービス アーキテクチャでは、サービスの登録と検出は非常に重要な問題です。この問題を解決するには、ZooKeeper をサービス登録センターとして使用します。この記事では、Beego フレームワークで ZooKeeper を使用してサービスの登録と検出を実装する方法を紹介します。 1. ZooKeeper の概要 ZooKeeper は、オープンソースの分散調整サービスであり、Apache Hadoop のサブプロジェクトの 1 つです。 ZooKeeperの主な役割
【おすすめ作品集】魂責め！動物園飼育員の 31 発の大砲
Aug 28, 2023 pm 04:45 PM
ZooKeeper は、オープンソースの分散調整サービスです。分散アプリケーションに一貫性サービスを提供するソフトウェアであり、分散アプリケーションは、データのパブリッシュ/サブスクリプション、ロード バランシング、ネーミング サービス、分散調整/通知、クラスター管理、マスター選出、分散ロック、分散キュー、その他の機能などのタスクを実装できます。
ZooKeeper による分散ロックの Redis 実装の比較
Jun 20, 2023 pm 03:19 PM
インターネット技術の急速な発展に伴い、分散システムは最新のアプリケーション、特に大規模なインターネット企業で広く使用されています。しかし、分散システムではノード間の一貫性を維持することが非常に難しいため、分散ロック機構はこの問題を解決する基盤の 1 つとなっています。分散ロックの実装では、Redis と ZooKeeper がどちらも人気のあるツールなので、この記事ではそれらを比較して分析します。 Redis は分散ロックを実装します Redis はオープンソースのメモリ データ ストレージです
Dubbo Zookeeper を SpringBoot に統合する方法
May 17, 2023 pm 02:16 PM
dockerpullzookeeperdockerrun --namezk01-p2181:2181--restartalways-d2e30cac00aca は、zookeeper が Zookeeper と Dubbo を正常に開始したことを示します。 • ZooKeeperZooKeeper は、分散型のオープンソース分散アプリケーション調整サービスです。分散アプリケーションに一貫したサービスを提供するソフトウェアであり、構成保守、ドメイン名サービス、分散同期、グループ サービスなどの機能が提供されます。 DubboDubbo は Alibaba のオープンソース分散サービスフレームワークであり、最大の特徴は階層構造になっている点です。
