Observer Pattern
Mari kita bahas Observer Pattern, salah satu pola desain perilaku (behavioral pattern) yang sangat populer selain Strategy Pattern.
Observer Pattern adalah pola desain di mana sebuah objek, yang disebut subject, mengelola daftar objek lain yang bergantung padanya, yang disebut observers. Subject secara otomatis akan memberi tahu semua observers-nya setiap kali ada perubahan keadaan (state change).
Analogi Sederhana: 📢
Bayangkan Anda berlangganan (subscribe) sebuah kanal YouTube.
Kanal YouTube adalah Subject.
Anda (dan subscriber lainnya) adalah Observers.
Ketika kanal YouTube mengunggah video baru (ini adalah "perubahan keadaan"), YouTube secara otomatis mengirimkan notifikasi kepada Anda dan semua subscriber lainnya. Kanal tidak perlu tahu siapa saja Anda secara spesifik, ia hanya tahu memiliki daftar subscriber yang harus diberi tahu. Anda pun tidak perlu terus-menerus memeriksa kanal tersebut; Anda akan diberi tahu secara otomatis.
Inilah inti dari Observer Pattern: menciptakan hubungan satu-ke-banyak (one-to-many) antara objek, sehingga jika satu objek berubah, semua yang bergantung padanya akan diperbarui secara otomatis.
## Implementasi di Go
Dalam Go, kita akan menggunakan interface untuk mendefinisikan peran Subject dan Observer.
Skenario: Sebuah toko online (Store) sebagai Subject. Pelanggan (Customer) sebagai Observers yang tertarik pada produk baru. Ketika produk baru tiba di toko, semua pelanggan yang terdaftar akan mendapatkan notifikasi.
1. Definisikan Interface
package main
// Observer Interface
type Observer interface {
Update(productName string)
GetID() string
}
// Subject Interface
type Subject interface {
Register(observer Observer)
Deregister(observer Observer)
NotifyAll()
}2. Buat Concrete Subject dan Concrete Observer
Store adalah Concrete Subject dan Customer adalah Concrete Observer.
package main
import "fmt"
// --- Concrete Subject ---
type Store struct {
observers []Observer
productName string
}
func NewStore() *Store {
return &Store{
observers: make([]Observer, 0),
}
}
func (s *Store) Register(observer Observer) {
fmt.Printf("Menambahkan pelanggan %s ke daftar notifikasi\n", observer.GetID())
s.observers = append(s.observers, observer)
}
func (s *Store) Deregister(observer Observer) {
s.observers = removeFromSlice(s.observers, observer)
}
func (s *Store) NotifyAll() {
fmt.Println("\n--- Mengirim notifikasi ke semua pelanggan ---")
for _, observer := range s.observers {
observer.Update(s.productName)
}
}
// Method untuk memicu notifikasi
func (s *Store) NewProductArrived(productName string) {
fmt.Printf("\nProduk baru telah tiba: %s!\n", productName)
s.productName = productName
s.NotifyAll()
}
// Helper function untuk menghapus observer
func removeFromSlice(observers []Observer, observerToRemove Observer) []Observer {
for i, observer := range observers {
if observer.GetID() == observerToRemove.GetID() {
return append(observers[:i], observers[i+1:]...)
}
}
return observers
}
// --- Concrete Observer ---
type Customer struct {
name string
}
func (c *Customer) Update(productName string) {
fmt.Printf("Hai %s, produk '%s' sekarang tersedia di toko!\n", c.name, productName)
}
func (c *Customer) GetID() string {
return c.name
}3. Penggunaan di Client (main.go)
package main
func main() {
// Subject
appleStore := NewStore()
// Observers
customerA := &Customer{name: "Andi"}
customerB := &Customer{name: "Budi"}
customerC := &Customer{name: "Citra"}
// Pelanggan mendaftar untuk notifikasi
appleStore.Register(customerA)
appleStore.Register(customerB)
appleStore.Register(customerC)
// Toko merilis produk baru, notifikasi terkirim otomatis
appleStore.NewProductArrived("iPhone 17")
// Budi berhenti berlangganan
appleStore.Deregister(customerB)
// Toko merilis produk baru lagi
appleStore.NewProductArrived("MacBook Pro M5")
}Output Go:
Menambahkan pelanggan Andi ke daftar notifikasi
Menambahkan pelanggan Budi ke daftar notifikasi
Menambahkan pelanggan Citra ke daftar notifikasi
Produk baru telah tiba: iPhone 17!
--- Mengirim notifikasi ke semua pelanggan ---
Hai Andi, produk 'iPhone 17' sekarang tersedia di toko!
Hai Budi, produk 'iPhone 17' sekarang tersedia di toko!
Hai Citra, produk 'iPhone 17' sekarang tersedia di toko!
Produk baru telah tiba: MacBook Pro M5!
--- Mengirim notifikasi ke semua pelanggan ---
Hai Andi, produk 'MacBook Pro M5' sekarang tersedia di toko!
Hai Citra, produk 'MacBook Pro M5' sekarang tersedia di toko!## Implementasi di Java
Implementasi di Java sangat mirip secara konsep, menggunakan interface dan kelas.
1. Definisikan Interface
Observer.java
public interface Observer {
void update(String productName);
}Subject.java
public interface Subject {
void register(Observer observer);
void deregister(Observer observer);
void notifyObservers();
}2. Buat Concrete Subject dan Concrete Observer
Store.java (Concrete Subject)
import java.util.ArrayList;
import java.util.List;
public class Store implements Subject {
private String productName;
private List<Observer> observers = new ArrayList<>();
@Override
public void register(Observer observer) {
System.out.println("Menambahkan observer ke daftar notifikasi.");
observers.add(observer);
}
@Override
public void deregister(Observer observer) {
System.out.println("Menghapus observer dari daftar notifikasi.");
observers.remove(observer);
}
@Override
public void notifyObservers() {
System.out.println("\n--- Mengirim notifikasi ke semua observer ---");
for (Observer observer : observers) {
observer.update(productName);
}
}
// Method untuk memicu notifikasi
public void newProductArrived(String productName) {
this.productName = productName;
System.out.printf("\nProduk baru (%s) telah tiba!\n", productName);
notifyObservers();
}
}Customer.java (Concrete Observer)
public class Customer implements Observer {
private String name;
public Customer(String name) {
this.name = name;
}
@Override
public void update(String productName) {
System.out.printf("Hai %s, produk '%s' sekarang tersedia!\n", this.name, productName);
}
}3. Penggunaan di Client (Main.java)
public class Main {
public static void main(String[] args) {
// Subject
Store appleStore = new Store();
// Observers
Observer customerA = new Customer("Andi");
Observer customerB = new Customer("Budi");
Observer customerC = new Customer("Citra");
// Pelanggan mendaftar
appleStore.register(customerA);
appleStore.register(customerB);
appleStore.register(customerC);
// Produk baru datang
appleStore.newProductArrived("iPhone 17");
// Budi berhenti berlangganan
appleStore.deregister(customerB);
// Produk baru lainnya datang
appleStore.newProductArrived("MacBook Pro M5");
}
}Output Java:
Menambahkan observer ke daftar notifikasi.
Menambahkan observer ke daftar notifikasi.
Menambahkan observer ke daftar notifikasi.
Produk baru (iPhone 17) telah tiba!
--- Mengirim notifikasi ke semua observer ---
Hai Andi, produk 'iPhone 17' sekarang tersedia!
Hai Budi, produk 'iPhone 17' sekarang tersedia!
Hai Citra, produk 'iPhone 17' sekarang tersedia!
Menghapus observer dari daftar notifikasi.
Produk baru (MacBook Pro M5) telah tiba!
--- Mengirim notifikasi ke semua observer ---
Hai Andi, produk 'MacBook Pro M5' sekarang tersedia!
Hai Citra, produk 'MacBook Pro M5' sekarang tersedia!Last updated