在前端开发中，流式输出（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>
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>
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>
- Fetch API：得当在HTTP响应中逐步获取和处理数据流。
- Server-Sent Events：用于从服务器推送实时变乱，简单易用。
- WebSockets：提供双向通信，得当需要实时交互的应用。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。 |
