输出前端流式的三种实现方法

这篇文章主要介绍了前端流式输出的三种实现方法,流式输出在前端开发中用于逐步处理和显示数据,特别是对于大型数据集和实时数据,文中通过代码介绍的非常详细,需要的朋友可以参考下

前言

在前端开发中，流式输出（streaming output）通常是指逐步输出数据，而不是等待所有数据准备好后一次性显示。这种技术在处理大型数据集、实时数据或需要逐步加载内容的情况下非常有用。下面介绍几种实现流式输出的方法，包括使用 Fetch API 和 EventSource。

1. 使用 Fetch API 实现流式输出

通过 Fetch API 和可读流（Readable Streams），可以在响应到达时逐步读取和处理数据。这在处理大文件或实时更新时非常有效。

示例代码

<!DOCTYPE html><html lang="en"><head>    <meta charset="UTF-8">    <meta name="viewport" content="width=device-width, initial-scale=1.0">    <title>Stream Output Example</title></head><body>    <h1>Streamed Output</h1>    <div id="output"></div>    <script>        async function streamData() {            const response = await fetch('https://jsonplaceholder.typicode.com/posts');            const reader = response.body.getReader();            const outputDiv = document.getElementById('output');            let result;            // 读取数据流            while (!(result = await reader.read()).done) {                const chunk = new TextDecoder().decode(result.value);                // 将新接收到的部分添加到输出                outputDiv.innerHTML += chunk + '<br>';            }        }        streamData();    </script></body></html>

2. 使用 Server-Sent Events (SSE)

Server-Sent Events (SSE) 是一种技术，可以从服务器向客户端推送实时数据。它基于HTTP协议，使用EventSource API。

示例代码

<!DOCTYPE html><html lang="en"><head>    <meta charset="UTF-8">    <meta name="viewport" content="width=device-width, initial-scale=1.0">    <title>SSE Example</title></head><body>    <h1>Server-Sent Events Example</h1>    <div id="output"></div>    <script>        const outputDiv = document.getElementById('output');        const eventSource = new EventSource('https://example.com/sse'); // 替换为你的SSE服务URL        eventSource.onmessage = function(event) {            outputDiv.innerHTML += 'Received: ' + event.data + '<br>';        };        eventSource.onerror = function(event) {            console.error('Error occurred:', event);            eventSource.close(); // 关闭连接        };    </script></body></html>

3. 使用 WebSockets

WebSockets 提供了全双工通信，允许在客户端和服务器之间进行实时数据传输。这适用于需要双向通信的场景。

示例代码

<!DOCTYPE html><html lang="en"><head>    <meta charset="UTF-8">    <meta name="viewport" content="width=device-width, initial-scale=1.0">    <title>WebSocket Example</title></head><body>    <h1>WebSocket Example</h1>    <div id="output"></div>    <script>        const outputDiv = document.getElementById('output');        const socket = new WebSocket('wss://example.com/socket'); // 替换为你的WebSocket服务URL        socket.onopen = function() {            console.log('WebSocket connection established');        };        socket.onmessage = function(event) {            outputDiv.innerHTML += 'Received: ' + event.data + '<br>';        };        socket.onerror = function(error) {            console.error('WebSocket error:', error);        };        socket.onclose = function() {            console.log('WebSocket connection closed');        };    </script></body></html>