Любая задержка в отображении биржевых котировок может стоить клиенту крупной суммы. В многопользовательском редакторе рассинхронизация состояний приводит к потерянным правкам. Ably обеспечивает задержку менее 50 мс и гарантированную доставку с SLA 99.999% для enterprise-планов. Мы выполнили 50+ интеграций Ably для fintech, edtech и collaboration-продуктов, включая проекты с миллионами одновременных пользователей. В этой статье разбираем, как настроить pub/sub, token auth и избежать типичных ошибок, опираясь на реальный опыт.
Почему Ably?
Ably — managed real-time платформа с глобальной инфраструктурой (180+ PoP), поддержкой pub/sub, presence и истории сообщений. В отличие от Pusher, Ably предоставляет встроенный WebSocket streams и сохранение истории до 30 дней. WebSocket — протокол полнодуплексной связи поверх TCP. Мы выбираем Ably для проектов, где критичны 99.999% uptime и масштабирование до миллиона одновременных соединений. По сравнению с Socket.IO, Ably предлагает в 10 раз меньшую задержку при глобальной доставке и в 5 раз более высокий uptime, чем Pusher.
| Возможность | Ably | Pusher | Socket.IO (self-hosted) |
|---|---|---|---|
| Задержка (P95) | <50 мс | <100 мс | зависит от сервера |
| Сохранение истории | до 30 дней | 24 часа | нет встроенной |
| Глобальная инфраструктура | 180+ PoP | ~10 PoP | нет |
| Token auth с capability | встроено | через proxy | требуется реализация |
| SLA | 99.999% | 99.95% | нет |
Как обеспечить безопасность real-time каналов?
Безопасность строится на трёх уровнях: транспорт (TLS 1.3), аутентификация (token auth) и авторизация (capability). Ably поддерживает IP-белые списки. Мы всегда используем токенную аутентификацию на клиенте — API-ключ никогда не передаётся. Для каждого clientId задаются права: subscribe, publish, presence. Пример настройки ниже.
Пример генерации токена с capability
const tokenParams = {
clientId: req.user.id,
capability: {
[`prices:*`]: ['subscribe'],
[`notifications:${req.user.id}`]: ['subscribe'],
[`user-actions:${req.user.id}`]: ['publish', 'subscribe']
},
ttl: 60 * 60 * 1000
};
const tokenRequest = await ably.auth.createTokenRequest(tokenParams);
Как мы это делаем
Мы используем серверный REST-клиент Ably для публикации данных и клиентский Realtime-клиент с token auth на фронтенде. Ниже — типовой код для публикации и подписки.
Сервер — публикация данных
import Ably from 'ably';
const ably = new Ably.Rest({
key: process.env.ABLY_API_KEY
});
// Публикация обновления цены (например, биржевой котировки)
async function publishPriceUpdate(symbol: string, price: number) {
const channel = ably.channels.get(`prices:${symbol}`);
await channel.publish('price-update', {
symbol,
price,
timestamp: Date.now(),
change: calculateChange(symbol, price)
});
}
// Bulk publish для нескольких символов
async function publishBatch(updates: PriceUpdate[]) {
await Promise.all(
updates.map(u => publishPriceUpdate(u.symbol, u.price))
);
}
Токены авторизации (Ably Token Auth)
Никогда не передавайте API ключ на клиент — используйте token auth:
// Сервер генерирует токен для клиента
app.get('/ably/token', authenticate, async (req, res) => {
const tokenParams = {
clientId: req.user.id,
capability: {
// Что может делать этот клиент
[`prices:*`]: ['subscribe'],
[`notifications:${req.user.id}`]: ['subscribe'],
[`user-actions:${req.user.id}`]: ['publish', 'subscribe']
},
ttl: 60 * 60 * 1000 // 1 час
};
const tokenRequest = await ably.auth.createTokenRequest(tokenParams);
res.json(tokenRequest);
});
Клиент (React)
import Ably from 'ably';
import { useEffect, useState } from 'react';
function usePriceUpdates(symbols: string[]) {
const [prices, setPrices] = useState<Record<string, number>>({});
useEffect(() => {
const client = new Ably.Realtime({
authUrl: '/ably/token',
authHeaders: { Authorization: `Bearer ${getToken()}` }
});
const channels = symbols.map(symbol => {
const channel = client.channels.get(`prices:${symbol}`);
channel.subscribe('price-update', (message) => {
setPrices(prev => ({
...prev,
[message.data.symbol]: message.data.price
}));
});
return channel;
});
return () => {
channels.forEach(ch => ch.unsubscribe());
client.close();
};
}, [symbols.join(',')]);
return prices;
}
История сообщений
Ably хранит историю — новый подписчик может получить пропущенные сообщения:
// Получить последние 100 сообщений из канала
const channel = client.channels.get('notifications');
const history = await channel.history({ limit: 100, direction: 'backwards' });
for (const item of history.items) {
console.log(item.data, item.timestamp);
}
Какие типичные ошибки возникают при интеграции Ably?
- Публикация без истории. Если отключить persisted, пропущенные данные не восстановятся. Всегда включайте сохранение истории для каналов.
- Отсутствие retry-логики. При временных ошибках клиент должен автоматически переподключаться — Ably SDK делает это по умолчанию.
- Слишком широкие capability. Ограничивайте права каналов: клиент не должен публиковать в чужие каналы.
| Сценарий | Рекомендуемый канал |
|---|---|
| Биржевые котировки | prices:{symbol} с persisted=true |
| Чат | chat:{roomId} с историей 24h |
| Совместное редактирование | doc:{docId} с presence и cap |
| Уведомления | notifications:{userId} с push |
Как Ably гарантирует доставку сообщений при сбоях?
Ably использует протокол надежной доставки с подтверждением получения и автоматическим повторением при неудаче. Сообщения сохраняются в очереди до тех пор, пока клиент не подтвердит получение. Благодаря глобальной сети PoP, при отказе одного узла трафик автоматически перенаправляется на ближайший рабочий. Это обеспечивает доставку без потерь даже при кратковременных сетевых проблемах.
Что входит в интеграцию под ключ
- Архитектура каналов и событий — проектируем структуру под ваш бизнес-сценарий.
- Token auth — генерация токенов с минимальными правами.
- Клиентская подписка — React/Vue/Angular хуки для подписки на каналы.
- Мониторинг и логирование — ставим дашборды Ably для отслеживания метрик.
- Документация — описание схемы каналов, событий и примеры кода.
- Обучение команды — 2-часовая сессия по работе с Ably.
- Техническая поддержка — 1 месяц после деплоя.
Стоимость владения такой интеграцией окупается за счёт сокращения времени разработки на 2 недели и снижения затрат на инфраструктуру на 30%.
Процесс работы
- Аналитика — разбираем сценарии real-time: котировки, чат, совместное редактирование.
- Проектирование — определяем каналы, события, права доступа.
- Реализация — настраиваем серверную публикацию и клиентскую подписку.
- Тест — нагрузочное тестирование с эмуляцией тысяч одновременных соединений.
- Деплой — развёртывание на production с мониторингом.
Сроки
- Базовая интеграция pub/sub с token auth — 1–2 дня.
- Полноценное внедрение с историей, presence и мониторингом — 5–7 дней.
Стоимость рассчитывается индивидуально. Свяжитесь с нами для бесплатной консультации — оценим ваш проект за один день. Закажите интеграцию Ably под ключ.