同一台机器上的套接字连接,PHP 到 C++ 并返回
Socket connection on same machine, PHP to C++ and back
我必须在用 c++ 编写的应用程序和使用 PHP 编写脚本的 Web 服务器之间实现通信。
基本思想是使用 C++ 应用程序创建一个套接字,绑定它并侦听与它的 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
?>
现在我还想实现一个 auto-update 数据,c++(服务器端)发送数据,PHP 端(客户端)收集数据。
数据更新应每分钟进行一次。
可悲的是,我在网络开发方面没有太多经验,所以我很乐意就此提出一些建议。
我能做的最简单的事情是循环 PHP 代码,直到收到已知消息。我面临的问题是,在循环结束并且 PHP 脚本结束之前,我不会获取数据。
为了克服这个问题,我尝试将 PHP 侧的套接字设置为 non-blocking
将 socket_recv 中的选项 MSG_WAITALL 替换为 MSG_DONTWAIT 但没有任何改变。然后我试图跳出 PHP 脚本,但它无法完成,因为我需要循环它以每秒获取数据。
另外我遇到了另一个问题,在循环周期中,PHP 位于 运行 上的 apache 服务器出现 503 错误,服务器不可用。
不知道为什么会这样,可能是接收到的消息缓冲区满了,或者脚本占用了太多资源。
由于我缺乏经验,我无法理解为什么。
我知道有很好的库可以执行我需要的操作,但我在嵌入式机器上工作,所以我只能使用基本库。
如何在 Apache 服务器上实现 PHP 从 c++ 应用程序获取定时数据?我忽略了什么?
非常感谢您的帮助。
编辑:删除反问。
不要重新发明轮子。使用网络套接字。它旨在进行这种异步通信,您可以通过它发送 JSON 就好了。
有 C++ 和 PHP 的库,这意味着这应该很容易。
使用 php 通过 tcp/ip 从另一个进程获取数据与使用 tcp/ip 个插座。
您的 php 脚本将需要在 apache 之外启动,并且需要一个无限循环来持续侦听给定端口以读取输入数据。 following post 概述了我认为您所追求的目标。
编辑
为了在网页上显示结果,您可以使用内存数据存储,例如 Redis。 php 服务器应用程序会更新 redis 中的数据结构,然后网页加载可以从 redis 中提取最新值并将其显示在屏幕上,但这需要刷新页面。
如果您要求在没有服务器回发的情况下接收到数据后立即刷新,这将需要一些 javascript。当用户加载页面时,您将初始化与 websocket 服务器的 websocket 连接(人们通常使用 node.js 和 socket.io 来实现这一点,但您可以在支持该技术的任何地方编写 websocket 服务器)。 websocket 服务器将订阅一个 redis 通道,该通道在更新时会将新值发送给所有连接的客户端。我想这也可以在没有 redis 的情况下完成,具体取决于您的要求。 websocket 服务器的程序也可以是使用单独线程从您的 c++ 程序接受信息的服务器。当数据来自 c++ 程序时,您可以将其直接发送到通过 websocket 连接的客户端。
我必须在用 c++ 编写的应用程序和使用 PHP 编写脚本的 Web 服务器之间实现通信。 基本思想是使用 C++ 应用程序创建一个套接字,绑定它并侦听与它的 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
?>
现在我还想实现一个 auto-update 数据,c++(服务器端)发送数据,PHP 端(客户端)收集数据。 数据更新应每分钟进行一次。 可悲的是,我在网络开发方面没有太多经验,所以我很乐意就此提出一些建议。
我能做的最简单的事情是循环 PHP 代码,直到收到已知消息。我面临的问题是,在循环结束并且 PHP 脚本结束之前,我不会获取数据。 为了克服这个问题,我尝试将 PHP 侧的套接字设置为 non-blocking 将 socket_recv 中的选项 MSG_WAITALL 替换为 MSG_DONTWAIT 但没有任何改变。然后我试图跳出 PHP 脚本,但它无法完成,因为我需要循环它以每秒获取数据。 另外我遇到了另一个问题,在循环周期中,PHP 位于 运行 上的 apache 服务器出现 503 错误,服务器不可用。 不知道为什么会这样,可能是接收到的消息缓冲区满了,或者脚本占用了太多资源。 由于我缺乏经验,我无法理解为什么。 我知道有很好的库可以执行我需要的操作,但我在嵌入式机器上工作,所以我只能使用基本库。
如何在 Apache 服务器上实现 PHP 从 c++ 应用程序获取定时数据?我忽略了什么? 非常感谢您的帮助。
编辑:删除反问。
不要重新发明轮子。使用网络套接字。它旨在进行这种异步通信,您可以通过它发送 JSON 就好了。
有 C++ 和 PHP 的库,这意味着这应该很容易。
使用 php 通过 tcp/ip 从另一个进程获取数据与使用 tcp/ip 个插座。
您的 php 脚本将需要在 apache 之外启动,并且需要一个无限循环来持续侦听给定端口以读取输入数据。 following post 概述了我认为您所追求的目标。
编辑
为了在网页上显示结果,您可以使用内存数据存储,例如 Redis。 php 服务器应用程序会更新 redis 中的数据结构,然后网页加载可以从 redis 中提取最新值并将其显示在屏幕上,但这需要刷新页面。
如果您要求在没有服务器回发的情况下接收到数据后立即刷新,这将需要一些 javascript。当用户加载页面时,您将初始化与 websocket 服务器的 websocket 连接(人们通常使用 node.js 和 socket.io 来实现这一点,但您可以在支持该技术的任何地方编写 websocket 服务器)。 websocket 服务器将订阅一个 redis 通道,该通道在更新时会将新值发送给所有连接的客户端。我想这也可以在没有 redis 的情况下完成,具体取决于您的要求。 websocket 服务器的程序也可以是使用单独线程从您的 c++ 程序接受信息的服务器。当数据来自 c++ 程序时,您可以将其直接发送到通过 websocket 连接的客户端。