grimkirill/stomp

纯PHP Stomp客户端。支持协议版本1.0，1.1，1.2。兼容RabbitMQ，Apache ActiveMQ

维护者

详细信息

github.com/grimkirill/stomp

主页

源代码

问题

安装: 585

依赖项: 0

建议者: 0

安全: 0

星标: 3

关注者: 0

分支: 0

开放问题: 0

1.1.0 2015-03-13 10:26 UTC

Requires

  • php: >=5.3.0

MIT 20e7b8776016570947b050b151e2c83ab0f2033f

rabbitmqstompApache ActiveMQActiveMQ Apollo

This package is not auto-updated.

Last update: 2024-09-28 12:53:36 UTC

README

使用方法

<?php
/**
 * Create connection
 */
$client = new \Stomp\Client(array('tcp://127.0.0.1:61613'), array(
        'login' => 'admin',
        'passcode' => 'password',
        'host' => '/',
        'queue_prefix' => '/queue/',
    ));
        
$client->send('queue_destination', 'hello message');    

$client->subscribe('queue_destination');
while ($message = $client->readMessage()) {
    echo $message->getBody();
    $message->ack();
}

RPC示例

服务器端示例

<?php
require_once __DIR__ . '/../tests/Bootstrap.php';

$client = new \Stomp\Client('tcp://127.0.0.1:61613', array('login' => 'admin', 'passcode' => 'password'));

$consumer = new \Stomp\Helper\Consumer($client, '/queue/testing');

$endTime = new \DateTime('+30 second');
$condition = function () use ($endTime) {
    return ((new DateTime()) < $endTime);
};

$consumer->run(function($data, $headers) {
    var_dump($data);
    print_r($headers);
    return date('c');
}, $condition);

客户端示例

<?php
require_once __DIR__ . '/../tests/Bootstrap.php';

$client = new \Stomp\Client('tcp://127.0.0.1:61613', array('login' => 'admin', 'passcode' => 'password'));

$rpc = new \Stomp\Helper\Rpc($client, '/queue/testing');

var_dump($rpc->call('Ping')); // string(25) "2015-03-13T10:22:27+00:00"