GlobalData 组件客户端

(要求Workerman版本>=3.3.0)

__construct

  1. 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.0.11:2207')

说明

支持赋值、读取、isset、unset操作。
同时支持cas原子操作。

例子

  1. <?php
  2. use Workerman\Worker;
  3. require_once __DIR__ . '/Workerman/Autoloader.php';
  4. require_once __DIR__ . '/GlobalData/src/Client.php';
  5. $worker = new Worker('tcp://0.0.0.0:6636');
  6. // 进程启动时
  7. $worker->onWorkerStart = function()
  8. {
  9. // 初始化一个全局的global data client
  10. global $global;
  11. $global = new \GlobalData\Client('127.0.0.1:2207');
  12. };
  13. // 每次服务端收到消息时
  14. $worker->onMessage = function($connection, $data)
  15. {
  16. // 更改$global->somedata的值,其它进程会共享这个$global->somedata变量
  17. global $global;
  18. echo "now global->somedata=".var_export($global->somedata, true)."\n";
  19. echo "set \$global->somedata=$data";
  20. $global->somedata = $data;
  21. };
  22. Worker::runAll();

全部用法(php-fpm环境也可以使用)

  1. require_once __DIR__ . '/GlobalData/src/Client.php';
  2. $global = new Client('127.0.0.1:2207');
  3. var_export(isset($global->abc));
  4. $global->abc = array(1,2,3);
  5. var_export($global->abc);
  6. unset($global->abc);
  7. var_export($global->add('abc', 10));
  8. var_export($global->increment('abc', 2));
  9. var_export($global->cas('abc', 12, 18));

注意:

GlobalData组件无法共享资源类型的数据,例如mysql连接、socket连接等无法共享。

如果在Workerman环境中使用GlobalData/Client,请在onXXX回调中实例化GlobalData/Client对象,例如在onWorkerStart中实例化。

不能这样操作共享变量。

  1. $global->somekey = array();
  2. $global->somekey[]='xxx';
  3. $global->someObject = new someClass();
  4. $global->someObject->someVar = 'xxx';

可以这样

  1. $somekey = array();
  2. $somekey[] = 'xxx';
  3. $global->somekey = $somekey;
  4. $someObject = new someClass();
  5. $someObject->someVar = 'xxx';
  6. $global->someObject = $someObject;