LISTEN i NOTIFY pružaju ugrađeni publish/subscribe sustav razmjene poruka u PostgreSQL-u — jedna sesija može poslati obavijest na kanalu, a druge sesije koje slušaju taj kanal je primaju trenutno. To je lagan način za slanje događaja u realnom vremenu iz baze podataka bez kontinuiranog provjere stanja.
LISTEN order_created;
NOTIFY order_created, ;
LISTEN se pretplaćuje na kanal; NOTIFY objavljuje na njega (s opcionalne tekstualne korisnosti). Slušači se asinkrono obavještavaju — nije potrebna kontinuirana provjera stanja.
-- a trigger that notifies whenever a row is inserted
CREATE FUNCTION notify_new_order() RETURNS trigger AS $$
BEGIN
PERFORM pg_notify('order_created', NEW.id::text); -- notify with the new id
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER order_notify AFTER INSERT ON orders
FOR EACH ROW EXECUTE FUNCTION notify_new_order();
-- now inserting an order automatically pushes a notification to listeners
Kombiniranje NOTIFY-ja s okidačem omogućuje bazi podataka da automatski proslijedi događaje kada se podaci promijene (nova narudžba, ažuriranje statusa) — poslužitelji aplikacija koji slušaju kanal reagiraju u realnom vremenu.
Application code (Node, Python, etc.) opens a connection and LISTENs on a channel.
When a NOTIFY fires (e.g. from a trigger on data change), the app receives the event
and reacts — pushing to websockets, invalidating a cache, triggering a job, etc.
→ Real-time reactions to database changes WITHOUT polling the database.
✗ Notifications are NOT persisted — if no one is listening, the message is LOST
(no durability/queue guarantees like a real message broker)
✗ Payload is small (limited size); delivered only after the transaction COMMITS
→ Good for lightweight real-time signaling; for durable/reliable messaging use a
proper broker (RabbitMQ, Kafka) or a queue table.
LISTEN/NOTIFY je korisna, relativno nepoznata značajka PostgreSQL-a koja pruža ugrađenu pub/sub razmjenu poruka, vrijedna za dodavanje reaktivnosti u realnom vremenu aplikacijama bez kontinuirane provjere stanja.
Osnovnu vrijednost predstavlja omogućavanje bazi podataka da proslijedi događaje sesijama slušajućih aplikacija trenutno kada se nešto dogodi (nova narudžba, promjena statusa) — obično u kombinaciji s okidačima tako da promjene podataka automatski obavijeste slušače, na koje poslužitelji aplikacija reagiraju (slanje kroz websockete, poništavanje priručne memorije, pokretanje pozadiske obrade).
Ovo je vrijedno jer omogućava ponašanje vođeno događajima u realnom vremenu bez neučinkovitosti kontinuirane provjere stanja baze podataka kako bi se provjerile promjene (čest, rasipan obrazac koji LISTEN/NOTIFY elegantno zamjenjuje).
Razumijevanje mehanizma (LISTEN za pretplatu, NOTIFY za objavljivanje, s okidačima za automatsku obavijest pri promjeni podataka) i kako ga aplikacije koriste (slušanje događaja kako bi pokrenule reaktivne akcije u realnom vremenu) korisno je za gradnju odzivnih, aplikacija vođenih događajima koristeći samo PostgreSQL.
Jednako važno je znati ograničenja: obavijesti nisu trajne (izgubljene ako nitko ne sluša — bez garancija trajnosti), imaju male korisnosti i aktiviraju se samo nakon potvrde — pa je prikladna za laganu signalizaciju u realnom vremenu, ne zamjenu za izdržljiv posrednik poruka (RabbitMQ, Kafka) kada su pouzdanost i trajnost važne.
Budući da je reaktivnost u realnom vremenu česta potreba a LISTEN/NOTIFY nudi ugrađeni, bez kontinuirane provjere način da se to postigne za lake slučajeve, razumijevanje tog — pub/sub mehanizma, obrasca s okidačima, i kritično njena ograničenja (kada je dovoljna u odnosu na kada je potreban pravi posrednik) — je vrijedna, praktično relevantna PostgreSQL znanja za gradnju aplikacija vođenih događajima, korisna ugrađena značajka koja se često zanemaruje.