Что такое Notify в PostgreSQL?

Что такое NOTIFY в PostgreSQL?

Notify в PostgreSQL — это механизм асинхронного уведомления, позволяющий процессам в рамках одного экземпляра базы данных обмениваться простыми сигналами (событиями). Это реализация модели «издатель-подписчик» (publish-subscribe), встроенная непосредственно в СУБД. Команда NOTIFY используется для отправки уведомления, а команда LISTEN — для подписки на канал и получения этих уведомлений.

Ключевые характеристики и принцип работы

Notify работает через именованные каналы (channels), которые являются строками (обычно в нижнем регистре). Процесс (клиентское приложение, сессия) может:

1. Подписаться на канал с помощью LISTEN channel_name;.
2. Отправить уведомление в канал с помощью NOTIFY channel_name, 'payload';, где payload — необязательная текстовая строка (до 8000 байт).
3. Получить уведомление асинхронно, когда оно приходит.

Уведомления доставляются только активным сессиям, которые в момент отправки NOTIFY были подписаны на данный канал. Доставка происходит при завершении транзакции, в которой был выполнен NOTIFY. Это ключевая особенность: уведомление отправляется в базу данных, но фактическая рассылка происходит после COMMIT. Если транзакция откатывается (ROLLBACK), уведомление не отправляется.

Пример базового использования:

-- Сессия 1: Подписывается на канал 'orders'
LISTEN orders;

-- Сессия 2: Отправляет уведомление в канал 'orders' с полезной нагрузкой 'new_order_123'
BEGIN;
NOTIFY orders, 'new_order_123';
COMMIT;

-- Сессия 1: Получает уведомление асинхронно
-- (В приложении это обрабатывается через API клиентской библиотеки, например, pq для Go)

Как работает на уровне приложения (например, на Go)

В приложении на Go, использующем драйвер pq (или pgx), механизм Notify используется через постоянное соединение с базой данных, которое слушает каналы. При получении уведомления драйвер вызывает callback-функцию. Пример с использованием database/sql и pq:

package main

import (
    "database/sql"
    "fmt"
    "log"
    _ "github.com/lib/pq"
)

func main() {
    connStr := "user=postgres dbname=test sslmode=disable"
    db, err := sql.Open("postgres", connStr)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    // Выполняем LISTEN в отдельном соединении, так как стандартный sql.DB не поддерживает уведомления напрямую
    listener := pq.NewListener(connStr, 10*time.Second, time.Minute, nil)
    err = listener.Listen("orders")
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("Слушаем канал 'orders'...")
    for {
        select {
        case notify := <-listener.Notify:
            fmt.Printf("Получено уведомление: канал=%s, payload=%s, PID=%d\n", 
                notify.Channel, notify.Extra, notify.BePid)
        case <-time.After(90 * time.Second):
            fmt.Println("Таймаут, проверяем соединение...")
            err := listener.Ping()
            if err != nil {
                log.Fatal(err)
            }
        }
    }
}

Преимущества и ограничения NOTIFY

Преимущества:

• Встроен в PostgreSQL: Не требует внешних систем (как RabbitMQ или Redis) для простых сценариев.
• Транзакционная безопасность: Уведомления отправляются только после коммита, что гарантирует согласованность.
• Низкие накладные расходы: Легковесный механизм, эффективный для событий высокой частоты.
• Поддержка полезной нагрузки (payload): Можно передавать небольшие данные (например, ID записи).

Ограничения:

• Нет гарантии доставки: Уведомления теряются, если сессия-подписчик отключена в момент отправки.
• Нет персистентности: Уведомления не сохраняются после отправки и не пересылаются повторно.
• Ограничение по размеру payload: Максимум 8000 байт, что недостаточно для больших данных.
• Только в рамках одного экземпляра PostgreSQL: Не работает в распределённых кластерах (например, между разными серверами).

Практические сценарии использования

1. Реакция на изменения данных: Например, при вставке новой записи в таблицу orders отправить NOTIFY, чтобы обновить кэш в приложении.
2. Очереди задач: Простые фоновые задачи, где payload содержит параметры задачи (например, NOTIFY tasks, '{"type": "email", "id": 123}').
3. Real-time уведомления: Чаты, оповещения в веб-приложениях через WebSocket (комбинация с pg_notify в триггерах).
4. Координация процессов: Сигнализация между несколькими экземплярами приложения о необходимости обновить конфигурацию.

Пример с триггером, который автоматически отправляет NOTIFY при изменении данных:

CREATE OR REPLACE FUNCTION notify_order_change() RETURNS TRIGGER AS $$
BEGIN
    NOTIFY orders, 'updated:' || NEW.id;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER order_update_trigger
AFTER INSERT OR UPDATE ON orders
FOR EACH ROW EXECUTE FUNCTION notify_order_change();

Альтернативы и расширения

Для сложных сценариев, где требуется персистентность, гарантии доставки или обработка в распределённых системах, Notify может быть недостаточно. В таких случаях используют:

• Таблицы-очереди с SKIP LOCKED для конкурентной обработки.
• Внешние брокеры сообщений (RabbitMQ, Kafka).
• Расширение pg_message_queue для расширенных возможностей.

В заключение, Notify в PostgreSQL — это мощный, но простой инструмент для асинхронной коммуникации, идеальный для real-time уведомлений и реактивных систем в пределах одной базы данных. Его эффективность особенно высока в микросервисных архитектурах и приложениях, требующих мгновенной реакции на изменения данных. Однако для критически важных сообщений с гарантированной доставкой стоит рассмотреть более надёжные альтернативы.