Forem: Benita Clarissa

Implementasi SSE pada Golang (Backend)

Benita Clarissa — Wed, 01 Dec 2021 04:34:20 +0000

Pada kali ini, kita akan menggunakan package go-sse.

Untuk install package tersebut, silakan eksekusi instruksi berikut pada terminal/command prompt.
go get github.com/alexandrevicenzi/go-sse.

Di bawah ini adalah contoh kode program implementasi SSE.

package main

import (
    "encoding/json"
    "net/http"
    "strconv"
    "time"

    "github.com/alexandrevicenzi/go-sse"
)

func main() {
    name := "Latest Event"
    channel := "new-update-channel"

    const jsonData = `
            {
                "stringField": "Value",
                "intField": 123,
                "floatField": 3.14159,
                "booleanField": true
            }
        `

    var sseData map[string]string
    json.Unmarshal([]byte(jsonData), &sseData)

    s := sse.NewServer(nil)
    defer s.Shutdown()

    // Konfigurasi route http
    http.Handle("/", http.FileServer(http.Dir("./static"))) // dummy static html file yang akan menampilkan event source
    http.Handle("/events/", s)

    // Mengirimkan data setiap 3 detik sekali
    go func() {
        for {
            id := strconv.FormatInt(time.Now().UTC().UnixNano(), 10)
            sseData["timestamp"] = time.Now().Format("2006-01-02 15:04:05")

            data, err := json.Marshal(sseData)
            if err == nil {
                s.SendMessage("/events/"+channel, sse.NewMessage(id, string(data), name))
            }
            time.Sleep(3 * time.Second)
        }
    }()

    http.ListenAndServe(":8080", nil)
}

Setelah itu, kita jalankan function Main.

go run main.go

Lalu, amati hasilnya.

C:\Users\benita.clarissa\Documents\go\src\github.com\Bhinneka\coba-coba>go run main.go
go-sse: 2021/11/28 10:52:29 server started.
go-sse: 2021/11/28 10:52:31 channel '/events/new-update-channel' created.
go-sse: 2021/11/28 10:52:31 new client connected to channel '/events/new-update-channel'.
go-sse: 2021/11/28 10:52:32 message sent to channel '/events/new-update-channel'.
go-sse: 2021/11/28 10:52:35 message sent to channel '/events/new-update-channel'.
go-sse: 2021/11/28 10:52:38 message sent to channel '/events/new-update-channel'.

SSE dari sisi backend sudah kita siapkan. Namun, kita perlu melakukan development agar client dapat menerima data yang di-push tersebut. Oleh karena itu, kita perlu menulis script pada sisi frontend yang akan berfungsi sebagai client dari SSE ini. Script pada sisi frontend dapat menggunakan bahasa pemrograman dan framework yang dapat mengakses HTML Server-Sent Events API. Salah satu contohnya adalah React JS.

Referensi

Cook, D. (2014). Data Push Apps with HTML5 SSE: Pragmatic Solutions for Real-World Clients (1st ed.) [E-book]. O’Reilly Media.

Perbedaan SSE dan WebSockets

Benita Clarissa — Thu, 04 Nov 2021 04:50:06 +0000

SSE dan WebSockets termasuk ke dalam teknologi data push. Lantas, apa yang membedakan keduanya? dan teknologi mana yang lebih baik untuk digunakan?

Perbedaan SSE dan WebSockets

Server-Sent Events (SSE) adalah teknologi HTML5 yang akan membuat server melakukan push data ke client secara satu arah (one-way messaging).
WebSockets adalah teknologi HTML5 yang akan membuat server melakukan push data dua arah antara client dan server (two-way communication).

Kapan perlu menggunakan data push? WebSockets atau SSE?

Berikut pertimbangan saat memilih teknologi data push yang akan diimplementasikan dalam aplikasi.

