LISTEN ir NOTIFY PostgreSQL teikia įtaisytą publish/subscribe (publikavimo/prenumeratos) pranešimų sistemą — vienas seansas gali siųsti pranešimą kanale, ir kiti seansai, klausantys to kanalo, jį gauna iš karto. Tai lengva priemonė aplankam realaus laiko įvykiams iš duomenų bazės siųsti be apklausų.
LISTEN order_created;
NOTIFY order_created, ;
LISTEN užsisako kanalą; NOTIFY jį publikuoja (su neprivaloma teksto apkrova). Klausytojai gauna pranešimus asinchroniškai — apklausos nereikalingos.
-- 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
Sujungus NOTIFY su триggеriu, duomenų bazė gali automatiškai siųsti įvykius, kai duomenys keičiasi (naujas užsakymas, būsenos atnaujinimas) — programų serveriai, klausantys kanalo, reaguoja iš karto.
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 yra naudinga, gana mažiau žinoma PostgreSQL savybė, teikianti įtaisytą pub/sub pranešimų sistemą, vertinga realaus laiko reaktyvumui pridėti be apklausų.
Pagrindinė vertė yra tai, kad duomenų bazė gali siųsti įvykius klausantiems programų seansams iš karto, kai nutinka kažkas (naujas užsakymas, būsenos pokytis) — paprastai sujungtą su trigeriais, kad duomenų pakeitimai automatiškai praneštu klausytojams, kuriems programų serveriai reaguoja (išsiunčia į websocket, panaikina talpyklas, paleidžia foninio darbo).
Tai vertinga, nes suteikia realaus laiko įvykiais paremtą elgesį be apklausų neefektyvumo — pakartotinai apklausiamos duomenų bazės norėdamos sužinoti apie pokyčius (dažnas, švaistantis modelis, kurį LISTEN/NOTIFY elegantiškai pakeičia).
Supratimas mechanizmo (LISTEN užsisakymui, NOTIFY publikavimui, su trigeriais automatiniam pranešimui apie duomenų pokyčius) ir kaip programos jį naudoja (klausymas įvykių, norėdami varoma realaus laiko reakcijas) yra naudinga kurti atsakioms, įvykiais paremtoms programoms naudojant tik PostgreSQL.
Lygiai taip pat svarbu žinoti apribojimus: pranešimai nėra išlaikomi (prarandami, jei niekas neklausosi — nėra ilgalaikiškumo garantijų), jie turi mažus apkrovas, ir juos paleista tik po patvirtinimo — todėl ji tinka lengviems realaus laiko signalams, ne atkaklios pranešimų brokerio (RabbitMQ, Kafka) pakeitimui, kai reikalingas patikimumas ir išlieka.
Besaikalis realaus laiko reaktyvumas yra dažna poreikis ir LISTEN/NOTIFY siūlo įtaisytą, be apklausų būdą jį pasiekti šviesiems atvejams, suprasti — pub/sub mehanizmą, trigger modelį, ir kritiškai jo apribojimus (kai jo užtenka ir kai tikras broker yra reikalingas) — yra vertinga, praktiškai aktuali PostgreSQL žinios kurti įvykiais paremtas programas, naudinga įtaisyta savybė, kuri dažnai nepastebima.