可以使用wx.request自己实现一个 export default class EventSource {   constructor(url, retryTime = 0) {     this.url = url;     this.retryTime = retryTime;     this.listeners = {};     this.requestTask = null;     this.connect()   }   connect() {     this.requestTask = wx.request({       url: this.url,       enableChunked: true,       responseType: 'text',       method: 'GET',       timeout: 300e3,       success: res => {         this.emit('success', res)         if (this.retryTime > 0) {           setTimeout(() => {             this.connect()           }, this.retryTime)         }       },       fail: () => {       }     });     this.requestTask.onHeadersReceived(res => {       this.emit('open', res);     })     this.requestTask.onChunkReceived(res => this.handleChunk(res))   }   handleChunk(res) {     const arrayBuffer = res.data;     const uint8Array = new Uint8Array(arrayBuffer);     let data = uni.arrayBufferToBase64(uint8Array)     data = new Buffer(data, 'base64')     data = data.toString('utf8');     const eventData = this.parseEventData(data);     this.emit(eventData.event, {data: eventData.data});   }   parseEventData(data) {     const lines = data.split('\n');     const result = {};     lines.forEach(line => {       const [key, value] = line.trim().split(':');       if (key === 'data') {         const data = line.substring(5).trim();         try {           result[key] = JSON.parse(data);         } catch(e) {           result[key] = data;         }       } else {         result[key] = value;       }     });     if (!result.event) {       result.event = 'message'     }     return result;   }   addEventListener(event, callback) {     if (!this.listeners[event]) {       this.listeners[event] = [];     }     this.listeners[event].push(callback);   }   emit(event, data) {     if (this.listeners[event]) {       this.listeners[event].forEach(callback => {         callback(data);       });     }   }   close() {     if (this.requestTask) {       this.requestTask.abort();     }   } } // 使用方法 const eventSource = new EventSource('https://domain.com/test.php'); eventSource.addEventListener('message', res => { console.log('message', res) })