来自 php 源的 Socket.io

Posted 2023-04-18

【中文标题】来自 php 源的 Socket.io

【英文标题】：Socket.io from php source

【发布时间】：2011-09-07 22:31:55

【问题描述】：

我使用socket.io 开发了一个客户端-服务器连接，我很高兴地说它运行良好。 问题来了，因为我需要从 php Source（而不是“echo html javascript”）创建该连接。有点像

$socket = socket.createConectionJS;

我尝试了不同的方法，例如：

从服务器执行代码（使用spiderMonkey和节点） 创建一个 phpSocket 并将其连接到 ServerSocket.j（但显然格式不同）。或... 最后我尝试使用 curl 进行邮寄，我可以访问服务器脚本，但我无法打开连接

我认为解决它的唯一方法是通过创建一个套接字来模拟 Web 套接字连接，方法与 de socket.io 类相同，但在 php 中

任何 socket.io 专家可以提供帮助吗？

Tnks ！ ！ _

【问题讨论】：

我很久以前做过一个PHP套接字连接脚本，但不记得具体的了。您需要有一个脚本开始侦听特定套接字，然后循环以将新连接添加到订阅者列表，以及向这些订阅者接收/发送数据消息。此脚本必须连续运行且永不停止。

您很可能需要 VPS 或专用服务器才能访问套接字。我设置了一个 VPS 并创建了一个脚本，以确保 PHP 套接字服务器始终在启动时启动。

【参考方案1】：

是的，我刚才很快就开始了。我很幸运已经在 PHP 中构建了一个相当先进的网络抓取库，所以我只是将 TamperData（firefox 插件）中的 XML 插入其中，并进行了一些调整。

模拟 xhr-polling（我的代理不允许 websockets，而且这看起来更简单）...

请求：

/socket.io/1/?t=1337779479761   

（13377...这个数字只是一个时间戳，使用time()来生成）。

应该返回如下内容：

682970926640665221:60:60:websocket,htmlfile,xhr-polling,jsonp-polling

抓住前面的大数字，即您的“[CONNECT_ID]”，您将在接下来的会话中保留它。现在做另一个请求：

/socket.io/1/xhr-polling/[CONNECT_ID]?t=[TIMESTAMP]

你会得到类似 ::1 的东西

就我而言，这就是我费心去关注的，从那里看起来一切都很基本......没有特殊的标题或任何鬼鬼祟祟的东西。建议您使用 TamperData 或数据包嗅探器，并自行操作。这是我的代码的输出：

$ php RealTestCurl.php xml/xhr.xml init1 xhr1 xhr1 xhr1 xhr1

xmlFilename: xml/xhr.xml

Step: init1
Reply: 7638339571841585529:60:60:websocket,htmlfile,xhr-polling,jsonp-polling
Found: connect_id: ([0-9]*) - 7638339571841585529

Step: xhr1
Reply: 1::

Step: xhr1
Reply: ?46?5:::"name":"news","args":["hello":"world"]?63?5:::"name":"this","args":["will":"be received by everyone"]

Step: xhr1
.... there is a massive 20 second timeout here

Step: xhr1
8::

Step: xhr1
8::

在 node.js/socket.io 方面，运行他们首页的基本示例：

debug - client authorized
info  - handshake authorized 3445861131360107212
debug - setting request GET /socket.io/1/xhr-polling/3445861131360107212?t=1337781185
debug - setting poll timeout
debug - client authorized for 
debug - clearing poll timeout
debug - xhr-polling writing 1::
debug - set close timeout for client 3445861131360107212
debug - websocket writing 5:::"name":"this","args":["will":"be received by everyone"]

【参考方案2】：

我们开发并在生产中使用Elephant.io

我们基本上在我们的服务器 cron-jobs 中使用它来通知我们的前端，并在我们的 Symfony2 API 中将一些事件推送到前端。

看看吧，也许对你有帮助。

最好的

【参考方案3】：

我一直在寻找一种非常简单的方法来让 PHP 向客户端发送 socket.io 消息。

这不需要任何额外的 PHP 库 - 它只使用套接字。

与其像许多其他解决方案那样尝试连接到 websocket 接口，只需连接到 node.js 服务器并使用.on('data') 接收消息。

然后，socket.io 可以将其转发给客户。

我认为许多这些臃肿的解决方案都试图让 PHP 运行 websocket 协议。

何必呢？

在 Node.js 中检测来自 PHP 服务器的连接，如下所示：

//You might have something like this - just included to show object setup
var app = express();
var server = http.createServer(app);
var io = require('socket.io').listen(server);

server.on("connection", function(s) 
    var ip = s.remoteAddress;
    if(ip == "::ffff:127.0.0.1")    //If connection is from our server (localhost)
        s.on('data', function(buf) 
            var js = JSON.parse(buf);
            io.emit(js.msg,js.data); //Send the msg to socket.io clients
        );
    
);

这是非常简单的 php 代码——我将它封装在一个函数中——你可能会想出更好的东西。

请注意，8080 是我的 Node.js 服务器的端口 - 您可能需要更改。

function sio_message($message, $data) 
    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    $result = socket_connect($socket, '127.0.0.1', 8080);
    if(!$result) 
        die('cannot connect '.socket_strerror(socket_last_error()).PHP_EOL);
    
    $bytes = socket_write($socket, json_encode(Array("msg" => $message, "data" => $data)));
    socket_close($socket);

你可以这样使用它：

sio_message("chat message","Hello from PHP!");

您还可以发送转换为 json 并传递给客户端的数组。

sio_message("DataUpdate",Array("Data1" => "something", "Data2" => "something else"));

这是一种“信任”您的客户端从服务器获取合法消息的有用方法。

您还可以让 PHP 传递数据库更新，而无需数百个客户端查询数据库。

我希望我能早点找到这个 - 希望这会有所帮助！ ?