php - 同一台机器上的套接字连接，PHP 到 C++ 并返回

Question

我必须在用 C++ 编写的应用程序和用 PHP 编写脚本的 Web 服务器之间实现通信。基本思想是用 C++ 应用程序创建一个套接字，绑定(bind)它并监听与其的 PHP 连接。然后 PHP 将通过 TCP 发送消息请求数据，而 C++ 将发回答案。单个 header 请求，单个字符串 (JSON) 答案。到目前为止，一切都很好。这是我在 PHP 端使用的代码:

<?php
error_reporting(E_ALL);

$service_port = 8080;
$address = 'localhost';


$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
} 

echo "Attempting to connect to '$address' on port '$service_port'...";
$result = socket_connect($socket, $address, $service_port);
if ($result === false) {
    echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
} 


$in = "request1";

$out = '';

socket_write($socket, $in, strlen($in));

$buf = 'This is my buffer.';
if (false !== ($bytes = socket_recv($socket, $buf, 2048, MSG_WAITALL))) {
    echo "Read $bytes bytes from socket_recv(). Closing socket...";
} else {
    echo "socket_recv() failed; reason: " . socket_strerror(socket_last_error($socket)) . "\n";
}
socket_close($socket);

echo $buf . "\n";
//elaborate the $buf
?>

现在我还想实现数据的自动更新，C++(服务器端)发送数据，PHP 端(客户端)收集数据。数据更新应每分钟进行一次。遗憾的是，我在网络开发方面没有太多经验，所以我很乐意就此提出一些建议。

我能做的最简单的事情是循环 PHP 代码，直到收到已知消息。我面临的问题是，在循环结束并且 PHP 脚本结束之前，我不会获取数据。为了克服这个问题，我尝试将 PHP 端的套接字设置为非阻塞在 socket_recv 中将选项 MSG_WAITALL 替换为 MSG_DONTWAIT 但没有任何改变。然后我试图跳出 PHP 脚本，但无法完成，因为我需要循环它以每秒获取数据。另外我遇到了另一个问题，在循环周期中，运行 PHP 的 apache 服务器出现 503 错误，服务器不可用。不知道为什么会这样，可能是接收到的消息缓冲区满了，或者脚本占用了太多资源。由于我缺乏经验，我无法理解为什么。我知道有很好的库可以执行我需要的操作，但我在嵌入式机器上工作，所以我只能使用基本库。

如何在 Apache 服务器上实现 PHP 从 C++ 应用程序获取定时数据？我忽略了什么？非常感谢您的帮助。

编辑:删除反问句。

Answer 1

与使用 tcp/ip 套接字将数据从通过 apache 执行的 php 脚本发送到另一个进程相比，使用 php 通过 tcp/ip 从另一个进程获取数据需要更多的努力。

您的 php 脚本将需要在 apache 之外启动，并且需要一个无限循环来持续监听给定端口以读取输入数据。 following post概述了我认为您追求的目标。

编辑

为了在网页上显示结果，您可以使用内存数据存储，例如 Redis。 php 服务器应用程序将更新 redis 中的数据结构，然后网页加载可以从 redis 中提取最新值并将其显示在屏幕上，但这需要刷新页面。

如果您需要在没有服务器回发的情况下接收到数据后立即刷新，这将需要一些 javascript。当用户加载页面时，您将初始化与 websocket 服务器的 websocket 连接(人们通常使用 node.js 和 socket.io 来实现这一点，但您可以在支持该技术的任何地方编写 websocket 服务器)。 websocket 服务器将订阅一个 redis channel ，该 channel 在更新时会将新值发送给所有连接的客户端。我想这也可以在没有 redis 的情况下完成，具体取决于您的要求。 websocket 服务器的程序也可以是使用单独线程从您的 c++ 程序接受信息的服务器。当数据来自 c++ 程序时，您可以将其直接发送到通过 websocket 连接的客户端。