1

我正在尝试通过 websocket 向我的服务器发送请求，并从服务器返回回复。这是“某种”工作，但是我只能这样做一次，任何额外的请求都会挂在某个地方。

服务器绑定：

$pull = $context->getSocket(ZMQ::SOCKET_REP);
$pull->bind('tcp://127.0.0.1:5552');
$pull->on('message', array($pusher, 'onPull'));
$pull->recv();
$pull->send('back');

我的服务器上有一个静态 PHP 文件，当我运行它时，想要从服务器返回回复：

$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_REQ, 'Sock');
$socket->connect("tcp://localhost:5552");

$socket->send('sending');

$message = $socket->recv();

echo "$message";

现在，当我启动服务器并运行我的 php 文件时，我得到了“返回”响应。但是，当我尝试再次运行它时，它就会挂起。我每次都收到请求？

另外，任何人都可以$pull->on向我解释一下，我在任何地方都找不到它的作用。

完整的服务器代码：

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

    $loop   = React\EventLoop\Factory::create();
    $pusher = new MyApp\Pusher;

    $context = new React\ZMQ\Context($loop);

    $push = $context->getSocket(ZMQ::SOCKET_PULL);
    $push->bind('tcp://127.0.0.1:5555');
    $push->on('message', array($pusher, 'onNewPush'));

    $pull = $context->getSocket(ZMQ::SOCKET_REP);
    $pull->bind('tcp://127.0.0.1:5552');
    $pull->on('message', array($pusher, 'onPull'));
    $pull->recv();
    $pull->send('back');

    $webSock = new React\Socket\Server($loop);
    $webSock->listen(8080, '0.0.0.0');
    $webServer = new Ratchet\Server\IoServer(
        new Ratchet\Http\HttpServer(
            new Ratchet\WebSocket\WsServer(
                $pusher
            )
        ),
        $webSock
    );

    $loop->run();
4

1 回答 1

2

我认为这样的事情应该可以完成：

$pull->on(
    'message',
    function ($message) use ($pull) {
        $pull->send('response');
    }
);

在任何情况下，无论您使用像上面这样的匿名函数还是对象/方法对，您都需要访问$pull，因为这是允许您发送消息的通信通道。http://socketo.me/docs/push上的示例，这似乎是您的代码的基础，不需要那个，因为它使用一个只接收消息的拉式套接字。

于 2014-05-27T20:10:02.787 回答