php - PHP 从原始 tcp 套接字读取数据并使用 2 React 连接器通过 WebSocket 客户端发送它们
问题描述
这是我想要做的:
(套接字服务器:9006)<- (Websocket 客户端) ->(:8080 Websocket 服务器)
我想从 Socket Server 读取数据,编辑一些东西,然后发送到 Websocket Server。我必须能够同时读取来自 Websocker 服务器的数据
我设法使用 1 个用于 Socket 服务器的 React 连接器和 1 个用于 WebSocket 服务器的 Ratchet 连接器连接到两个服务器:
$loop = React\EventLoop\Factory::create();
$connector = new React\Socket\Connector($loop);
$connector->connect('192.168.0.1:9006')->then(function (React\Socket\ConnectionInterface $connection) use ($loop) {
$connection->pipe(new React\Stream\WritableResourceStream(STDOUT, $loop));
$connection->write("Hello World!\n");
$connection->on('data', function ($chunk) {
echo $chunk;
// How to send $chunk to the Websocket server through second connector, see below?
});
});
$reactConnector = new \React\Socket\Connector($loop, [
'dns' => '8.8.8.8',
'timeout' => 10
]);
$connector = new \Ratchet\Client\Connector($loop, $reactConnector);
$connector('ws://1.2.3.4:8080')
->then(function(Ratchet\Client\WebSocket $conn) {
$conn->on('message', function(\Ratchet\RFC6455\Messaging\MessageInterface $msg) use ($conn) {
echo "Received: {$msg}\n";
// $conn->close();
});
$conn->on('close', function($code = null, $reason = null) {
echo "Connection closed ({$code} - {$reason})\n";
});
$conn->send('Hello World!');
}, function(\Exception $e) use ($loop) {
echo "Could not connect: {$e->getMessage()}\n";
$loop->stop();
});
$loop->run();
所以我的问题是:如何在第二个连接器中使用在第一个连接器中接收到的数据?
感谢您的帮助!
解决方案
我找到了解决方案,如果它可以帮助任何人,我会粘贴在那里......:
require __DIR__ . '/vendor/autoload.php';
use React\Socket\Connector;
use React\Socket\ConnectionInterface;
$loop = React\EventLoop\Factory::create();
$reactConnector = new \React\Socket\Connector($loop, [
'dns' => '8.8.8.8',
'timeout' => 10
]);
$wsConnector = new \Ratchet\Client\Connector($loop, $reactConnector);
$wsConnector('ws://1.2.3.4:8080')
->then(function(Ratchet\Client\WebSocket $wsConn) use ($loop) {
$socketConnector = new React\Socket\Connector($loop);
$socketConnector->connect('192.168.0.1:9006')->then(function (ConnectionInterface $socketConn) use ($wsConn) {
$socketConn->on('data', function ($msg) use ($wsConn){
printf("Msg received from Socket Server : %s\n", $msg);
// Send it to wsServer
$wsConn->send($msg);
});
});
$wsConn->on('message', function(\Ratchet\RFC6455\Messaging\MessageInterface $msg) use ($wsConn) {
printf("Msg received from WebSocket Server : %s\n", $msg);
});
$wsConn->on('close', function($code = null, $reason = null) {
echo "Connection closed ({$code} - {$reason})\n";
});
}, function(\Exception $e) use ($loop) {
echo "Could not connect: {$e->getMessage()}\n";
$loop->stop();
});
$loop->run();
推荐阅读
- python - 我们如何在 PyModbus 库中生成流量?
- sql - 如果 MV 使用 ASNI Join,查询重写失败
- javascript - Discord.js:错误告诉我命令文件不存在
- python - 无法在 matplotlib 图中设置 xlabel 和 ylabel
- google-apps-script - 根据变量的名称从数组中分配变量值
- rust - rust 迭代器的 position() 和 rposition() 有什么区别,有什么原因吗?
- git - 为什么我不能从他们的网站更改我的 Github 存储库描述?
- javascript - Javascript 中具有指定索引的 QuerySelector(如 [1])
- javascript - Nodejs 自定义类不会在车把中呈现
- c# - 包 SharePoint.Client.Runtime 15.0.0 与 netcoreapp3.1 不兼容