GlobalData コンポーネント クライアント

(要件 Workerman バージョン >= 3.3.0)

__construct

void \GlobalData\Client::__construct(mixed $server_address)

\GlobalData\Client クライアントオブジェクトをインスタンス化します。クライアントオブジェクトにプロパティを割り当てることで、プロセス間でデータを共有します。

パラメータ

GlobalData server のサーバーアドレス。形式は<ipアドレス>:<ポート>、例えば127.0.0.1:2207です。

GlobalData server クラスターの場合は、アドレスの配列を渡します。例えばarray('10.0.0.10:2207', '10.0.0.11:2207')です。

説明

値の設定、読み取り、isset、unset 操作をサポートしています。
同時に cas アトミック操作もサポートしています。

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

// GlobalData Server
$global_worker = new GlobalData\Server('0.0.0.0', 2207);

$worker = new Worker('tcp://0.0.0.0:6636');
// プロセス起動時
$worker->onWorkerStart = function()
{
    // グローバルな global data client を初期化
    global $global;
    $global = new \GlobalData\Client('127.0.0.1:2207');
};
// サーバーがメッセージを受信するたびに
$worker->onMessage = function(TcpConnection $connection, $data)
{
    // $global->somedata の値を変更、他のプロセスがこの $global->somedata 変数を共有します
    global $global;
    echo "now global->somedata=".var_export($global->somedata, true)."\n";
    echo "set \$global->somedata=$data";
    $global->somedata = $data;
};
Worker::runAll();

すべての使用法(php-fpm 環境でも使用可能)

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

$global = new Client('127.0.0.1:2207');

var_export(isset($global->abc));

$global->abc = array(1,2,3);

var_export($global->abc);

unset($global->abc);

var_export($global->add('abc', 10));

var_export($global->increment('abc', 2));

var_export($global->cas('abc', 12, 18));

注意:

GlobalData コンポーネントは、MySQL 接続、ソケット接続などのリソースタイプのデータを共有することはできません。

Workerman 環境で GlobalData/Client を使用する場合は、onXXX コールバック内で GlobalData/Client オブジェクトをインスタンス化してください。例えば、onWorkerStart 内でインスタンス化します。

共有変数をこのように操作してはいけません。

$global->somekey = array();
$global->somekey[]='xxx';

$global->someObject = new someClass();
$global->someObject->someVar = 'xxx';

このようにできます。

$somekey = array();
$somekey[] = 'xxx';
$global->somekey = $somekey;

$someObject = new someClass();
$someObject->someVar = 'xxx';
$global->someObject = $someObject;