Seberapa sering server mengirimkan event (data) ke client?
- Jika server sering mengirimkan data ke client, aplikasi tersebut cocok menggunakan teknologi data push dibandingkan data pull.
Apakah latency dan baterai menjadi pertimbangan utama bagi user?
- Latency dan baterai dapat menjadi pertimbangan utama bagi mobile user. Konektivitas jaringan sangat penting bagi tipe user ini. Oleh karena itu, data push lebih baik dibandingkan data pull.
Seberapa sering client mengiriman event (data) ke server?
- Jika event terjadi dalam frekuensi rapat (di bawah 5 detik, atau bahkan 1 detik sekali), aplikasi tersebut lebih baik menggunakan WebSockets dibandingkan SSE.
- Jika event terjadi dalam frekuensi lebih jarang (5-10 detik sekali), Anda dapat menggunakan SSE dan bahkan data push technology tidak perlu terlalu diprioritaskan.
Apakah waktu pengiriman event dari server bisa diprediksi?
- Ketika event dikirim lebih dari 1 menit sekali, data pull lebih baik karena tidak perlu membuka socket untuk SSE/WebSockets.
Apakah server mengirimkan (push) binary data ke client?
- Jika ada banyak binary data yang dikirimkan server, sebaiknya menggunakan WebSockets dibandingkan SSE (bahkan lebih baik menggunakan XHR polling dibandingkan SSE).
- Jika data binary hanya sedikit, lakukan encoding pada SSE untuk mengurangi jumlah byte yang dikirimkan
Apakah client mengirimkan (push) binary data ke server?
- XMLHttpRequest (seperti: Ajax dan SSE) dan WebSockets bisa digunakan untuk mengirimkan binary data.

Jadi, teknologi mana yang lebih baik?

Masing-masing teknologi memiliki keunggulan yang berbeda, tergantung dari kebutuhan aplikasi yang dikembangkan.

Aplikasi yang membutuhkan komunikasi 2 arah antara client dan server
- harus menggunakan WebSockets
- tidak cocok menggunaakn SSE
- Contoh: chat platform
Aplikasi yang hanya mengirimkan data 1 arah ke client
- sangat cocok menggunakan SSE
- tidak cocok menggunakan WebSockets
- Contoh: FX trading

Selanjutnya

Post selanjutnya akan membahas cara implementasi SSE. Implementasi backend akan menggunakan bahasa pemrograman Golang. Implementasi dari sisi frontend akan menggunakan teknologi ReactJS.

Referensi

Cook, D. (2014). Data Push Apps with HTML5 SSE: Pragmatic Solutions for Real-World Clients (1st ed.) [E-book]. O’Reilly Media.

Mengenal Server-Sent Events (SSE)

Benita Clarissa — Tue, 05 Oct 2021 03:31:02 +0000

Apa itu SSE?

Server-Sent Events (SSE) adalah teknologi HTML5 yang akan membuat server melakukan push data ke client secara satu arah (one-way messaging). Hal ini akan menjadikan aplikasi akan selalu mendapatkan update terbaru secara otomatis. User tidak perlu melakukan interaksi apa pun seperti refresh page, click button, atau sejenisnya.

Data Push vs Data Pull

Secara garis besar, komunikasi data antara server dan client dapat terbagi 3 macam, yaitu: no-updates, data pull, dan data push.

No updates

Ini adalah komunikasi data paling sederhana antara client dan server. Tidak ada update data secara otomatis dari server. User harus refresh / reload page untuk mendapatkan data terbaru.

Data Pull

Data pull menggunakan teknik ajax untuk mendapatkan data terbaru dalam periode tertentu (contoh: 5 menit sekali). Client (browser) tetap harus melakukan request ke server secara otomatis untuk mendapatkan data terbaru. User tidak perlu refresh / reload halaman untuk mendapatkan data terbaru.

Data Push

Pada data push, server yang akan mengirimkan data terbaru ke client. Hal ini membuat client (browser) tidak perlu melakukan request ke server. User juga tidak perlu melakukan refresh / reload halaman untuk mendapatkan data terbaru. SSE termasuk ke dalam kategori data push.

Data push memiliki beberapa keunggulan dibandingkan data pull:

Latency yang lebih rendah
Saat tidak ada update, client tidak perlu melakukan request ke server secara otomatis sehingga meminimalkan resource/request yang terbuang.
Lebih hemat bandwidth dan connection

Aplikasi yang menggunakan SSE

SSE sangat berguna untuk aplikasi web yang membutuhkan fresh data dalam kurun waktu singkat. Contohnya: kurs valuta asing, pergerakan harga saham, dan aplikasi lainnya yang membutuhkan realtime data updates.

Selanjutnya

Teknologi yang termasuk ke dalam data push adalah SSE dan WebSocket. Pada post selanjutnya, kita akan membahas mengenai perbedaan SSE dan WebSocket.

Referensi

Cook, D. (2014). Data Push Apps with HTML5 SSE: Pragmatic Solutions for Real-World Clients (1st ed.) [E-book]. O’Reilly Media.

Membuat Penjadwalan Otomatis (Cron Job Scheduler) menggunakan Golang

Benita Clarissa — Thu, 16 Sep 2021 06:02:06 +0000

