节点，socket.io - 当新条目添加到新闻提要时更新客户端？答案

【问题标题】：node, socket.io - update client when new entry added to news feed?节点，socket.io - 当新条目添加到新闻提要时更新客户端？
【发布时间】：2015-02-02 09:53:51
【问题描述】：

我已经用socket.io 创建了node 的client 和server。 server 正在执行 4 个 get 新闻提要请求并获取数据。这些数据通过socket.io 发送到client。

client 正在显示特定socket.io 事件发生的新闻提要。这一次效果很好。这是代码和working fiddle

server.js

var app = require('http').createServer(handler)
  , io = require('socket.io').listen(app)
  , fs = require('fs')
  , redis = require("redis");

var http = require("http");

// initialize the container for our data
var data = "";

var nfs = [
    "http://economictimes.feedsportal.com/c/33041/f/534037/index.rss",
    "http://www.timesonline.co.uk/tol/feeds/rss/uknews.xml",
    "http://www.independent.co.uk/news/business/rss",
    "http://www.dailymail.co.uk/money/index.rss"
];

//setInterval(function() {
    for(var i=0; i<nfs.length; i++){
        //console.log(nfs[i]);  
            http.get(nfs[i], function (http_res) {

                // this event fires many times, each time collecting another piece of the response
                http_res.on("data", function (chunk) {
                    // append this chunk to our growing `data` var
                    data += chunk;
                });

                // this event fires *one* time, after all the `data` events/chunks have been gathered
                http_res.on("end", function () {
                    // you can use res.send instead of console.log to output via express
                    console.log("data received");
                });
            }); 
    }
//}, 30000);

app.listen(8080);

function handler (req, res) {
  fs.readFile(__dirname + '/client.html',
  function (err, data) {
    if (err) {
      res.writeHead(500);
      return res.end('Error loading index.html');
    }

    res.writeHead(200);
    res.end(data);
  });
}

io.on('connection', function (socket) {

  //setInterval(function() {
      socket.emit('news', data);
      /*socket.on('my other event', function (data) {
        console.log(data);
      });*/
  //}, 5000);

});

client.html

<html>
    <head>
        <script src="https://cdn.socket.io/socket.io-1.2.1.js"></script>
        <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.8.3/jquery.min.js"></script>
        <script>
            //socket io client
            var socket = io.connect('http://localhost:8080');

            //on connetion, updates connection state and sends subscribe request
            socket.on('connect', function(data){
                setStatus('connected');
                socket.emit('subscribe', {channel:'notif'});
            });

            //when reconnection is attempted, updates status 
            socket.on('reconnecting', function(data){
                setStatus('reconnecting');
            });

            //on new message adds a new message to display

            socket.on('news', function (data) {
                console.log(data);              
                //socket.emit('my other event', { my: 'data' });
                addMessage(data);
            });

            /*socket.on('news', function (data) {
                debugger;
                socket.emit('my other event', { my: 'data' }
                var msg = "";
                if (data) {
                    msg = data; 
                }
            addMessage(msg);
            });*/

            //updates status to the status div
            function setStatus(msg) {
                $('#status').html('Connection Status : ' + msg);
            }

            //adds message to messages div
            function addMessage(msg) {  
                //debugger;
                var $xml = $(msg);
                var html = '';
                $xml.find("item").each(function() {
                    var $item = $(this);                                        
                    html += '<li>' +
                        '<h3><a href ="' + $item.find("link").text() + '" target="_new">' +
                        $item.find("title").text() + '</a></h3> ' +
                        '<p>' + $item.find("description").text() + '</p>' +
                        // '<p>' + $item.attr("c:date") + '</p>' +
                        '</li>';                    
                });             
                $('#result').prepend(html);
}
        </script>
    </head>
    <body>
        <div id="status"></div><br><br>     
        <ul id="result"></ul>       
    </body>
</html>

我对@987654336@ 的了解是，我们不需要长时间的服务器轮询，那么server 如何知道新闻已添加到受人尊敬的新闻提要中。

当新闻添加到新闻提要 rss 时，我如何用新添加的新闻更新 client ???

更新好的，所以从所有回复中我都明白socket.io 不可能知道已添加新条目。那么，我怎么知道（哪些工具/库确实需要知道已添加新条目并更新客户端）???

【问题讨论】：

标签： javascript jquery node.js sockets rss

【解决方案1】：

“节点”无法知道新条目何时添加到新闻提要中。您将不得不像现在一样轮询新闻服务。除非我完全误解了您的要求，否则这实际上与 Node 或 Socket.io 无关。

【讨论】：

【解决方案2】：

从新闻提要中检索消息完全独立于 socket.io，除非新闻提要在其端实现套接字并且您的服务器成为其客户端。因此，您将不得不继续使用 http 请求轮询它们，以了解它们是否更新了数据。

为了将更新通知您的客户，您只需发出新闻事件。大概你会在服务器上有逻辑来确保你只发送以前没有发送过的事件。

【讨论】：

感谢您的回答。将for 循环放入setInterval 是否是一种好习惯？我试过了，但检索到相同的数据。您能否介绍一下如何实施/避免这种情况？？？
当新条目通过节点添加到新闻提要时，您能告诉我如何更新客户端吗？？？目前它正在向客户端附加相同的条目。