多客戶端長輪詢處理與節點

Question

我想創建一個節點服務器，當服務器上的文件更新時將通知長輪詢客戶端。但是，我似乎無法拿出代碼讓服務器識別文件中的更改，並更新任何已執行更新的輪詢客戶端。

我的困惑根源在於處理時間戳，具體來說，我應該跟蹤哪些時間戳。客戶只是想知道文件是否已經改變。我認爲我們不應該關心請求何時進入，即我們不需要存儲請求的時間戳以確定對文件的更改。但是，我們需要跟蹤以確定何時到期請求。

所以，我想服務器收到一個請求，並立即存儲目標文件的時間戳。然後，服務器每10秒鐘檢查一次存儲的時間戳與當前時間的文件時間戳。如果存在差異，則文件已更新，並且服務器向客戶端發送指示文件已更改的響應。如果服務器在60秒之後沒有看到文件中的更改，它會向客戶端發送響應，以指示客戶端應該發起新的請求。

上述策略是否有意義？人們如何高效地處理時間戳記？而且，如何同時處理多個客戶？而且，如何防止服務器被來自同一客戶端的多個請求所超時？

Answer 1

您需要小心客戶端啓動新請求時發生的情況，因爲文件在此時間段內可能會更改。爲了照顧這個

一種方式是客戶端首先查詢當前文件狀態：

GET /file/timestamp 
    -> Server returns the timestamp 

GET /file/update?after=[timestamp] 
    -> Server checks whether the file has changed after the timestamp. 
     If it has, the server sends the response immediately. 
     Otherwise insert the client into a queue. 
     You don't need to save the timestamp in the queue. 
     If the server notices a change it notifies the clients. 

現在，因爲多個客戶端的服務器不應該做在客戶端請求處理的輪詢。而是有一個單獨的對象來處理輪詢。

根據您是否有一個或多個需要監視的文件，您最終可能會得到一個簡單或複雜的實現。總之，儘管您可能想將fs.watchFile換成EventEmitter，以便對文件所做的更改將發出change事件。

一個天真的實現是：

var watcher = new EventEmitter(); 

// Get the initial status 
fs.lstat('test.file', function(err, stat) { 
    if(err) return console.error(err); 
    watcher.stat = stat; 
}); 

// Start watching the file and emit an event whenever the file changes. 
fs.watchFile('test.file', function(curr, prev) { 
    console.log('File changed'); 
    watcher.stat = curr; 
    watcher.emit('change', curr); 
}); 

有了這些到位您的請求處理程序看起來像沿着線的東西：

var server = http.createServer(function(req, res) { 

    res.writeHead(200, { 'Content-Type': 'text/html' }); 

    var timeout; 
    var onChange = function(stat) { 
     // Prevent timeout from triggering 
     clearTimeout(timeout); 

     console.log('File changed at ' + stat.mtime); 
     res.end(
      'Changed at ' + stat.mtime + '. ' + 
      '<a href="?after=' + stat.mtime.getTime() + '">Poll again</a>'); 
    }; 

    var after = url.parse(req.url).query || ''; 
    after = after.split('='); 
    console.dir(after); 
    if(after.length < 2 || after[1] < watcher.stat.mtime.getTime()) { 
     console.log('Initial request or file changed before request'); 
     return onChange(watcher.stat); 
    } 

    console.log('Polling request.'); 

    watcher.once('change', onChange); 
    timeout = setTimeout(function() { 
     console.log('File not changed. Giving up.'); 
     watcher.removeListener('change', onChange); 
     res.end(
      'Unchanged! <a href="?after=' + after[1] + '">Poll again</a>'); 
    }, 10000); 
}); 

最後的「防止服務器被溢出來自同一客戶的多個請求？「 - 你沒有。不是如果你想保證這一點，並仍然允許匿名請求。您可以嘗試基於cookie的排除，但是如果您的服務允許匿名請求，則用戶可以停止發送cookie，在這一點上很難識別來自同一瀏覽器的請求。