ZMQSocketException:无法连接 ZMQ:不支持的协议
ZMQSocketException: Failed to connect the ZMQ: Protocol not supported
我在连接插座时遇到问题
我正在使用 Rachet 和他们提供的指南 http://socketo.me/docs/push 进行简单的推拉式套接字,但是在尝试连接我的推式套接字时出现 ZMQSocketException:无法连接 ZMQ:不支持协议
这是我尝试连接插座的控制器代码
$fileData = $request->post('File');
$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'pusher');
$socket->connect("tcp:://localhost:5555");
$socket->send(json_encode($fileData));
这是我的拉式套接字,我在其中启动服务器等待接收消息,
require __DIR__ . '/../vendor/autoload.php';
require __DIR__ . '/../handlers/FileHandler.php';
$loop = Factory::create();
$handler = new FileHandler();
$context = new Context($loop);
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555');
$pull->on('message', [$handler, 'onFileDataSubmit']);
$webSock = new React\Socket\Server('127.0.0.1:8080', $loop);
$webServer = IoServer::factory(new HttpServer(new WsServer(new
WampServer($handler))), 8080);
$webServer->run();
错误我认为是因为这一行有两个::
。请使用只有一个的以下行。
$socket->connect("tcp://localhost:5555");
// OR
// $socket->connect("tcp://127.0.0.1:5555");
我在连接插座时遇到问题
我正在使用 Rachet 和他们提供的指南 http://socketo.me/docs/push 进行简单的推拉式套接字,但是在尝试连接我的推式套接字时出现 ZMQSocketException:无法连接 ZMQ:不支持协议
这是我尝试连接插座的控制器代码
$fileData = $request->post('File');
$context = new ZMQContext();
$socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'pusher');
$socket->connect("tcp:://localhost:5555");
$socket->send(json_encode($fileData));
这是我的拉式套接字,我在其中启动服务器等待接收消息,
require __DIR__ . '/../vendor/autoload.php';
require __DIR__ . '/../handlers/FileHandler.php';
$loop = Factory::create();
$handler = new FileHandler();
$context = new Context($loop);
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555');
$pull->on('message', [$handler, 'onFileDataSubmit']);
$webSock = new React\Socket\Server('127.0.0.1:8080', $loop);
$webServer = IoServer::factory(new HttpServer(new WsServer(new
WampServer($handler))), 8080);
$webServer->run();
错误我认为是因为这一行有两个::
。请使用只有一个的以下行。
$socket->connect("tcp://localhost:5555");
// OR
// $socket->connect("tcp://127.0.0.1:5555");