swoole/zmq

Swoole 的 ZeroMQ 绑定。

v0.1.3 2017-08-18 12:01 UTC

This package is auto-updated.

Last update: 2024-09-15 17:03:57 UTC


README

Swoole 的 ZeroMQ 绑定。

安装

推荐安装 swoole/zmq 的方式是通过 composer

{
    "require": {
        "swoole/zmq": "0.1.*"
    }
}
composer require swoole/zmq

示例

不要忘记自动加载

<?php
require 'vendor/autoload.php';

以下是一个推送套接字的示例

$zmq = new Swoole\Async\ZMQ();

$zmq->on('Message', function ($msg)
{
    echo "Received: $msg\n";
});

$zmq->bind('tcp://0.0.0.0:9530');

以及与其对应的拉取套接字

$zmq = new Swoole\Async\ZMQ();

$zmq->connect('tcp://0.0.0.0:5555');

Swoole\Timer::tick(1000, function () use ($zmq)
{
    static $i = 0;
    $msg = "hello-" . $i++;
    echo "Sending: $msg\n";
    $zmq->send($msg);
});