关于Nodejs推送

关于Node.js推送

最近才开始研究Node.js，发现这个推送真的很好用。公司有一个项目是股票行情，目前使用的是定时通过AJAX请求来获取数据。现在计划将其改造成基于Node.js的实时推送系统。

使用Socket.IO实现推送

首先，我们需要安装socket.io库来实现实时通信。socket.io是一个非常强大的库，可以让你轻松地建立WebSocket连接，并且支持多种传输方式，包括WebSocket、长轮询等。

npm install socket.io

接下来，我们创建一个简单的Node.js服务器来处理WebSocket连接。

const http = require('http');
const socketIo = require('socket.io');

// 创建HTTP服务器
const server = http.createServer((req, res) => {
    res.writeHead(200, { 'Content-Type': 'text/html' });
    res.end('<h1>Hello, world!</h1>');
});

// 将HTTP服务器传递给socket.io
const io = socketIo(server);

// 当有客户端连接时触发
io.on('connection', (socket) => {
    console.log('A user connected');

    // 接收到消息时触发
    socket.on('message', (data) => {
        console.log('Message received:', data);
        // 广播消息给所有连接的客户端
        io.emit('message', data);
    });

    // 当客户端断开连接时触发
    socket.on('disconnect', () => {
        console.log('User disconnected');
    });
});

server.listen(3000, () => {
    console.log('Server is running on port 3000');
});

PHP与Node.js通信

对于PHP应用（如CodeIgniter框架）来说，当数据更新时需要通知Node.js服务器进行推送。这里可以使用HTTP请求的方式来进行通信。例如，你可以使用curl或file_get_contents函数发送HTTP POST请求到Node.js服务器。

<?php
$data = [
    'stock' => 'AAPL',
    'price' => 150.50
];

$options = [
    'http' => [
        'method' => 'POST',
        'content' => json_encode($data),
        'header' => 'Content-Type: application/json'
    ]
];

$context = stream_context_create($options);
$result = file_get_contents('http://localhost:3000/notify', false, $context);

if ($result === FALSE) {
    // 处理错误
}
?>

在Node.js端，你需要设置一个路由来接收这些HTTP请求：

io.on('connection', (socket) => {
    // 接收HTTP POST请求
    app.post('/notify', (req, res) => {
        const data = req.body;
        console.log('Received notification:', data);
        // 广播消息给所有连接的客户端
        io.emit('message', data);
        res.send({ status: 'success' });
    });
});

模板引擎

关于模板引擎，如果你已经习惯了PHP的模板引擎（如Twig或Blade），你不需要因为使用Node.js而更换它。Node.js生态系统中有许多成熟的模板引擎，如EJS、Pug等，但你可以在服务器端继续使用PHP进行渲染，客户端只需要关注WebSocket通信即可。

希望以上内容对你有所帮助！如果有任何疑问，请随时提问。

换websocket？还不如用bigpipe，websocket ie7以上才支持吧，nodejs的部署维护监控，你们能hold住么，等着踩坑吧