Модель Pub/Sub

Розгляне публікацію подій у теми, підписки споживачів і незалежне отримання повідомлень кількома сервісами.

Що таке Pub/Sub

Pub/Sub (Publish/Subscribe, публікація/підписка) — це модель обміну повідомленнями, у якій відправник події не звертається безпосередньо до конкретного отримувача.

Замість цього:

видавець (publisher) публікує повідомлення в тему (topic);
споживачі (subscribers) підписуються на тему;
система доставки передає повідомлення всім відповідним підпискам.

Схематично модель виглядає так:

text

Publisher
    |
    v
  Topic
  /   \
 v     v
Підписка A   Підписка B
   |             |
Сервіс email  Сервіс аналітики

text

Сервіс замовлень
       |
       | публікує order.created
       v
     orders
    /       \
   v         v
email-sub  analytics-sub
   |             |
Email-сервіс  Аналітика

javascript

class PubSub {
  constructor() {
    this.topics = new Map();
  }

  createTopic(topicName) {
    if (!this.topics.has(topicName)) {
      this.topics.set(topicName, new Map());
    }
  }

  subscribe(topicName, subscriptionName, handler) {
    this.createTopic(topicName);

    const subscriptions = this.topics.get(topicName);

    if (subscriptions.has(subscriptionName)) {
      throw new Error(`Підписка "${subscriptionName}" уже існує`);
    }

    subscriptions.set(subscriptionName, {
      handler,
      queue: [],
      processing: false
    });
  }

  publish(topicName, message) {
    const subscriptions = this.topics.get(topicName);

    if (!subscriptions) {
      throw new Error(`Тема "${topicName}" не існує`);
    }

    for (const subscription of subscriptions.values()) {
      subscription.queue.push(message);
      this.processQueue(subscription);
    }
  }

  async processQueue(subscription) {
    if (subscription.processing) {
      return;
    }

    subscription.processing = true;

    while (subscription.queue.length > 0) {
      const message = subscription.queue[0];

      try {
        await subscription.handler(message);

        // Видаляємо повідомлення лише після успішної обробки.
        subscription.queue.shift();
      } catch (error) {
        console.error("Помилка обробки повідомлення:", error.message);

        // Зупиняємо цю підписку, щоб не втратити повідомлення.
        break;
      }
    }

    subscription.processing = false;
  }
}

const broker = new PubSub();

broker.subscribe("orders", "email-service", async (event) => {
  console.log(
    `[email-service] Надсилаємо лист для замовлення ${event.orderId}`
  );
});

broker.subscribe("orders", "analytics-service", async (event) => {
  console.log(
    `[analytics-service] Записуємо подію ${event.type} для замовлення ${event.orderId}`
  );
});

broker.subscribe("orders", "warehouse-service", async (event) => {
  console.log(
    `[warehouse-service] Резервуємо товари для замовлення ${event.orderId}`
  );
});

broker.publish("orders", {
  type: "order.created",
  orderId: "order-123",
  userId: "user-42",
  total: 1499
});

text

[email-service] Надсилаємо лист для замовлення order-123
[analytics-service] Записуємо подію order.created для замовлення order-123
[warehouse-service] Резервуємо товари для замовлення order-123

text

Повідомлення доступне
        |
        v
Споживач отримав повідомлення
        |
        v
Успішна обробка?
   /          \
 так           ні
 |             |
ack       повторна спроба

javascript

const processedEvents = new Set();

async function handleOrderCreated(event) {
  if (processedEvents.has(event.eventId)) {
    console.log("Подію вже оброблено:", event.eventId);
    return;
  }

  // Виконуємо операцію лише один раз.
  console.log("Створюємо запис для замовлення:", event.orderId);

  processedEvents.add(event.eventId);
}

handleOrderCreated({
  eventId: "event-001",
  type: "order.created",
  orderId: "order-123"
});

handleOrderCreated({
  eventId: "event-001",
  type: "order.created",
  orderId: "order-123"
});

json

{
  "eventId": "event-001",
  "type": "order.created",
  "occurredAt": "2026-09-02T10:30:00Z",
  "version": 1,
  "data": {
    "orderId": "order-123",
    "userId": "user-42",
    "total": 1499
  }
}

Модель Pub/Sub

Що таке Pub/Sub

Основні поняття

Видавець

Тема

Підписка

Споживач

Як працює передавання повідомлення

Приклад простої реалізації

Незалежність підписок

Окремі підписки

Кілька споживачів однієї підписки

Підтвердження повідомлення

Повторна доставка та ідемпотентність

Формат повідомлення

Переваги Pub/Sub

Слабке зв’язування

Незалежне масштабування

Асинхронна обробка

Ізоляція збоїв

Розширюваність

Обмеження та компроміси

Коли використовувати Pub/Sub

Типові помилки

Споживання повідомлення замість розповсюдження

Відсутність ідемпотентності

Підтвердження до завершення обробки

Занадто багато логіки у видавці

Відсутність версії події

Ігнорування невдалих повідомлень

Підсумок