PHP與Zookeeper實現服務注冊與發現

使用PHP和Apache ZooKeeper實現服務注冊與發現是一個相對復雜的任務，但可以通過以下步驟來實現。Apache ZooKeeper是一個分布式協調服務，可以用于管理配置信息、命名服務、分布式同步等。

1. 安裝和配置ZooKeeper

首先，你需要在你的環境中安裝和配置Apache ZooKeeper。你可以從ZooKeeper官方網站下載并安裝。

2. 安裝PHP ZooKeeper客戶端庫

為了在PHP中使用ZooKeeper，你需要安裝一個PHP客戶端庫。一個常用的庫是php-zookeeper。你可以通過Composer來安裝它：

composer require zookeeper/zookeeper

3. 創建ZooKeeper客戶端

創建一個PHP腳本來連接到ZooKeeper并執行服務注冊和發現操作。

<?php
require_once __DIR__ . '/vendor/autoload.php';

use zookeeper\ZooKeeper;
use zookeeper\ZooKeeperException;

// ZooKeeper連接配置
$zk = new ZooKeeper([
    'host' => '127.0.0.1:2181', // ZooKeeper地址
    'timeout' => 3000 // 連接超時時間（毫秒）
]);

// 服務注冊
function registerService($zk, $serviceName, $serviceAddress, $port) {
    try {
        // 創建節點
        $servicePath = "/services/{$serviceName}";
        if (!$zk->exists($servicePath)) {
            $zk->create($servicePath, null, ZooKeeper::EPHEMERAL | ZooKeeper::SEQUENTIAL);
        }

        // 創建臨時順序節點
        $nodePath = $servicePath . "/instance_" . getmypid();
        $zk->create($nodePath, ["value" => "{$serviceAddress}:{$port}"], ZooKeeper::EPHEMERAL | ZooKeeper::SEQUENTIAL);

        echo "Service registered: {$serviceAddress}:{$port}\n";
    } catch (ZooKeeperException $e) {
        echo "Failed to register service: " . $e->getMessage() . "\n";
    }
}

// 服務發現
function discoverService($zk, $serviceName) {
    try {
        $servicePath = "/services/{$serviceName}";
        if ($zk->exists($servicePath)) {
            $children = $zk->getChildren($servicePath);
            foreach ($children as $child) {
                $nodePath = $servicePath . "/instance_" . $child;
                $data = $zk->getData($nodePath);
                $serviceInfo = json_decode($data[0], true);
                echo "Discovered service: {$serviceInfo['value']}\n";
            }
        } else {
            echo "Service not found: {$serviceName}\n";
        }
    } catch (ZooKeeperException $e) {
        echo "Failed to discover service: " . $e->getMessage() . "\n";
    }
}

// 注冊服務示例
registerService($zk, 'myService', '192.168.1.100', 8080);

// 發現服務示例
discoverService($zk, 'myService');

// 關閉ZooKeeper連接
$zk->close();
?>

4. 運行腳本

確保ZooKeeper正在運行，然后運行你的PHP腳本。你應該會看到服務注冊和發現的輸出。

5. 服務發現客戶端

為了在實際應用中使用服務發現，你可以創建一個客戶端來調用已注冊的服務。以下是一個簡單的客戶端示例：

<?php
require_once __DIR__ . '/vendor/autoload.php';

use zookeeper\ZooKeeper;
use zookeeper\ZooKeeperException;

// ZooKeeper連接配置
$zk = new ZooKeeper([
    'host' => '127.0.0.1:2181', // ZooKeeper地址
    'timeout' => 3000 // 連接超時時間（毫秒）
]);

// 服務發現
function discoverService($zk, $serviceName) {
    try {
        $servicePath = "/services/{$serviceName}";
        if ($zk->exists($servicePath)) {
            $children = $zk->getChildren($servicePath);
            foreach ($children as $child) {
                $nodePath = $servicePath . "/instance_" . $child;
                $data = $zk->getData($nodePath);
                $serviceInfo = json_decode($data[0], true);
                return $serviceInfo['value'];
            }
        } else {
            return "Service not found: {$serviceName}";
        }
    } catch (ZooKeeperException $e) {
        return "Failed to discover service: " . $e->getMessage();
    }
}

// 調用服務示例
$serviceAddress = discoverService($zk, 'myService');
echo "Service address: {$serviceAddress}\n";

// 關閉ZooKeeper連接
$zk->close();
?>

通過以上步驟，你可以使用PHP和Apache ZooKeeper實現基本的服務注冊與發現。根據你的需求，你可能需要進一步擴展和優化這個示例。