dqz30992 2014-05-26 17:56
浏览 85

React / ZMQ / Ratchet - Websocket服务器响应

I've currently got a web socket server running and working with Ratchet PHP. I'm not at the stage where I want external scripts to communicate with my server. I can successfully push data to it using ZMQ:


$json = ['name' => 'Joe Bloggs'];

$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'Push Notification');


Then in my webserver script I can send this to a method (onNewPush) to do something with it when the push.php file is run (ran?):

$push = $context->getSocket(ZMQ::SOCKET_PULL);
$push->on('Push Notification', array($pusher, 'onNewPush'));

So this works fine, but I'm having trouble trying to receive a response back. I'm trying something like:


$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_REQ, 'Pull Notification');


echo $socket->recv();

Then in my server script:

$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->on('message', array($pusher, 'onPull'));

My $pusher variable loads my file which implements a few Ratchet Interfaces. But essentially I'm just returning a string:

public function onPull()
    return "some data";

When running pull.php I get the error:

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

Does anyone know why?

Also what importance does the second parameter on getSocket() have? Just seems like a string which is never used again.



  • 写回答

2条回答 默认 最新

  • douyun8901 2014-05-27 19:20

    In your pull.php file, you've got a REQ socket connecting to a PULL socket. Check out the docs to see compatible socket pairs. In particular, it appears that you want a REQ-REP pair so that your client can request data and your server replies with a response. You'd use PUSH-PULL if your server queues up data ready for the next client, and then your client pulls whatever is next from the queue.

    In either event, you cannot connect a REQ socket to a PULL socket or a PUSH socket.

    I don't fully understand your use case or communication architecture from the listed code or naming scheme, so I don't know how much more detail I can give than that, feel free to clarify what's going on and I might be able to advise more definitively what socket strategy you should be using.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?



  • ¥15 Jenkins+k8s部署slave节点offline
  • ¥15 微信小游戏反编译后,出现找不到分包的情况
  • ¥15 如何实现从tello无人机上获取实时传输的视频流,然后将获取的视频通过yolov5进行检测
  • ¥15 WPF使用Canvas绘制矢量图问题
  • ¥15 用三极管设计一个单管共射放大电路
  • ¥15 孟德尔随机化r语言运行问题
  • ¥15 pyinstaller编译的时候出现No module named 'imp'
  • ¥15 nirs_kit中打码怎么看(打码文件是csv格式)
  • ¥15 怎么把多于硬盘空间放到根目录下
  • ¥15 Matlab问题解答有两个问题