服务发现（Service Discovery）在Swoole中的实现

<?php
use Swoole\Coroutine;
use Swoole\Coroutine\Http\Client;

class ServiceDiscovery {
    private $consulHost;
    private $consulPort;

    public function __construct($host = '127.0.0.1', $port = 8500) {
        $this->consulHost = $host;
        $this->consulPort = $port;
    }

    public function registerService($serviceName, $serviceAddress, $servicePort) {
        Coroutine::create(function () use ($serviceName, $serviceAddress, $servicePort) {
            $client = new Client($this->consulHost, $this->consulPort);
            $client->set(['timeout' => 1]);
            $client->post('/v1/agent/service/register', json_encode([
                'Name' => $serviceName,
                'Address' => $serviceAddress,
                'Port' => $servicePort,
            ]));
            $client->close();
        });
    }

    public function discoverService($serviceName) {
        $services = [];
        Coroutine::create(function () use ($serviceName, &$services) {
            $client = new Client($this->consulHost, $this->consulPort);
            $client->set(['timeout' => 1]);
            $client->get("/v1/catalog/service/{$serviceName}");
            if ($client->statusCode === 200) {
                $services = json_decode($client->body, true);
            }
            $client->close();
        });
        return $services;
    }
}

$discovery = new ServiceDiscovery();
$discovery->registerService('myService', '127.0.0.1', 9501);
$services = $discovery->discoverService('myService');
var_dump($services);