Workerman如何实现服务注册？Workerman服务发现机制？

my_service

127.0.0.1:2000

<?php
use Workerman\Worker;
use Workerman\Timer;

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

// Redis连接配置
$redisHost = '127.0.0.1';
$redisPort = 6379;
$redis = new \Redis();
$redis->connect($redisHost, $redisPort);

// 假设服务实例的唯一标识
$serviceName = 'my_service';
$serviceIp = '127.0.0.1'; // 实际部署时应获取本机IP
$servicePort = 2000;
$instanceId = $serviceIp . ':' . $servicePort; // 实例ID，例如 127.0.0.1:2000
$redisKey = "services:{$serviceName}:{$instanceId}"; // Redis中存储的键

$worker = new Worker('tcp://' . $serviceIp . ':' . $servicePort);
$worker->name = $serviceName . '-' . $instanceId;

$worker->onWorkerStart = function($worker) use ($redis, $redisKey, $instanceId) {
    echo "Worker {$worker->id} started. Registering service...\n";

    // 注册服务，并设置过期时间（例如30秒）
    // 值可以更丰富，例如JSON字符串包含权重、版本等
    $redis->setex($redisKey, 30, $instanceId); 
    echo "Service {$instanceId} registered with key {$redisKey}\n";

    // 定时器：每隔10秒发送一次心跳，刷新过期时间
    Timer::add(10, function() use ($redis, $redisKey, $instanceId) {
        $redis->expire($redisKey, 30);
        echo "Heartbeat sent for {$instanceId}\n";
    });
};

$worker->onMessage = function($connection, $data) {
    $connection->send("Hello from {$connection->worker->name}! You sent: " . $data);
};

$worker->onWorkerStop = function($worker) use ($redis, $redisKey) {
    // Worker停止时，从Redis中删除注册信息
    $redis->del($redisKey);
    echo "Service {$worker->name} unregistered.\n";
};

Worker::runAll();

onWorkerStart

setex

Timer::add

onWorkerStop

my_service

my_service

<?php
// 假设这是一个独立的客户端脚本或Workerman中的另一个服务
require_once __DIR__ . '/vendor/autoload.php';

// Redis连接配置
$redisHost = '127.0.0.1';
$redisPort = 6379;
$redis = new \Redis();
$redis->connect($redisHost, $redisPort);

$serviceName = 'my_service';
$servicePattern = "services:{$serviceName}:*"; // 用于匹配所有实例的键

// 模拟客户端发现服务并调用
function discoverAndCallService($redis, $servicePattern) {
    echo "Discovering services for pattern: {$servicePattern}\n";
    $keys = $redis->keys($servicePattern); // 获取所有匹配的键

    $availableInstances = [];
    foreach ($keys as $key) {
        $instanceId = $redis->get($key); // 获取存储的实例ID
        if ($instanceId) {
            $availableInstances[] = $instanceId;
        } else {
            // 如果键已过期，但keys命令仍返回，这里可以做额外清理
            // 实际生产中，Redis的过期键不会立即从keys结果中消失，但get会返回false
        }
    }

    if (empty($availableInstances)) {
        echo "No available instances for {$serviceName}.\n";
        return null;
    }

    // 简单的负载均衡：随机选择一个实例
    $selectedInstance = $availableInstances[array_rand($availableInstances)];
    echo "Found " . count($availableInstances) . " instances. Selected: {$selectedInstance}\n";

    // 假设这里是实际调用服务的逻辑
    // 例如：通过Workerman的AsyncTcpConnection或者其他HTTP客户端去连接这个地址
    echo "Simulating call to service at {$selectedInstance}...\n";
    return $selectedInstance;
}

// 示例调用
$instance = discoverAndCallService($redis, $servicePattern);
if ($instance) {
    // 可以在这里使用Workerman的AsyncTcpConnection或者Guzzle等进行实际的网络请求
    // 例如：
    // $client = new \Workerman\Connection\AsyncTcpConnection('tcp://' . $instance);
    // $client->onConnect = function($connection) {
    //     $connection->send('Hello service!');
    // };
    // $client->onMessage = function($connection, $data) {
    //     echo "Service response: " . $data . "\n";
    //     $connection->close();
    // };
    // $client->connect();
}

keys

keys

scan

services:my_service:*