发表新帖

Swoole\Process\Pool 内怎么使用Table子进共享数据？

发布于4年前 · 3 次浏览 · 来自提问

2020-07-22

鲁飞

```php
$table = new Swoole\Table(1024);
$table->column('workerId', Swoole\Table::TYPE_INT);
$table->column('data', Swoole\Table::TYPE_STRING, 64);
$table->create();

$workerNum = 2;
$pool = new Swoole\Process\Pool($workerNum);
$pool->table = $table;
$pool->on("WorkerStart", function ($pool, $workerId) {
    echo "Worker#{$workerId} is started\n";
    $redis = new Redis();
    $redis->pconnect('127.0.0.1', 6379);
    $key = "key". $workerId;
    while (true) {
        $msg = $redis->brpop($key, 2);
        var_dump($msg);
        if ( $msg == null) continue;
        if ($msg[1] == 'get')
        {
            $info = $pool->table->get($workerId);
            var_dump($info);
        }
        //set
        elseif ($msg[1] == 'set')
        {
            $ret = $pool->table->set($workerId, array('data' => 'bar', 'workerId' => $workerId));
            var_dump('table set ' . $ret);
        }
    }
});

$pool->on("WorkerStop", function ($pool, $workerId) {
    echo "Worker#{$workerId} is stopped\n";
});

$pool->start();
```