Flutter 移动端 AI 流式对话：SSE 事件接收与 UI 更新完整指南

สถานการณ์ข้อผิดพลาดจริงที่ประสบ

ผมเคยเจอปัญหาหนักใจมากเมื่อพัฒนาแอป Flutter สำหรับ AI Chat เมื่อผู้ใช้งานรายงานว่า "ข้อความตอบกลับมาช้ามาก" และ "UI ค้างเป็นสิบวินาที" หลังจากวิเคราะห์พบว่าปัญหาคือการใช้ HTTP request แบบธรรมดาแทนที่จะใช้ SSE (Server-Sent Events) ทำให้ต้องรอข้อมูลทั้งหมดก่อนแสดงผล แถมยังเจอ ConnectionError: timeout อีกเพราะ connection ถูกตัดเมื่อ response ใหญ่เกินไป บทความนี้จะสอนวิธีแก้ปัญหาอย่างถูกต้องด้วยการใช้ [HolySheep AI](https://www.holysheep.ai/register) ซึ่งให้บริการ API รองรับ SSE streaming ได้อย่างเสถียรพร้อมความหน่วงต่ำกว่า 50ms และราคาประหยัดกว่า 85% เมื่อเทียบกับผู้ให้บริการรายอื่น

SSE คืออะไรและทำไมต้องใช้

Server-Sent Events เป็นเทคโนโลยีที่ช่วยให้เซิร์ฟเวอร์ส่งข้อมูลมายังไคลเอนต์แบบต่อเนื่องโดยไม่ต้องรอให้ request เสร็จสิ้น สำหรับ AI chat ที่ต้องแสดงคำตอบทีละส่วน การใช้ SSE ช่วยให้ผู้ใช้เห็นข้อความปรากฏทันทีที่ AI พิมพ์ออกมา แทนที่จะรอเป็นนาที

เริ่มต้นโปรเจกต์ Flutter

ก่อนอื่นต้องเพิ่ม dependencies ที่จำเป็นในไฟล์ pubspec.yaml:

dependencies:
  flutter:
    sdk: flutter
  http: ^1.2.0
  flutter_chat_ui: ^1.6.6
  uuid: ^4.2.1
  provider: ^6.1.1
  shared_preferences: ^2.2.2

dependencies:
  flutter:
    sdk: flutter
  http: ^1.2.0
  flutter_chat_ui: ^1.6.6
  uuid: ^4.2.1
  provider: ^6.1.1
  shared_preferences: ^2.2.2

สร้าง Stream Service สำหรับ SSE

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:http/http.dart' as http;

class SSEStreamService {
  static const String _baseUrl = 'https://api.holysheep.ai/v1';
  static const String _apiKey = 'YOUR_HOLYSHEEP_API_KEY';
  
  Stream streamChat(String message, {String model = 'gpt-4.1'}) async* {
    final uri = Uri.parse('$_baseUrl/chat/completions');
    
    final response = await http.post(
      uri,
      headers: {
        'Content-Type': 'application/json',
        'Authorization': 'Bearer $_apiKey',
        'Accept': 'text/event-stream',
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive',
      },
      body: jsonEncode({
        'model': model,
        'messages': [
          {'role': 'user', 'content': message}
        ],
        'stream': true,
        'temperature': 0.7,
        'max_tokens': 2000,
      }),
    ).timeout(
      const Duration(seconds: 30),
      onTimeout: () => throw Exception('ConnectionError: timeout - เซิร์ฟเวอร์ไม่ตอบสนองภายใน 30 วินาที'),
    );

    if (response.statusCode == 401) {
      throw Exception('401 Unauthorized - API Key ไม่ถูกต้องหรือหมดอายุ');
    }
    
    if (response.statusCode != 200) {
      throw Exception('ServerError: ${response.statusCode} - ${response.body}');
    }

    final stream = response.stream.transform(utf8.decoder);
    
    String buffer = '';
    
    await for (final chunk in stream) {
      buffer += chunk;
      final lines = buffer.split('\n');
      buffer = lines.removeLast();
      
      for (final line in lines) {
        if (line.startsWith('data: ')) {
          final data = line.substring(6);
          if (data == '[DONE]') {
            yield '[EOF]';
            return;
          }
          
          try {
            final json = jsonDecode(data);
            final content = json['choices']?[0]?['delta']?['content'];
            if (content != null && content.toString().isNotEmpty) {
              yield content.toString();
            }
          } catch (e) {
            // ข้าม chunk ที่ parse ไม่ได้
          }
        }
      }
    }
  }
}

สร้าง Chat Provider สำหรับจัดการ State

import 'package:flutter/foundation.dart';
import 'package:flutter_chat_ui/flutter_chat_ui.dart';
import 'package:uuid/uuid.dart';
import '../services/sse_stream_service.dart';

class ChatProvider extends ChangeNotifier {
  final SSEStreamService _streamService = SSEStreamService();
  final List _messages = [];
  final Uuid _uuid = const Uuid();
  
  bool _isLoading = false;
  String _currentStreamingText = '';
  
  List get messages => List.unmodifiable(_messages);
  bool get isLoading => _isLoading;
  String get currentStreamingText => _currentStreamingText;
  
  Future sendMessage(String text) async {
    if (text.trim().isEmpty || _isLoading) return;
    
    _isLoading = true;
    _currentStreamingText = '';
    
    final userMessage = types.TextMessage(
      id: _uuid.v4(),
      text: text,
      author: types.User(id: 'user'),
      createdAt: DateTime.now().millisecondsSinceEpoch,
    );
    
    _messages.add(userMessage);
    notifyListeners();
    
    final botMessageId = _uuid.v4();
    
    try {
      await for (final chunk in _streamService.streamChat(text)) {
        if (chunk == '[EOF]') break;
        
        _currentStreamingText += chunk;
        notifyListeners();
      }
      
      final botMessage = types.TextMessage(
        id: botMessageId,
        text: _currentStreamingText,
        author: types.User(id: 'assistant'),
        createdAt: DateTime.now().millisecondsSinceEpoch,
      );
      
      _messages.add(botMessage);
    } catch (e) {
      final errorMessage = types.TextMessage(
        id: _uuid.v4(),
        text: 'เกิดข้อผิดพลาด: ${e.toString()}',
        author: types.User(id: 'assistant'),
        createdAt: DateTime.now().millisecondsSinceEpoch,
      );
      _messages.add(errorMessage);
    } finally {
      _isLoading = false;
      _currentStreamingText = '';
      notifyListeners();
    }
  }
  
  void clearChat() {
    _messages.clear();
    notifyListeners();
  }
}

สร้าง Chat Screen UI

import 'package:flutter/material.dart';
import 'package:provider/provider.dart';
import 'package:flutter_chat_ui/flutter_chat_ui.dart';
import '../providers/chat_provider.dart';

class ChatScreen extends StatelessWidget {
  const ChatScreen({super.key});

  @override
  Widget build(BuildContext context) {
    return ChangeNotifierProvider(
      create: (_) => ChatProvider(),
      child: Scaffold(
        appBar: AppBar(
          title: const Text('AI Chat - HolySheep'),
          backgroundColor: const Color(0xFF6366F1),
          foregroundColor: Colors.white,
          actions: [
            IconButton(
              icon: const Icon(Icons.delete_outline),
              onPressed: () {
                context.read().clearChat();
              },
            ),
          ],
        ),
        body: Consumer(
          builder: (context, chatProvider, _) {
            return Column(
              children: [
                Expanded(
                  child: Chat(
                    messages: chatProvider.messages,
                    onSendPressed: (types.PartialText message) {
                      chatProvider.sendMessage(message.text);
                    },
                    isLoading: chatProvider.isLoading,
                    typingIndicator: chatProvider.isLoading && 
                        chatProvider.currentStreamingText.isNotEmpty
                        ? _buildStreamingIndicator(chatProvider.currentStreamingText)
                        : null,
                  ),
                ),
                if (chatProvider.isLoading && chatProvider.currentStreamingText.isEmpty)
                  const Padding(
                    padding: EdgeInsets.all(16),
                    child: Row(
                      mainAxisAlignment: MainAxisAlignment.center,
                      children: [
                        SizedBox(
                          width: 20,
                          height: 20,
                          child: CircularProgressIndicator(strokeWidth: 2),
                        ),
                        SizedBox(width: 12),
                        Text('กำลังประมวลผล...'),
                      ],
                    ),
                  ),
              ],
            );
          },
        ),
      ),
    );
  }
  
  Widget _buildStreamingIndicator(String text) {
    return Container(
      padding: const EdgeInsets.symmetric(horizontal: 16, vertical: 8),
      child: Row(
        mainAxisSize: MainAxisSize.min,
        children: [
          Container(
            width: 8,
            height: 8,
            decoration: const BoxDecoration(
              color: Colors.green,
              shape: BoxShape.circle,
            ),
          ),
          const SizedBox(width: 8),
          Flexible(
            child: Text(
              text,
              style: const TextStyle(fontSize: 14),
              maxLines: 3,
              overflow: TextOverflow.ellipsis,
            ),
          ),
          const SizedBox(
            width: 16,
            height: 16,
            child: CircularProgressIndicator(strokeWidth: 1),
          ),
        ],
      ),
    );
  }
}

ข้อผิดพลาดที่พบบ่อยและวิธีแก้ไข

1. ConnectionError: timeout - เซิร์ฟเวอร์ไม่ตอบสนอง

ปัญหานี้เกิดจากการตั้งค่า timeout สั้นเกินไปหรือเครือข่ายไม่เสถียร

// โค้ดที่ทำให้เกิดปัญหา
final response = await http.post(uri, headers: headers, body: body);

// โค้ดแก้ไข - เพิ่ม timeout ที่เหมาะสมและ retry logic
Future<http.Response> postWithRetry(
  Uri uri, {
  Map<String, String>? headers,
  String? body,
  int maxRetries = 3,
}) async {
  int attempt = 0;
  
  while (attempt < maxRetries) {
    try {
      final response = await http.post(
        uri,
        headers: headers,
        body: body,
      ).timeout(
        const Duration(seconds: 60), // เพิ่มเป็น 60 วินาที
      );
      return response;
    } on TimeoutException {
      attempt++;
      if (attempt >= maxRetries) {
        throw Exception('ConnectionError: timeout - ลองใหม่ $maxRetries ครั้งแล้วไม่สำเร็จ');
      }
      await Future.delayed(Duration(seconds: attempt * 2)); // Exponential backoff
    }
  }
  throw Exception('ConnectionError: timeout');
}

2. 401 Unauthorized - API Key ไม่ถูกต้อง

ปัญหานี้เกิดจาก API key หมดอายุ พิมพ์ผิด หรือยังไม่ได้สมัคร

// ตรวจสอบ API Key ก่อนใช้งาน
Future<bool> validateApiKey(String apiKey) async {
  try {
    final response = await http.get(
      Uri.parse('https://api.holysheep.ai/v1/models'),
      headers: {'Authorization': 'Bearer $apiKey'},
    ).timeout(const Duration(seconds: 10));
    
    if (response.statusCode == 401) {
      print('401 Unauthorized - กรุณาตรวจสอบ API Key ของคุณ');
      print('สมัครได้ที่: https://www.holysheep.ai/register');
      return false;
    }
    return response.statusCode == 200;
  } catch (e) {
    return false;
  }
}

// แก้ไขโดยเก็บ API Key ใน secure storage
import 'package:flutter_secure_storage/flutter_secure_storage.dart';

class SecureConfig {
  static const _storage = FlutterSecureStorage();
  static const _apiKeyKey = 'holysheep_api_key';
  
  static Future<void> saveApiKey(String key) async {
    await _storage.write(key: _apiKeyKey, value: key);
  }
  
  static Future<String?> getApiKey() async {
    return await _storage.read(key: _apiKeyKey);
  }
}

3. UI ไม่อัพเดทระหว่าง Streaming

ปัญหานี้เกิดจากการใช้ setState ผิดวิธีหรือ context ไม่ถูกต้อง

// โค้ดที่ทำให้ UI ไม่อัพเดท
class BadChatProvider extends ChangeNotifier {
  String _text = '';
  String get text => _text;
  
  Stream<String> streamChat(String message) async* {
    await for (final chunk in _streamService.streamChat(message)) {
      _text += chunk; // ไม่ได้เรียก notifyListeners()
      // yield ไปแล้วแต่ UI ไม่รู้ว่าต้อง rebuild
    }
  }
}

// โค้ดแก้ไข - ใช้ isolate สำหรับ heavy computation
class GoodChatProvider extends ChangeNotifier {
  String _streamingText = '';
  bool _isLoading = false;
  
  String get streamingText => _streamingText;
  bool get isLoading => _isLoading;
  
  void setLoading(bool value) {
    _isLoading = value;
    notifyListeners(); // สำคัญมาก!
  }
  
  void updateStreamingText(String chunk) {
    _streamingText += chunk;
    notifyListeners(); // บังคับให้ UI rebuild
  }
  
  void clearStreamingText() {
    _streamingText = '';
    notifyListeners();
  }
}

ราคาและการเปรียบเทียบ

| โมเดล | ราคา/MTok | HolySheep | |-------|----------|-----------| | GPT-4.1 | $8.00 | ✓ รองรับ | | Claude Sonnet 4.5 | $15.00 | ✓ รองรับ | | Gemini 2.5 Flash | $2.50 | ✓ รองรับ | | DeepSeek V3.2 | $0.42 | ✓ รองรับ | HolySheep AI ให้บริการด้วยอัตราแลกเปลี่ยน ¥1=$1 ทำให้ประหยัดได้มากกว่า 85% เมื่อเทียบกับราคามาตรฐาน รองรับการชำระเงินผ่าน WeChat และ Alipay พร้อมความหน่วงต่ำกว่า 50ms ทำให้การสนทนาแบบ streaming ราบรื่นไม่มีสะดุด

สรุป

การทำ streaming chat ใน Flutter ด้วย SSE ต้องระวังเรื่อง timeout handling, error handling และการอัพเดท UI อย่างถูกต้อง การใช้ HolySheep AI ที่รองรับ SSE แบบ native พร้อมความหน่วงต่ำและราคาประหยัด จะช่วยให้แอปของคุณทำงานได้ดีในทุกสถานการณ์ 👉 สมัคร HolySheep AI — รับเครดิตฟรีเมื่อลงทะเบียน