PHP 向 Node/Socket.IO 服务器发送消息

Question

我不太确定我是否以正确的方式处理这件事。我想坚持使用我的 Socket.IO 服务器，不想在 Node 内创建一个单独的 HTTP 服务器。有了这个，我可以创建一个可以将数据(例如:玩家从在线商店购买商品)直接发送到 Node Socket.IO 服务器的 PHP 客户端吗？

我从这个开始:

<?php

class communicator {
   public function connect($address, $port){
      $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

      if($socket){
          try {
              socket_connect($socket, $address, $port);
          } catch(Exception $e){
              throw new Exception($e->getMessage());
          }
      }else{
          throw new Exception('Could not create socket.');
      }
}

?>

套接字似乎可以很好地连接到 Node 服务器，但我如何才能开始直接从 PHP 客户端接收数据？

例如:假设我使用 socket_write 向服务器发送消息。我如何通过 Socket.IO 获得它？

希望我的问题有道理!

Answer 1

我搜索了很多，终于找到了一个相对简单的解决方案。

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

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

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

像这样在 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) {
    //If connection is from our server (localhost)
    if(s.remoteAddress == "::ffff:127.0.0.1") {
        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("聊天消息","来自 PHP 的问候!");

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

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

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

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

我希望我能早点找到这个 - 希望这有帮助! 😉

后期编辑:不确定这是否是必需的，但我将其添加到我的 http.conf(Apache 配置)中:

我想我会把代码放在这里以防它对任何人有帮助。

在 httpd.conf 中我添加了以下代码:

RewriteEngine On
RewriteCond %{HTTP:UPGRADE} ^WebSocket$ [NC]
RewriteCond %{HTTP:CONNECTION} Upgrade$ [NC]
RewriteRule .* ws://localhost:8080%{REQUEST_URI} [P]

ProxyRequests Off
ProxyPass        /socket.io http://localhost:8080/socket.io retry=0
ProxyPassReverse /socket.io http://localhost:8080/socket.io retry=0

ProxyPass "/node" "http://localhost:8080/"