前端流式輸出的三種實(shí)現(xiàn)方法

更新時(shí)間：2024年11月23日 11:33:57 作者：呼叫6945

這篇文章主要介紹了前端流式輸出的三種實(shí)現(xiàn)方法,流式輸出在前端開發(fā)中用于逐步處理和顯示數(shù)據(jù),特別是對(duì)于大型數(shù)據(jù)集和實(shí)時(shí)數(shù)據(jù),文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下

前言

在前端開發(fā)中，流式輸出（streaming output）通常是指逐步輸出數(shù)據(jù)，而不是等待所有數(shù)據(jù)準(zhǔn)備好后一次性顯示。這種技術(shù)在處理大型數(shù)據(jù)集、實(shí)時(shí)數(shù)據(jù)或需要逐步加載內(nèi)容的情況下非常有用。下面介紹幾種實(shí)現(xiàn)流式輸出的方法，包括使用 Fetch API 和 EventSource。

1. 使用 Fetch API 實(shí)現(xiàn)流式輸出

通過 Fetch API 和可讀流（Readable Streams），可以在響應(yīng)到達(dá)時(shí)逐步讀取和處理數(shù)據(jù)。這在處理大文件或?qū)崟r(shí)更新時(shí)非常有效。

示例代碼

<!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;

            // 讀取數(shù)據(jù)流
            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) 是一種技術(shù)，可以從服務(wù)器向客戶端推送實(shí)時(shí)數(shù)據(jù)。它基于HTTP協(xié)議，使用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服務(wù)URL

        eventSource.onmessage = function(event) {
            outputDiv.innerHTML += 'Received: ' + event.data + '<br>';
        };

        eventSource.onerror = function(event) {
            console.error('Error occurred:', event);
            eventSource.close(); // 關(guān)閉連接
        };
    </script>
</body>
</html>

3. 使用 WebSockets

WebSockets 提供了全雙工通信，允許在客戶端和服務(wù)器之間進(jìn)行實(shí)時(shí)數(shù)據(jù)傳輸。這適用于需要雙向通信的場(chǎng)景。

示例代碼

<!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服務(wù)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>