Terkadang dalam sebuah aplikasi, ada tugas-tugas yang perlu dijalankan otomatis sesuai jadwal yang telah ditentukan. Contohnya, ketika kita menerima email otomatis yang berisi ucapan tahun baru, notifikasi agenda setiap hari kerja jam 8 pagi, tagihan setiap bulan tanggal 10 jam 9 pagi, cek pesanan baru setiap 10 menit, dan lainnya. Artikel ini akan membahas bagaimana cara membuat penjadwalan otomatis menggunakan golang.

Bagaimana penjadwalan otomatis dilakukan pada server?

Pada artikel ini, penjadwalan otomatis akan dilakukan pada server berbasis Linux dengan menggunakan cron. Cron adalah sebuah command Linux untuk menjalankan script secara terjadwal.

Di bawah ini adalah cara mengatur penjadwalan pada crontab.

* * * * * perintah yang akan dieksekusi
– – – – –
| | | | |
| | | | +—– day of week (0 – 7) (Sunday=0)
| | | +——- month (1 – 12)
| | +——— day of month (1 – 31)
| +———– hour (0 – 23)
+————- min (0 – 59)

Contoh:

Email otomatis untuk ucapan tahun baru jam 12 malam
0 0 1 1 * /home/user/automail-new-year.sh
Email otomatis tagihan setiap bulan tanggal 10 jam 7 pagi
0 07 10 * * /home/user/automail-billing.sh
Notifikasi agenda setiap hari kerja (Senin-Jumat) jam 9 pagi
0 09 * * 1-5 /home/user/notification-daily-agenda.sh
Notifikasi pesanan baru setiap 10 menit sekali
*/10 * * * * /home/user/notification-new-order.sh

Ya, saya sudah memahami cron. Bagaimana cara implementasi pada Go?

Setelah melakukan pencarian terhadap beberapa package go terkait scheduler, saya memilih package robfig/cron v3. Cara implementasinya cukup sederhana. Mari kita lihat bersama.

package main

import (
   "fmt"
   "os"
   "os/signal"
   "syscall"
   "time"

   cron "github.com/robfig/cron/v3"
)

func main() {
   // set scheduler berdasarkan zona waktu sesuai kebutuhan
   jakartaTime, _ := time.LoadLocation("Asia/Jakarta") 
   scheduler := cron.New(cron.WithLocation(jakartaTime))

   // stop scheduler tepat sebelum fungsi berakhir
   defer scheduler.Stop()

   // set task yang akan dijalankan scheduler
   // gunakan crontab string untuk mengatur jadwal
   scheduler.AddFunc("0 0 1 1 *", func() { SendAutomail("New Year") })
   scheduler.AddFunc("0 07 10 * *", SendMonthlyBillingAutomail)
   scheduler.AddFunc("0 09 * * 1-5", NotifyDailyAgenda)
   scheduler.AddFunc("*/10 * * * *", NotifyNewOrder)

   // start scheduler
   go scheduler.Start()

   // trap SIGINT untuk trigger shutdown.
   sig := make(chan os.Signal, 1)
   signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
   <-sig
}

func SendAutomail(automailType string) {
    // ... instruksi untuk mengirim automail berdasarkan automailType
    fmt.Printf(time.Now().Format("2006-01-02 15:04:05") + " SendAutomail " + automailType + " telah dijalankan.\n")
}

func SendMonthlyBillingAutomail(){
    // ... instruksi untuk mengirim automail berisi tagihan
    fmt.Printf(time.Now().Format("2006-01-02 15:04:05") + " SendMonthlyBillingAutomail telah dijalankan.\n")
}

func NotifyDailyAgenda(){
    // ... instruksi untuk mengirim notifikasi agenda harian
    fmt.Printf(time.Now().Format("2006-01-02 15:04:05") + " NotifyDailyAgenda telah dijalankan.\n")
}

func NotifyNewOrder(){
    // ... instruksi untuk mengecek pesanan baru, lalu mengirimkan notifikasi
    fmt.Printf(time.Now().Format("2006-01-02 15:04:05") + " NotifyNewOrder telah dijalankan.\n")
}

Setelah itu, kita jalankan function Main.

go run main.go

Lalu, amati hasilnya.

2021-09-16 09:00:00 NotifyDailyAgenda telah dijalankan.
2021-09-16 12:30:00 NotifyNewOrder telah dijalankan.
2021-09-16 12:40:00 NotifyNewOrder telah dijalankan.

Penjadwalan otomatis dengan golang sudah berhasil dibuat.

Selanjutnya

Berikut beberapa link yang dapat dijadikan referensi.

Dokumentasi lengkap package robfig/cron dapat dilihat dari link tersebut.
Gunakan crontab.guru untuk mengatur crontab dan memastikan waktu penjadwalan sudah sesuai dengan kebutuhan.