🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
# react/stomp # react/stomp **`(要求Workerman版本>=3.3.6)`** STOMP是一个通讯协议。它是支持大多数消息队列如RabbitMQ、Apollo等。 ## 安装: ```php composer require react/stomp ``` ## 示例: ```php <?php require_once __DIR__ . '/vendor/autoload.php'; use Workerman\Worker; $consumer = new Worker(); $consumer->onWorkerStart = function() { global $client; $loop = Worker::getEventLoop(); $factory = new React\Stomp\Factory($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();```返回值 **备注** * swoole-worker不支持此组件