Что такое NATS?

Слушай, вот есть такая штука — NATS. Если по-простому, это такая система, чтобы твои сервисы могли друг с другом болтать. Овердохуища быстрая, лёгкая, на Go написана. В мире Node.js её любят, когда нужно микросервисы пообщать, IoT-штуки или что-то в облаках поднять. Всё потому, что она простая, шустрая и не тормозит.

Что тебе, как Node.js-разработчику, важно знать, чтобы не облажаться:

• Простота, блядь: Клиентская библиотека (nats.js) — ничего лишнего, протокол — либо текст, либо бинарник. Никакой ебанины.
• Скорость пиздец: Может гонять миллионы сообщений в секунду, задержки — минимальные.
• Как общаемся: Есть три основных способа: публикация/подписка (Pub/Sub), запрос/ответ (Request/Reply) и очереди (Queue Groups), чтобы нагрузку распределить.
• По умолчанию — без сохранения: Ядро (NATS Core) работает по принципу «доставил и забыл». Если тебе нужно, чтобы сообщения никуда не девались, тебе нужен NATS JetStream — это уже отдельная опция.
• Кластеризация: Брокеры можно в кластеры сбивать, чтобы всё не накрылось медным тазом, если один упадёт.

Самый простой пример: один публикует, другой слушает (Pub/Sub)

// publisher.js
const { connect } = require('nats');

async function publishEvent() {
  // Цепляемся к локальному серверу NATS
  const nc = await connect({ servers: 'nats://localhost:4222' });

  // Кидаем сообщение в топик 'user.created'
  nc.publish('user.created', JSON.stringify({
    userId: 'usr_123',
    email: 'alice@example.com',
    timestamp: new Date().toISOString()
  }));
  console.log('Событие user.created опубликовано');

  await nc.drain(); // Красиво закрываем соединение
}

publishEvent().catch(console.error);

// subscriber.js
const { connect } = require('nats');

async function subscribeToEvents() {
  const nc = await connect({ servers: 'nats://localhost:4222' });

  // Подписываемся на топик 'user.created'
  const subscription = nc.subscribe('user.created');

  console.log('Подписан на user.created. Жду...');

  // Ловим сообщения, как только прилетают
  for await (const msg of subscription) {
    const data = JSON.parse(msg.data);
    console.log(`[${msg.subject}] Получено событие для пользователя:`, data.userId);
    // Тут можешь писать в базу, письма слать — делай что хочешь.
  }
}

subscribeToEvents().catch(console.error);

Пример «Запрос-Ответ», почти как RPC:

// service.js (сервис, который отвечает)
const { connect } = require('nats');

async function startService() {
  const nc = await connect({ servers: 'nats://localhost:4222' });

  // Висим на топике 'get.user' и ждём запросов
  const sub = nc.subscribe('get.user');
  for await (const msg of sub) {
    const userId = msg.data.toString();
    console.log(`Запрос данных для пользователя: ${userId}`);
    // Допустим, тут идёт поиск в базе
    const userData = { id: userId, name: 'John Doe' };
    // Шлём ответ тому, кто спрашивал
    msg.respond(JSON.stringify(userData));
  }
}

// client.js (клиент, который спрашивает)
async function makeRequest() {
  const nc = await connect({ servers: 'nats://localhost:4222' });
  try {
    // Шлём запрос и ждём ответ, но не дольше 3 секунд
    const response = await nc.request('get.user', 'usr_999', { timeout: 3000 });
    const user = JSON.parse(response.data);
    console.log('Получен ответ:', user);
  } catch (err) {
    console.error('Запрос не удался:', err.message); // Таймаут или сервис сдох
  }
  await nc.close();
}

Очереди (Queue Groups), чтобы воркеры нагрузку делили:

// Запусти несколько таких воркеров
const { connect } = require('nats');

async function startWorker(workerId) {
  const nc = await connect({ servers: 'localhost:4222' });
  // Подписка с именем группы 'user.processors'. Сообщения в 'user.task'
  // попадёт только ОДНОМУ из подписчиков в этой группе. Не всем сразу!
  const sub = nc.subscribe('user.task', { queue: 'user.processors' });
  console.log(`Worker ${workerId} запущен и ждёт задач...`);
  for await (const msg of sub) {
    console.log(`Worker ${workerId} обрабатывает: ${msg.data}`);
    // Какая-то тяжёлая работа...
  }
}

startWorker(1).catch(console.error);
// Запусти ещё один процесс: startWorker(2)

Так когда же эту NATS выбирать для своего проекта на Node.js?

• Микросервисы общаются между собой: Когда нужна максимальная скорость и простота, без наворотов.
• IoT и данные в реальном времени: Потому что жрёт мало памяти и протокол — огонь.
• Event-Driven архитектура: Чтобы раскидывать события между компонентами.
• А что ещё есть? Если тебе нужны сложные маршруты и гарантированная доставка — смотри в сторону RabbitMQ, эта мартышлюшка там всё умеет. Если нужна потоковая обработка логов или больших данных с обязательным сохранением — тебе прямой путь на Apache Kafka. А NATS — это такая хитрая жопа, которая занимает свою нишу: очень простые и ебейше быстрые системы для обмена сообщениями. Выбирай с умом.