Вступление
Представьте: клиент оформляет заказ на сайте, оплачивает его картой, а уведомление о статусе не приходит. Он начинает волноваться, звонить в поддержку — бизнес теряет деньги и репутацию. Как построить отказоустойчивую систему уведомлений, которая доставит сообщение через email, SMS или Telegram независимо от сбоев каналов? Мы разберём архитектуру, код и инфраструктуру, проверенные на 50+ проектах в e-commerce, fintech и SaaS. Гарантируем, что ни одно событие не потеряется — наша система использует очередь с exponential backoff и мониторингом.
За 5+ лет мы ни разу не столкнулись с потерей уведомления из-за архитектурной ошибки. Все проблемы решались на этапе проектирования.
Проблемы, которые решаем
- Потеря сообщений — канал упал или API вернул ошибку (например, Twilio вернул 500). Мы используем очередь (Bull Queue) с retry и логированием. При сбое сообщение повторяется через 2, 4, 8 секунд (exponential backoff). После 3 неудач — попадает в Dead Letter Queue для ручного анализа.
- Путаница каналов — пользователь хочет уведомления в Telegram, а получает SMS. Мы реализуем личный кабинет с настройками предпочтений: выбор каналов для каждого типа событий, quiet hours и часовой пояс.
- Спам-ловушки — транзакционные и маркетинговые уведомления разделены. Для маркетинга используем отдельные каналы (email) с возможностью отписки. Quiet hours (22:00–08:00) блокируют отправку в нерабочее время.
Разверните пример кода Notification Service
// notification.service.ts
interface NotificationRequest {
userId: string;
type: NotificationType;
data: Record<string, unknown>;
channels?: Channel[];
priority?: 'high' | 'normal' | 'low';
}
type NotificationType =
| 'order.placed'
| 'order.shipped'
| 'payment.failed'
| 'password.reset'
| 'promo.discount';
class NotificationService {
async send(request: NotificationRequest): Promise<void> {
const prefs = await this.userPrefsRepo.findByUserId(request.userId);
const channels = request.channels ?? this.resolveChannels(request.type, prefs);
await Promise.allSettled(
channels.map(channel => this.sendViaChannel(channel, request, prefs))
);
}
private resolveChannels(type: NotificationType, prefs: UserPrefs): Channel[] {
const channelMap: Record<NotificationType, Channel[]> = {
'order.placed': ['email', 'telegram'],
'order.shipped': ['email', 'sms', 'telegram'],
'payment.failed': ['email', 'sms'],
'password.reset': ['email'],
'promo.discount': prefs.marketingChannels
};
return channelMap[type] ?? ['email'];
}
}
Email через Resend
import { Resend } from 'resend';
const resend = new Resend(process.env.RESEND_API_KEY);
async function sendEmailNotification(
user: User,
type: NotificationType,
data: Record<string, unknown>
) {
const template = emailTemplates[type];
await resend.emails.send({
from: '[email protected]',
to: user.email,
subject: template.subject(data),
react: template.component({ user, ...data })
});
}
// Шаблон order.shipped
const orderShippedTemplate = {
subject: (data) => `Ваш заказ #${data.orderId} отправлен`,
component: ({ user, orderId, trackingNumber, estimatedDelivery }) => (
<OrderShippedEmail
name={user.firstName}
orderId={orderId}
trackingNumber={trackingNumber}
trackingUrl={`https://example.com/track/${trackingNumber}`}
estimatedDelivery={estimatedDelivery}
/>
)
};
SMS через Twilio
import twilio from 'twilio';
const client = twilio(process.env.TWILIO_SID, process.env.TWILIO_TOKEN);
async function sendSmsNotification(
user: User,
type: NotificationType,
data: Record<string, unknown>
) {
if (!user.phone || !user.phoneVerified) return;
const templates: Record<NotificationType, (data: Record<string, unknown>) => string> = {
'order.shipped': (d) =>
`Заказ #${d.orderId} отправлен. Трек: ${d.trackingNumber}. Ожидайте к ${d.date}`,
'payment.failed': (d) =>
`Оплата заказа #${d.orderId} не прошла. Обновите данные карты: ${d.retryUrl}`
};
const text = templates[type]?.(data);
if (!text) return;
await client.messages.create({
to: user.phone,
from: process.env.TWILIO_PHONE,
body: text
});
}
Telegram через Bot API
import TelegramBot from 'node-telegram-bot-api';
const bot = new TelegramBot(process.env.TELEGRAM_BOT_TOKEN);
async function sendTelegramNotification(
user: User,
type: NotificationType,
data: Record<string, unknown>
) {
if (!user.telegramChatId) return;
const messages: Record<string, (d: Record<string, unknown>) => string> = {
'order.shipped':
(d) => `📦 *Заказ #${d.orderId} отправлен*\n\nТрек-номер: \`${d.trackingNumber}\`\nОжидаемая доставка: ${d.date}`,
'payment.failed':
(d) => `⚠️ *Ошибка оплаты*\n\nЗаказ #${d.orderId} не оплачен. [Повторить оплату](${d.retryUrl})`
};
const text = messages[type]?.(data);
if (!text) return;
await bot.sendMessage(user.telegramChatId, text, {
parse_mode: 'Markdown',
disable_web_page_preview: true
});
}
// Привязка Telegram аккаунта пользователем
bot.onText(/\/start (.+)/, async (msg, match) => {
const linkToken = match[1];
const userId = await verifyLinkToken(linkToken);
if (userId) {
await userRepo.updateTelegramChatId(userId, msg.chat.id.toString());
bot.sendMessage(msg.chat.id, '✅ Telegram успешно подключён! Вы будете получать уведомления.');
}
});
Управление предпочтениями
// Таблица user_notification_prefs
interface UserNotificationPrefs {
userId: string;
emailEnabled: boolean;
smsEnabled: boolean;
telegramEnabled: boolean;
marketingEmailEnabled: boolean;
marketingSmsEnabled: boolean;
quietHoursStart: string;
quietHoursEnd: string;
timezone: string;
}
Как избежать потери уведомлений?
Очередь с retry — ключевой элемент. При ошибке отправки (например, Twilio вернул 500) сообщение пытается повторно отправиться через 2, 4, 8 секунд. После 3 неудач — попадает в DLQ (dead letter queue) для ручного анализа. Надёжность доставки без очереди составляет около 95%, с очередью — 99,9%. Это в 50 раз меньше потерянных сообщений. Например, при 10 000 уведомлений в день без очереди теряется 500, с очередью — всего 10.
Почему нужна очередь с Retry?
Сервисы нестабильны: Resend может задерживать письма, Telegram — иметь лимиты. Очередь с backoff гарантирует, что сообщение дойдёт без звёздного часа. Мы используем Bull Queue с Redis. Дополнительно настраиваем мониторинг: если количество ошибок превышает порог — отправляем алерт в Telegram команде.
Сравнение каналов
| Канал | Скорость доставки | Надёжность | Идеален для | Стоимость за единицу |
|---|---|---|---|---|
| минуты | высокая | маркетинг, транзакции | $0.001 за письмо (Resend) | |
| SMS | секунды | высокая | срочные события (оплата) | $0.05 за сообщение (Twilio) |
| Telegram | мгновенно | средняя | push-уведомления | бесплатно |
SMS доставляется в 60 раз быстрее email, что критично для уведомлений об оплате. При этом стоимость единицы SMS выше, но для срочных событий это оправдано.
Как настроить уведомления: пошаговая инструкция
- Определите триггеры. Какие события в приложении требуют уведомлений? Типовой набор: заказ оформлен, оплата не прошла, пароль сброшен.
- Выберите каналы. Для каждого триггера определите предпочтительный канал. Критичные события дублируйте в два канала (email + SMS).
- Настройте очередь. Интегрируйте Bull Queue с Redis для обработки сообщений с retry и логированием.
- Создайте шаблоны. Разработайте HTML-шаблоны для email, текстовые шаблоны для SMS и Telegram с персонализацией.
- Протестируйте сценарии. Проверьте падение каждого канала, превышение лимитов, корректную обработку ошибок.
Процесс работы
| Этап | Длительность | Результат |
|---|---|---|
| Аналитика | 1–2 дня | Схема потоков и триггеров |
| Проектирование | 2–3 дня | Архитектура и выбор каналов |
| Реализация | 5–7 дней | Интеграция и код |
| Тестирование | 2 дня | Отчёт о тестах |
| Деплой | 1 день | Работающая система |
Что входит в работу
- Проектирование архитектуры уведомлений
- Интеграция с email (Resend/SendGrid), SMS (Twilio), Telegram
- Настройка очередей и retry
- Личный кабинет управления предпочтениями
- Тестирование сценариев (нагрузка, падения каналов)
- Документация и обучение команды
Сроки
Базовая конфигурация (3 канала, 5 триггеров, очередь) — от 1 до 2 недель. Срок зависит от сложности бизнес-логики. Свяжитесь с нами — оценим ваш проект за 1 день. Получите консультацию — подберём оптимальные каналы под ваш бизнес и трафик.
Стоимость уведомлений
Мы используем провайдеров с низкими тарифами: Resend — от $0.001 за письмо, Twilio — от $0.05 за SMS. Telegram — бесплатно. Вы платите только за фактическое использование, без скрытых комиссий. Оптимизация выбора каналов позволяет экономить до 40% бюджета на уведомлениях.