LISTEN மற்றும் NOTIFY என்றால் என்ன?

Question

Accepted Answer

**`LISTEN`** மற்றும் **`NOTIFY`** PostgreSQL-இல் உள்ளமைக்கப்பட்ட **publish/subscribe** மெசேஜிங் சிஸ்டம் வழங்குகின்றன — ஒரு session ஒரு channel-இல் notification அனுப்பலாம், மற்றும் அந்த channel-ஐ கேட்கும் பிற sessions உடனடியாக அதைப் பெறுகின்றன. இது polling இல்லாமல் database-இலிருந்து real-time events தள்ள ஒரு இலகு முறை.

## அடிப்படை பொறிமுறை

```sql
-- a session SUBSCRIBES to a channel
LISTEN order_created;

-- another session/transaction PUBLISHES a notification (with an optional payload)
NOTIFY order_created, 'order id 123';
-- → all sessions listening on 'order_created' receive the message immediately
```

LISTEN ஒரு channel-க்கு உறுப்பினரை சேர்க்கிறது; NOTIFY அதற்கு வெளியிடுகிறது (விருப்ப உரை payload-உடன்). Listeners ஒத்திசைவற்றவாறு (asynchronously) அறிவிக்கப்படுகிறார்கள் — polling தேவையில்லை.

## தானாக NOTIFY ட்ரிகர் செய்தல் (ஒரு பொதுவான முறை)

```sql
-- 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
```

NOTIFY-ஐ **trigger**-உடன் இணைப்பது database-ஐ தரவு மாறும்போது (புதிய order, status update) தானாகவே events தள்ள அனுமதிக்கிறது — channel-ஐ கேட்கும் application servers real time-இல் பதிலளிக்கிறது.

## applications இது எப்படி பயன்படுத்துகிறது

```text
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.
```

## அறிந்து கொள்ள வேண்டிய வரம்புகள்

```text
✗ 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` என்பது PostgreSQL-இன் ஒரு பயனுள்ள, சற்று குறைவாக அறியப்பட்ட feature ஆகும், இது **உள்ளமைக்கப்பட்ட pub/sub மெசேஜிங்** வழங்குகிறது, polling இல்லாமல் applications-க்கு **real-time reactivity** சேர்ப்பதற்கு மূல்யமானது.

அடிப்படை மதிப்பு database-ஐ listening application sessions-க்கு **events தள்ள** உடனடியாக ஏதோ நடக்கும்போது (ஒரு புதிய order, ஒரு status change) — பொதுவாக **triggers**-உடன் இணைக்கப்பட்டு தரவு மாற்றங்கள் தானாகவே listeners-ஐ அறிவிக்கும், application servers அவற்றுக்கு பதிலளிக்கிறது (websockets-க்கு தள்ளுதல், caches-ஐ invalidate செய்தல், background work ট்ரிகர் செய்தல்).

இது மதிப்புள்ளது என்பதால் பொறிமுறை (subscribe செய்ய LISTEN, publish செய்ய NOTIFY, தரவு மாற்றங்களில் தானாக notification-க்கு triggers) மற்றும் applications இது எப்படி பயன்படுத்துகிறது (real-time reactions-ஐ চালிக்க events-க்கு கேட்டுக்கொள்ளுதல்) பயனுள்ள knowledge ஆகும், responsive, event-driven applications உருவாக்க PostgreSQL-ஐ பயன்படுத்தி.

சமவாறு முக்கியமான **வரம்புகள**-ஐ அறிந்து கொள்ளுதல்: notifications **persisted இல்லை** (யாரும் கேட்கவில்லை என்றால் হারிந்துவிடும் — durability guarantees இல்லை), சிறிய payloads உண்டு, மற்றும் commit-க்குப் பின்னரே fire ஆகிறது — எனவே இது lightweight real-time signaling-க்கு பொருத்தமானது, *not* ஒரு durable message broker (RabbitMQ, Kafka)-க்குப் பதிலாக reliability மற்றும் persistence முக்கியம் என்றால்.

Real-time reactivity ஒரு பொதுவான தேவை மற்றும் LISTEN/NOTIFY lightweight cases-க்கு உள்ளமைக்கப்பட்ட, polling-free வழி வழங்குகிறது என்பதால், pub/sub mechanism, trigger pattern, மற்றும் முக்கியமாக அதன் வரம்புகள் (அது எப்போது போதுமானது vs எப்போது ஒரு real broker தேவை) — event-driven applications உருவாக்க மதிப்புள்ள, practically-relevant PostgreSQL knowledge ஆகும், பொதுவாக தவறிவிடப்படும் ஒரு பயனுள்ள உள்ளமைக்கப்பட்ட feature.