friends-of-reactphp/zmq
Fork: 50 Star: 248 (更新于 2024-09-03 05:19:39)
license: MIT
Language: PHP .
ZeroMQ bindings for ReactPHP.
最后发布版本: v0.4.0 ( 2018-05-18 23:30:27)
React/ZMQ
ZeroMQ bindings for React.
Install
The recommended way to install react/zmq is through composer.
composer require react/zmq
Example
And don't forget to autoload:
<?php
require 'vendor/autoload.php';
Here is an example of a push socket:
<?php
$loop = React\EventLoop\Factory::create();
$context = new React\ZMQ\Context($loop);
$push = $context->getSocket(ZMQ::SOCKET_PUSH);
$push->connect('tcp://127.0.0.1:5555');
$i = 0;
$loop->addPeriodicTimer(1, function () use (&$i, $push) {
$i++;
echo "sending $i\n";
$push->send($i);
});
$loop->run();
And the pull socket that goes with it:
<?php
$loop = React\EventLoop\Factory::create();
$context = new React\ZMQ\Context($loop);
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555');
$pull->on('error', function ($e) {
var_dump($e->getMessage());
});
$pull->on('message', function ($msg) {
echo "Received: $msg\n";
});
$loop->run();
Todo
- Integration tests
- Buffer limiting
- Do not push messages if no listener
Tests
To run the test suite, you need PHPUnit.
$ phpunit
License
MIT, see LICENSE.
friends-of-reactphp/zmq同语言 PHP最近更新仓库
2024-09-18 20:45:32 coollabsio/coolify
2024-09-17 03:04:08 caseyamcl/guzzle_retry_middleware
2024-09-16 23:17:15 cakephp/migrations
2024-09-14 10:53:46 cakephp/cakephp
2024-09-06 16:28:08 spatie/holidays
2024-09-06 02:33:26 CakeDC/users