乐闻世界logo
搜索文章和话题

如何实现基本的“长轮询”?

1 个月前提问
1 个月前修改
浏览次数13

1个答案

1

什么是长轮询?

长轮询(Long Polling)是一种实现服务器推送技术的方式,主要用在客户端需要实时获取更新的情况下。传统的轮询方式是客户端定时向服务器发送请求,无论服务器是否有新的数据更新。而长轮询的方式是客户端发送请求后,服务器会持续保持该连接直到有新的数据可发送,此时服务器会响应请求并关闭连接。如果没有数据,连接会保持到一个预设的超时时间,然后服务器会发送一个空响应给客户端,客户端在接收到响应后,重新发起请求。

如何实现长轮询?

实现长轮询主要涉及到客户端和服务器端的交互。这里以一个简单的聊天应用为例,来说明如何实现长轮询。

服务器端的实现:

  1. 接收客户端请求: 服务器端接收到客户端的请求后,首先检查是否有新消息。
  2. 等待数据: 如果当前没有新消息,服务器不立即响应,而是将请求挂起。
  3. 响应请求: 当有新消息时,服务器立即将这些消息作为响应数据返回给客户端。
  4. 超时处理: 如果在一个预定的时间内(例如30秒)没有新消息,服务器应发送一个空响应,告知客户端没有新数据。

使用Node.js可以这样实现:

javascript
const express = require('express'); const app = express(); const PORT = 3000; let messageQueue = []; // 模拟存储消息的队列 app.get('/poll', (req, res) => { const sendResponse = (data) => { res.json({ data }); res.end(); }; if (messageQueue.length > 0) { sendResponse(messageQueue.shift()); } else { // 如果没有消息,将请求挂起 let timeoutId = setTimeout(() => { sendResponse("No new messages"); }, 30000); // 30秒后发送空响应 // 如果在超时前接收到新消息,取消超时并响应 req.on('newMessage', () => { clearTimeout(timeoutId); sendResponse(messageQueue.shift()); }); } }); // 一个简单的路由来接收并存储新消息 app.post('/send', (req, res) => { const { message } = req.body; messageQueue.push(message); req.emit('newMessage'); res.status(200).send("Message received"); }); app.listen(PORT, () => { console.log(`Server is running on port ${PORT}`); });

客户端的实现:

  1. 发送请求: 客户端发送一个HTTP请求到服务器以开始轮询。
  2. 处理响应: 接收到服务器的响应后,处理响应数据(新消息或空数据)。
  3. 再次请求: 不论响应是新消息还是空数据,客户端都需要再次发起请求以继续轮询。

使用JavaScript XMLHttpRequest来实现:

javascript
function poll() { var xhr = new XMLHttpRequest(); xhr.open("GET", "http://localhost:3000/poll", true); xhr.onload = function () { if (xhr.status >= 200 && xhr.status < 300) { // 处理从服务器返回的数据 console.log('Response:', xhr.responseText); // 继续轮询 poll(); } }; xhr.onerror = function () { console.error('Request failed'); poll(); }; xhr.send(); } // 开始轮询 poll();

总结

长轮询是一种有效但可能资源密集的方法来实现服务器到客户端的实时通信。虽然现代的Web应用更倾向于使用WebSocket等更高效的通信方式,长轮询仍然是一种在不支持WebSocket的环境下的备选方案。

2024年8月5日 00:54 回复

你的答案