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

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

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

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