Ably — bu nədir, real-time Pub/Sub platforması və necə işləyir

Ably nədir?

Ably — 2014-cü ildə əsası qoyulmuş bulud əsaslı real-time platformadır, real-time mesaj mübadiləsi üçün infrastruktur təmin edir. Sadə pub xidmətlərindən fərqli olaraq, Ably korporativ çatdırılma zəmanətləri, qlobal iştirak nöqtələri (POP) şəbəkəsi və milyonlarla eyni vaxtda olan kliendlər üçün daxili vəziyyət sinxronizasiyası təklif edir.

Platforma çatdırılmanın etibarlılığının kritik olduğu layihələrdə istifadə olunur: maliyyə tickerləri, logistik izləmə sistemləri, tibbi monitorinq sistemləri və çoxoyunçulu oyunlar. Ably 15+ məlumat mərkəzindən ibarət qlobal şəbəkə vasitəsilə məlumatları replikasiya edən öz paylanmış mesaj broker texnologiyasına əsaslanır.

Ably rəsmi saytına (2025) görə, platforma 50 000+ aktiv tətbiq üçün ayda 200 milyarddan çox mesaj emal edir. Müştərilər arasında Fortune 500 siyahısından şirkətlər var: Toyota (avtomobil telematikası), HubSpot (CRM sinxronizasiyası), Designity (birgə redaktə).

Ably arxitekturası

Ably arxitekturası yüksək sürətli kanallar vasitəsilə birləşdirilmiş paylanmış mesaj brokerləri (routerlər) şəbəkəsi üzərində qurulub. Hər bir broker kanalların alt çoxluğuna xidmət edir və vəziyyəti Ably Protocol — minimal overhead üçün optimallaşdırılmış WebSocket üzərindən ikili protokol vasitəsilə replikasiya edir. Kliendlər DNS balanslaşdırması vasitəsilə ən yaxın brokerə qoşulur.

Ably-nin rəqiblərindən əsas fərqi — hər bir kanal üçün mesaj tarixçəsini saxlayan daxili global log (qlobal jurnal). Bu, yeni abunəçilərə təkcə yeni deyil, həm də əvvəlki mesajları (replay) almağa imkan verir ki, bu da audit və yenidən qoşulmadan sonra vəziyyətin bərpası üçün kritikdir.

Ably necə işləyir

Ably qarşılıqlı əlaqə modeli əlavə imkanlarla Publisher-Subscriber nümunəsinə əməl edir. Nəşr edən mesajı REST API və ya SDK vasitəsilə kanala göndərir. Mesaj kanalın qlobal paylanmış jurnalına daxil olur və aktiv bağlantıları vasitəsilə bütün abunəçilərə göndərilir.

Nəqliyyat səviyyəsi Ably bir neçə protokolu dəstəkləyir: WebSocket (əsas, ikili Ably Protocol ilə), Server-Sent Events (birtərəfli qəbul üçün), HTTP streaming (məhdudiyyətli mühitlər üçün) və MQTT (IoT cihazları üçün). Kliyent avtomatik olaraq ən az gecikmə ilə mövcud nəqliyyatı seçir.

Hər bir mesaj Ably tərəfindən validasiyadan keçir — API açar imzası, kanal kvotası, giriş hüquqları yoxlanılır. Validasiya kənar routerdə 1–5 ms ərzində baş verir, bundan sonra mesaj qlobal jurnala replikasiya olunur. Ably texniki bloguna (2024) görə, qitələrarası ötürmədə mesajların 95% üçün end-to-end gecikmə 65 ms-dən azdır.

Kanallar və abunəliklər

Ably kanalları — mesaj mübadiləsi üçün adlandırılmış mövzular. Hər bir kanalın qeyri-məhdud sayda abunəçisi ola bilər, lakin sabit performans üçün bir zona çərçivəsində hər kanala 10 000-dən çox olmamaq tövsiyə olunur. Kanallar birtərəfli (yalnız serverdən nəşr) və ya tam (kliendlər mesajları nəşr edir) ola bilər.

Ably kanalları və Pub/Sub modeli

Ably-də Pub/Sub modeli klassik nümunəni əlavə imkanlarla genişləndirir: abunəçilərin iştirakı (presence), mesaj tarixçəsi (history), kanal vəziyyəti (channel state) və ad məkanları (namespaces). Hər bir kanal kvotaları və giriş hüquqlarını müəyyən edən ad məkanına aiddir.

İştirak (Presence) — kanal iştirakçılarının avtomatik izlənməsi. Kanala abunə olan hər bir kliyent clientId, status (online, away, offline) və ixtiyari məlumatlarla presence map-də qeydiyyatdan keçir. Kliyent ayrıldıqda (timeout və ya açıq şəkildə) presence avtomatik yenilənir.

Mesaj tarixçəsi — hər bir kanal standart olaraq mesaj tarixçəsini saxlayır (pulsuz planda 2 dəqiqə və ya 100 mesaj). Ödənişli planlarda tarixçə 72 saata qədər artırıla bilər, ixtiyari retrospektiv giriş imkanı ilə. Tarixçə dəyişməzlik zəmanəti (append-only) ilə paylanmış jurnalda saxlanılır.

Ably çatdırılma zəmanətləri

Çatdırılma zəmanətləri — Ably-nin əksər real-time xidmətlərdən əsas fərqi. Platforma mesajın dərc edilməsi zamanı seçilən bir neçə çatdırılma rejimini dəstəkləyir. Rejim mesajın neçə dəfə çatdırılacağını və bağlantı xətalarının necə idarə olunacağını müəyyən edir.

