我目前已经有一个正在运行并使用 Ratchet PHP 的 Web 套接字服务器。我还没有处于希望外部脚本与我的服务器进行通信的阶段。我可以使用 ZMQ 成功地将数据推送到它:
push.php
$json = ['name' => 'Joe Bloggs'];
$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'Push Notification');
$socket->connect("tcp://localhost:5555");
$socket->send(json_encode($json));
然后在我的网络服务器脚本中我可以将其发送到一个方法(onNewPush
)在 Push.php 文件运行(运行?)时用它做一些事情:
...
$push = $context->getSocket(ZMQ::SOCKET_PULL);
$push->bind('tcp://127.0.0.1:5555');
$push->on('Push Notification', array($pusher, 'onNewPush'));
...
所以这工作正常,但我在尝试收到回复时遇到困难。我正在尝试类似的事情:
pull.php
$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_REQ, 'Pull Notification');
$socket->connect("tcp://localhost:5554");
$socket->send('data');
echo $socket->recv();
然后在我的服务器脚本中:
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5554');
$pull->on('message', array($pusher, 'onPull'));
My $pusher
变量加载我的文件,该文件实现了一些棘轮接口。但本质上我只是返回一个字符串:
public function onPull()
{
return "some data";
}
跑步时pull.php
我收到错误:
Fatal error: Uncaught exception 'ZMQSocketException' with message 'Failed to receive message: Not supported' in websockets\pull.php:9 Stack trace: #0 websockets\pull.php(9): ZMQSocket->recv() #1 {main} thrown in websockets\pull.php on line 9
有谁知道为什么?
另外第二个参数的重要性是什么getSocket()
有?看起来就像是一个永远不会再使用的字符串。
Cheers
UPDATED