Zeromq 操作

[twn39]

zeromq 是高性能的消息队列系统

[twn39]

PHP

依赖包：php5-zmq

Reply-Request

server.php

<?php
$server = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_REP);

$server->bind("tcp://*:5555");

while ($message = $server->recv()) {
    echo "Got message: $message\n";
    $server->send($message);
}

client.php

<?php
$client = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_REQ);
$client->connect("tcp://127.0.0.1:5555");
$client->send('hello, yo!');

PAIR

server.php

<?php
$server = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_PAIR);
$server->bind("tcp://*:5555");
while ($message = $server->recv()) {
    echo "Got message: $message\n";
    $server->send($message);
}

client.php

<?php
$client = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_PAIR);
$client->connect("tcp://127.0.0.1:5555");
while(1) {
    $client->send('hello, yo!');
    $message = $client->recv();
    echo $message;
    sleep(1);
}