react/zmq

(要求Workerman版本>=3.3.6)

安装：

  1. composer require react/zmq

示例：

  1. <?php
  2. require_once __DIR__ . '/vendor/autoload.php';
  3. use Workerman\Worker;
  5. $worker = new Worker('text://0.0.0.0:6161');
  7. $worker->onWorkerStart = function() {
  8.     global   $pull;
  9.     $loop    = Worker::getEventLoop();
  10.     $context = new React\ZMQ\Context($loop);
  11.     $pull    = $context->getSocket(ZMQ::SOCKET_PULL);
  12.     $pull->bind('tcp://127.0.0.1:5555');
  14.     $pull->on('error', function ($e) {
  15.         var_dump($e->getMessage());
  16.     });
  18.     $pull->on('message', function ($msg) {
  19.         echo "Received: $msg\n";
  20.     });
  21. };
  23. Worker::runAll();

文档：

https://github.com/reactphp/zmq

注意：

1、所有的异步编码必须在onXXX回调中编写

2、异步客户端需要的$loop变量请使用Worker::getEventLoop();返回值