微信小程序sse流式请求

微信小程序中的 SSE (Server-Sent Events) 流式请求是一种实时数据传输的技术，它允许服务端主动向客户端推送数据，而不需要客户端频繁地发起请求。在微信小程序中，你可以通过 `wx.request` 的 `eventOffset` 和 `success` 回调函数结合实现 SSE 功能。

以下是使用步骤：

1. **创建事件源**:
首先，在服务器端设置一个支持 SSE 的 HTTP 资源，并监听数据更改。

// server-side code (e.g., Node.js with Express)
const http = require('http');
const express = require('express');

const app = express();
app.use(express.sse());

app.get('/your-stream-url', function(req, res) {
  // Your data sending logic
  setInterval(function() {
    res.write({ event: 'message', data: 'New message received.' });
  }, 5000); // Send a new message every 5 seconds as an example
  res.end(); // Close the connection after sending data
});

2. **微信小程序前端接收**:
在小程序中，你需要开启长连接并处理服务器发送的数据。

Page({
  onReady() {
    const sseClient = wx.createSSEClient({
      url: 'https://your-server.com/your-stream-url',
      success(res) {
        console.log('Connected to SSE stream.');
        res.onMessage((event) => {
          console.log(`Received message: ${event.data}`);
          // Handle the received data here
        });
      },
      fail(err) {
        console.error('Failed to connect to SSE:', err);
      }
    });

    // Start listening for events
    sseClient.start();
  },
})