At-least-once — mesaj ən azı bir dəfə çatdırılır, təkrarlar mümkündür. Rejim bildirişlər və təkrarların zərər vermədiyi qeyri-kritik məlumatlar üçün istifadə olunur. Exactly-once — mesaj kliyent və server tərəfində deduplikasiya hesabına ciddi şəkildə bir dəfə çatdırılır. Rejim maliyyə əməliyyatları və cihazların idarə edilməsi üçün məcburidir.

Last-value cache — xüsusi rejimdir, burada kanal hər bir adlandırılmış mesajın son dəyərini saxlayır. Yeni abunəçi növbəti hadisəni gözləmədən dərhal cari vəziyyəti alır. Bu, hər bir routerdə qlobal key-value store vasitəsilə həyata keçirilir. Ably sənədlərinə (2025) görə, last-value cache yenidən qoşulmadan sonra vəziyyətin bərpa müddətini 2–5 saniyədən 50–100 ms-ə endirir.

Layihədə Ably-dən necə istifadə etməli

Ably ilə işə başlamaq qeydiyyat, tətbiq yaratma və API açarı əldə etmə tələb edir. Kitabxanalar bütün əsas platformalar üçün mövcuddur. JavaScript SDK-dan istifadə edərək nəşr və abunə nümunəsinə baxaq. Kliyent API açarı ilə qoşulur, kanala abunə olur və hadisə idarəedicisi təyin edir.

Ably sənədlərinə (2025) görə, server və kliyent hissələri üçün müxtəlif API açarlarından minimal hüquqlarla (ən az imtiyaz prinsipi) istifadə etmək tövsiyə olunur. Server açarı istənilən kanallarda nəşr edə bilər, kliyent açarı — yalnız müəyyən ad məkanlarına abunə ola bilər.

Ably kanalına abunə

import * as Ably from 'ably';

const client = new Ably.Realtime({
    key: 'YOUR_API_KEY',
    clientId: 'user-123'
});

const channel = client.channels.get('test-channel');

channel.subscribe('update', (message) => {
    console.log('Alındı:', message.data);
});

channel.publish('update', {
    text: 'Hello from Ably',
    priority: 1
});

Serverdən nəşr

const Ably = require('ably');

const rest = new Ably.Rest({ key: 'SERVER_API_KEY' });

const channel = rest.channels.get('test-channel');

channel.publish('server-event', {
    type: 'notification',
    payload: { userId: 100, text: 'Server message' }
}).then(() => {
    console.log('REST vasitəsilə dərc edilmiş mesaj');
});

Ably vs Pusher: müqayisə

Ably və Pusher arasında seçim layihənin tələblərindən asılıdır. Hər iki platforma hosted real-time infrastruktur təmin edir, lakin arxitektura, zəmanətlər və qiymətləndirmə baxımından fərqlənir. Ably etibarlılığa yüksək tələbləri olan enterprise üçün, Pusher — sürətli başlanğıc və sadəlik üçün nəzərdə tutulub.

Ably hər bir kanal üçün qlobal paylanmış jurnal istifadə edir ki, bu da exactly-once çatdırılma və tarixçəyə retrospektiv giriş təmin edir. Pusher at-least-once zəmanəti ilə broker arxitekturasından istifadə edir. Əksər tətbiqlər üçün fərq nəzərə çarpmır, lakin maliyyə və tibbi sistemlər üçün exactly-once kritikdir.

Ably vs Pusher müqayisə testinə (2024) görə, Ably daha çox məlumat mərkəzi sayəsində qitələrarası ötürmədə 20–30% daha az gecikmə göstərir. Pusher inteqrasiya sürətinə görə üstündür — əsas konfiqurasiya Ably üçün 20–30 dəqiqəyə qarşı 10–15 dəqiqə çəkir, çünki Ably-də daha çox konfiqurasiya variantı var.

Ably mobil inteqrasiyası

Mobil platformalar üçün Ably SDK iOS (Swift), Android (Kotlin/Java), Flutter və React Native dəstəkləyir. Mobil kliendlər Ably server hissəsi ilə tam uyğundur və bütün funksiyaları dəstəkləyir: pub/sub, presence, history, push bildirişləri. Android üçün push bildirişlərinin oflayn çatdırılması üçün Firebase Cloud Messaging ilə inteqrasiya mövcuddur.

Mobil şəbəkələr üçün optimallaşdırma — Ably SDK adaptiv heartbeat istifadə edir: Wi-Fi-da interval 15 saniyə, mobil şəbəkədə — trafikə qənaət üçün 60 saniyəyə qədər. Bağlantı itirildikdə SDK istifadəçi üçün görünməz gecikmə ilə ehtiyat nəqliyyata (HTTP streaming) keçir. Orta trafik istehlakı — gözləmə rejimində dəqiqədə 0.5–1 KB.

Push bildirişləri — Ably APNs (Apple) və FCM (Firebase) vasitəsilə push göndərilməsini dəstəkləyir. Push konkret kanala və ya clientId-ə yönəldilə bilər. Kliyent aktivdirsə (WebSocket qoşulub), mesaj kanal vasitəsilə çatdırılır. Kliyent ayrılıbsa, mesaj push bildirişi kimi çatdırılır. Bu, istifadəçinin heç vaxt vacib mesajı qaçırmamasını təmin edir.