Server Sent Events (SSE)
SSE, Server Sent Events digunakan untuk mengimplementasikan komunikasi real-time, dimana server mengirimkan data ke klien. Untuk menerima data dari server ke klien biasanya kami membuat koneksi HTTP. Dalam kasus update berkala, kami dalam beberapa kasus sebelumnya menggunakan Polling atau Long Polling melalui HTTP request.
Untuk kasus koneksi yang persisten kita akan menggunakan WebSockets sehingga kita bisa mengirim/menerima data secara terus menerus tanpa membuat koneksi baru. Meskipun WebSockets adalah cara terbaik untuk berkomunikasi dengan server ketika kita perlu mengirim dan menerima data ke dan dari server. Tetapi dalam banyak kasus, kita perlu menerima data dari server menggunakan koneksi persisten, tetapi tidak perlu mengirim data ke server. Seperti, live dashboard, atau live analytics board. Dalam kasus ini, WebSockets menjadi beban tambahan yang tidak diperlukan. Untuk mengatasi masalah ini, kita menggunakan cara Server-Sent Events (SSE). Untuk detailnya bisa membaca di Server-sent events
Kelebihan
SSE memiliki beberapa kelebihan berikut:
- Koneksi persisten, di mana klien terhubung ke server, dan server menjaga koneksi tetap hidup (sampai ada masalah).
- Menggunakan koneksi HTTP biasa.
- Koneksi satu arah dari server ke klien. Jadi klien hanya dapat menerima data dari server, dan klien tidak dapat mengirim data apa pun setelah koneksi dibuat.
- Hanya dapat menerima teks UTF-8.
- Menggunakan sumber daya yang lebih sedikit dibandingkan WebSockets (karena koneksi ke soket TCP/IP tidak diperlukan dalam kasus ini).
- Sambungan ulang/percobaan ulang otomatis dilakukan dari sisi klien, jika ada masalah di server (seperti restart server).
- Tersedia di Web Workers.
- Proses implementasinya yang sangat sederhana.
Keterbatasan
SSE memiliki beberapa keterbatas berikut:
- Terbatas dalam menghubungkan dari satu browser dalam satu waktu:
- HTTP/1.1: Maksimum 6-8 koneksi sekaligus.
- HTTP/2: Maksimum 100 koneksi secara default (dapat diubah dari konfigurasi server).
- Hanya dapat mengirim teks UTF-8. Jadi Anda hanya dapat mengirim data teks yang terdiri dari karakter UTF-8, karena content-type nya adalah text/event-stream.
- Tidak mendukung pengiriman data secara client-to-server. Setelah koneksi dibuat, klien tidak dapat mengirim data setelah itu, menggunakan koneksi yang sama.
Manfaat SSE:
- Real-time: Data dikirimkan ke klien secara real-time tanpa perlu klien melakukan polling.
- Efisien: SSE hanya menggunakan satu koneksi HTTP, sehingga lebih efisien daripada polling.
- Skalabilitas: SSE dapat digunakan untuk aplikasi dengan banyak klien.
Contoh Source Code SSE dengan PHP
<?php
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
$eventData = [
'message' => 'Hello from PHP!',
'time' => time()
];
echo "data: " . json_encode($eventData) . "\n\n";
ob_flush();
flush();
sleep(5); // Simulasi penundaan 5 detik
$eventData = [
'message' => 'Another message from PHP!',
'time' => time()
];
echo "data: " . json_encode($eventData) . "\n\n";
ob_flush();
flush();
Contoh Source Code SSE dengan Golang
package main
import (
"encoding/json"
"fmt"
"net/http"
"time"
)
func main() {
http.HandleFunc("/sse", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "text/event-stream")
w.Header().Set("Cache-Control", "no-cache")
flusher := w.(http.Flusher)
eventData := map[string]interface{}{
"message": "Hello from Golang!",
"time": time.Now().Unix(),
}
json.NewEncoder(w).Encode(eventData)
flusher.Flush()
time.Sleep(5 * time.Second) // Simulasi penundaan 5 detik
eventData = map[string]interface{}{
"message": "Another message from Golang!",
"time": time.Now().Unix(),
}
json.NewEncoder(w).Encode(eventData)
flusher.Flush()
})
fmt.Println("Starting server on port 8080")
http.ListenAndServe(":8080", nil)
}
Catatan:
- Pastikan untuk menggunakan header HTTP yang benar saat mengirimkan SSE stream.
- Gunakan format JSON atau XML untuk event data.
- Flush event data ke klien secara berkala.
- Gunakan teknik caching untuk meningkatkan performa.