异步消息队列组件 - react/stomp

(要求Workerman版本>=3.3.6)

STOMP是一个通讯协议。它是支持大多数消息队列如RabbitMQ、Apollo等。

安装：

composer require react/stomp

示例：

<?php
require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;
$worker = new Worker('text://0.0.0.0:6161');
$worker->onWorkerStart = function() {
    global   $client;
    $loop    = Worker::getEventLoop();
    $factory = new ReactStompFactory($loop);
    $client  = $factory->createClient(array('vhost' => '/', 'login' => 'guest', 'passcode' => 'guest'));
    $client
        ->connect()
        ->then(function ($client) use ($loop) {
            $client->subscribe('/topic/foo', function ($frame) {
                echo "Message received: {$frame->body}n";
            });
        });
};
Worker::runAll();

文档：

https://github.com/reactphp/stomp

注意：

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

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