观察/侦听REST API响应中的更改

基础概念

观察/侦听REST API响应中的更改通常涉及到实时监控API返回的数据变化。这种机制允许应用程序在数据发生变化时立即做出反应，而不是定期轮询以检查更新。这在构建实时应用、仪表板或任何需要即时数据更新的场景中非常有用。

类型

WebSockets：提供双向通信通道，允许服务器主动向客户端推送数据。
Server-Sent Events (SSE)：允许服务器向客户端推送单向事件流。
长轮询：客户端发起请求后，服务器根据数据是否有更新来决定是否立即响应，如果没有更新则保持连接直到有新数据或超时。

应用场景

实时聊天应用：确保消息能够即时送达。
股票交易系统：实时显示最新的股票价格和交易信息。
在线协作工具：如Google Docs，允许多用户同时编辑文档并看到彼此的更改。

遇到的问题及解决方法

问题：如何实现WebSockets？

解决方法：

// 服务器端（Node.js + ws库）
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
  });

  ws.send('Hello! Message From Server!!');
});

// 客户端（浏览器）
const socket = new WebSocket('ws://localhost:8080');

socket.onopen = function() {
  socket.send('Hello Server!');
};

socket.onmessage = function(event) {
  console.log('Message from server ', event.data);
};

参考链接：MDN Web Docs - WebSockets

问题：如何处理连接断开？

解决方法：

在WebSockets中，可以通过监听close事件来处理连接断开的情况，并尝试重新连接。

socket.onclose = function(event) {
  console.log('WebSocket is closed now.');
  setTimeout(function() {
    connectWebSocket();
  }, 2000); // 2秒后尝试重新连接
};

function connectWebSocket() {
  socket = new WebSocket('ws://localhost:8080');
  socket.onopen = function() {
    console.log('Connected!');
  };
  socket.onclose = function(event) {
    console.log('Disconnected!');
  };
}