PHP通过Curl向Node.js Socket.IO服务发送消息无响应问题求助

我来帮你搞定这个问题——你当前的核心问题是：Socket.IO服务只处理遵循Socket.IO协议的连接（比如浏览器端的socket.io-client），并不识别普通的HTTP POST请求，所以你的PHP用curl直接发请求到3000端口完全没用。下面是两种简单可行的解决方案，优先推荐第一种（最适合你的单实例场景）：

方案一：给Node.js服务添加HTTP接口，让PHP调用触发推送 #

这个方法最直接，我们给你的Socket.IO服务加一个专门的HTTP POST接口，PHP调用这个接口传递房间名和消息，由Node.js负责推送到对应的Socket.IO房间。

1. 修改Socket.IO服务代码 #

首先安装需要的依赖：

npm install body-parser

然后修改你的Node.js代码，添加HTTP路由：

const fs = require('fs');
const credentials = {
    key: fs.readFileSync('C:/xampp/apache/conf/ssl.key/server.key'),
    cert: fs.readFileSync('C:/xampp/apache/conf/ssl.crt/server.crt')
};
const app = require('express')();
const bodyParser = require('body-parser');

// 解析JSON格式的请求体
app.use(bodyParser.json());

let server = require('https').createServer(credentials, app);
let io = require('socket.io')(server);

// 添加PHP调用的推送接口
app.post('/send-message', (req, res) => {
    const { room, message } = req.body;
    // 校验必填参数
    if (!room || !message) {
        return res.status(400).json({ error: 'Room and message are required' });
    }
    // 向指定房间推送消息
    io.sockets.in(room).emit('message', { 
        room: room, 
        content: message 
    });
    console.log(`推送消息到房间 ${room}: ${message}`);
    res.status(200).json({ success: true });
});

server.listen(3000);

// 保留原有的Socket.IO连接逻辑
io.sockets.on('connection', function(socket){
    console.log("客户端已连接");
    socket.emit('test', { hello: 'world' });
    
    socket.on('some other event', function (data) {
        console.log(data);
    });
    
    socket.on('subscribe', function(room) {
        console.log('客户端加入房间', room);
        socket.join(room);
    });
    
    socket.on('unsubscribe', function(room) {
        console.log('客户端离开房间', room);
        socket.leave(room);
    });
    
    socket.on('send', function(data) {
        console.log('客户端发送消息');
        io.sockets.in(data.room).emit('message', data);
    });
});

2. 修改PHP调用代码 #

注意你的Socket.IO服务是HTTPS的，所以curl的URL要改成https://localhost:3000/send-message，同时修正请求参数：

require_once __DIR__.'/../vendor/autoload.php';

$dbHandler = \services\DBHandling::getInstance();

// 假设数据库操作成功后，准备推送数据
$room = "room3";
$message = "evacuate nuclear reactor block B !";

$data = [
    "room" => $room,
    "message" => $message
];
$data_string = json_encode($data);

$curl = curl_init("https://localhost:3000/send-message");
curl_setopt($curl, CURLOPT_HEADER, true);
curl_setopt($curl, CURLOPT_HTTPHEADER, [
    'Content-Type: application/json',
    'Content-Length: ' . strlen($data_string)
]);
curl_setopt($curl, CURLOPT_PORT, 3000);
curl_setopt($curl, CURLOPT_POST, true);
// 开发环境临时关闭SSL校验，生产环境必须开启并使用有效证书
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 0);
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, 2);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, $data_string);

$json_response = curl_exec($curl);
$status = curl_getinfo($curl, CURLINFO_HTTP_CODE);

if ($status != 200) {
    print_r([
        '错误信息',
        'HTTP状态码: ' . $status,
        '错误代码: ' . curl_errno($curl),
        '详细描述: ' . curl_error($curl)
    ]);
} else {
    echo "消息推送成功";
}

curl_close($curl);

方案二：使用PHP Socket.IO Emitter（适合多Node实例场景） #

如果你的系统以后需要扩展多个Socket.IO服务实例，可以用Redis作为消息中间件，配合PHP的Emitter库直接向Socket.IO集群推送消息。不过这个需要额外配置Redis，步骤稍复杂：

1. 给Socket.IO配置Redis适配器：

npm install socket.io-redis

然后修改Node.js代码添加Redis支持：

const redisAdapter = require('socket.io-redis');
io.adapter(redisAdapter({ host: 'localhost', port: 6379 }));

2. 安装PHP的Emitter库：

composer require rase/socket.io-emitter

3. PHP代码中使用Emitter推送：

require_once __DIR__.'/../vendor/autoload.php';

$emitter = new \SocketIO\Emitter([
    'host' => 'localhost',
    'port' => 6379
]);

$emitter->to('room3')->emit('message', [
    'message' => 'evacuate nuclear reactor block B !'
]);

关键注意事项 #

• 生产环境下必须关闭CURLOPT_SSL_VERIFYPEER和CURLOPT_SSL_VERIFYHOST的false设置，使用有效的SSL证书，避免安全风险。
• 方案一的HTTP接口建议添加身份校验（比如API密钥），防止非法请求。

内容的提问来源于stack exchange，提问作者DataVader