Ably — nền tảng Pub/Sub thời gian thực là gì và cách hoạt động

Ably là gì?

Ably là nền tảng thời gian thực trên đám mây được thành lập năm 2014, cung cấp cơ sở hạ tầng cho nhắn tin thời gian thực. Không giống các dịch vụ pub đơn giản, Ably cung cấp đảm bảo gửi cấp doanh nghiệp, mạng lưới điểm hiện diện (POP) toàn cầu và đồng bộ hóa trạng thái tích hợp cho hàng triệu client đồng thời.

Nền tảng được sử dụng trong các dự án mà độ tin cậy gửi là quan trọng: bảng giá tài chính, trình theo dõi hậu cần, hệ thống giám sát y tế và trò chơi nhiều người chơi. Ably dựa trên công nghệ broker tin nhắn phân tán của riêng mình, sao chép dữ liệu qua mạng lưới toàn cầu gồm hơn 15 trung tâm dữ liệu.

Theo trang web chính thức của Ably (2025), nền tảng xử lý hơn 200 tỷ tin nhắn mỗi tháng cho hơn 50.000 ứng dụng đang hoạt động. Khách hàng bao gồm các công ty Fortune 500: Toyota (telematics ô tô), HubSpot (đồng bộ hóa CRM), Designity (chỉnh sửa cộng tác).

Kiến trúc Ably

Kiến trúc Ably được xây dựng trên mạng lưới broker tin nhắn phân tán (router) kết nối qua các kênh tốc độ cao. Mỗi broker phục vụ một tập hợp con các kênh và sao chép trạng thái qua Giao thức Ably — giao thức nhị phân trên WebSocket được tối ưu hóa cho overhead tối thiểu. Client kết nối đến broker gần nhất qua cân bằng tải DNS.

Một điểm khác biệt chính của Ably so với đối thủ là nhật ký toàn cầu tích hợp, lưu trữ lịch sử tin nhắn cho mỗi kênh. Điều này cho phép người đăng ký mới nhận không chỉ tin nhắn mới mà còn cả tin nhắn trước đó (phát lại), rất quan trọng cho kiểm toán và khôi phục trạng thái sau khi kết nối lại.

Cách Ably hoạt động

Mô hình tương tác Ably tuân theo mẫu Người xuất bản-Người đăng ký với các khả năng bổ sung. Người xuất bản gửi tin nhắn đến một kênh qua REST API hoặc SDK của Ably. Tin nhắn đi vào nhật ký phân tán toàn cầu của kênh và được phân phối đến tất cả người đăng ký qua kết nối đang hoạt động của họ.

Tầng vận chuyển — Ably hỗ trợ nhiều giao thức: WebSocket (chính, với Giao thức Ably nhị phân), Server-Sent Events (để nhận một chiều), HTTP streaming (cho môi trường hạn chế) và MQTT (cho thiết bị IoT). Client tự động chọn phương thức vận chuyển có sẵn với độ trễ thấp nhất.

Mỗi tin nhắn trải qua xác thực ở phía Ably — kiểm tra chữ ký khóa API, kiểm tra hạn mức kênh, quyền truy cập. Xác thực diễn ra trong 1–5 ms trên router biên, sau đó tin nhắn được sao chép vào nhật ký toàn cầu. Theo blog kỹ thuật của Ably (2024), độ trễ đầu cuối dưới 65 ms cho 95% tin nhắn khi truyền liên lục địa.

Kênh và đăng ký

Kênh Ably là các chủ đề có tên để trao đổi tin nhắn. Mỗi kênh có thể có số lượng người đăng ký không giới hạn, nhưng để có hiệu suất ổn định, khuyến nghị không quá 10.000 mỗi kênh trong một khu vực. Kênh có thể đơn hướng (chỉ xuất bản từ máy chủ) hoặc song công (client xuất bản tin nhắn).

Kênh Ably và mô hình Pub/Sub

Mô hình Pub/Sub trong Ably mở rộng mẫu cổ điển với các khả năng bổ sung: hiện diện người đăng ký, lịch sử tin nhắn, trạng thái kênh và không gian tên. Mỗi kênh thuộc về một không gian tên xác định hạn mức và quyền truy cập.

Hiện diện — theo dõi tự động người tham gia kênh. Mỗi client đăng ký một kênh sẽ đăng ký trong bản đồ hiện diện với clientId, trạng thái (trực tuyến, vắng mặt, ngoại tuyến) và dữ liệu tùy ý. Khi client ngắt kết nối (do hết thời gian hoặc rõ ràng), hiện diện được cập nhật tự động.

Lịch sử tin nhắn — mỗi kênh lưu trữ lịch sử tin nhắn theo mặc định (tối đa 2 phút hoặc 100 tin nhắn trong gói miễn phí). Trong gói trả phí, lịch sử có thể được mở rộng lên đến 72 giờ với khả năng truy cập hồi tố tùy ý. Lịch sử được lưu trữ trong nhật ký phân tán với đảm bảo bất biến (chỉ nối thêm).

Đảm bảo gửi của Ably

Đảm bảo gửi là điểm khác biệt chính của Ably so với hầu hết các dịch vụ thời gian thực. Nền tảng hỗ trợ nhiều chế độ gửi, có thể chọn khi xuất bản tin nhắn. Chế độ xác định số lần tin nhắn sẽ được gửi và cách xử lý lỗi kết nối.

At-least-once — tin nhắn được gửi ít nhất một lần, có thể trùng lặp. Chế độ này được sử dụng cho thông báo và dữ liệu không quan trọng khi trùng lặp không gây hại. Exactly-once — tin nhắn được gửi chính xác một lần nhờ khử trùng lặp ở phía client và máy chủ. Chế độ này bắt buộc cho giao dịch tài chính và quản lý thiết bị.

Last-value cache — chế độ đặc biệt nơi kênh lưu trữ giá trị cuối cùng của mỗi tin nhắn có tên. Người đăng ký mới nhận ngay lập tức trạng thái hiện tại mà không cần chờ sự kiện tiếp theo. Điều này được thực hiện qua kho lưu trữ key-value toàn cầu trên mỗi router. Theo tài liệu Ably (2025), last-value cache giảm thời gian khôi phục trạng thái sau khi kết nối lại từ 2–5 giây xuống 50–100 ms.

Cách sử dụng Ably trong dự án

Bắt đầu với Ably yêu cầu đăng ký, tạo ứng dụng và lấy khóa API. Thư viện có sẵn cho tất cả các nền tảng chính. Hãy xem ví dụ về xuất bản và đăng ký sử dụng JavaScript SDK. Client kết nối với khóa API, đăng ký một kênh và gắn trình xử lý sự kiện.

Theo tài liệu Ably (2025), khuyến nghị sử dụng khóa API khác nhau cho phần máy chủ và client với quyền tối thiểu (nguyên tắc đặc quyền tối thiểu). Khóa máy chủ có thể xuất bản lên bất kỳ kênh nào, trong khi khóa client chỉ có thể đăng ký các không gian tên cụ thể.

Đăng ký kênh Ably

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('Received:', message.data);
});

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

Xuất bản từ máy chủ

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('Message published via REST');
});

Ably vs Pusher: so sánh

Lựa chọn giữa Ably và Pusher phụ thuộc vào yêu cầu dự án. Cả hai nền tảng đều cung cấp cơ sở hạ tầng thời gian thực được lưu trữ, nhưng khác nhau về kiến trúc, đảm bảo và giá cả. Ably tập trung vào doanh nghiệp với yêu cầu độ tin cậy cao, trong khi Pusher hướng đến khởi động nhanh và đơn giản.

Ably sử dụng nhật ký phân tán toàn cầu cho mỗi kênh, đảm bảo gửi exactly-once và truy cập hồi tố lịch sử. Pusher sử dụng kiến trúc broker với đảm bảo at-least-once. Đối với hầu hết ứng dụng, sự khác biệt không đáng kể, nhưng đối với hệ thống tài chính và y tế, exactly-once là quan trọng.

Theo bài kiểm tra so sánh Ably vs Pusher (2024), Ably cho thấy độ trễ thấp hơn 20–30% khi truyền liên lục địa nhờ số lượng trung tâm dữ liệu lớn hơn. Pusher vượt trội về tốc độ tích hợp — thiết lập cơ bản mất 10–15 phút so với 20–30 phút cho Ably do có nhiều tùy chọn cấu hình hơn.

Tích hợp di động Ably

SDK Ably cho nền tảng di động hỗ trợ iOS (Swift), Android (Kotlin/Java), Flutter và React Native. Client di động hoàn toàn tương thích với phía máy chủ Ably và hỗ trợ tất cả tính năng: pub/sub, hiện diện, lịch sử, thông báo đẩy. Cho Android, có sẵn tích hợp với Firebase Cloud Messaging để gửi thông báo đẩy ngoại tuyến.

Tối ưu hóa cho mạng di động — SDK Ably sử dụng nhịp tim thích ứng: trên Wi-Fi, khoảng cách 15 giây, trên mạng di động — lên đến 60 giây để tiết kiệm lưu lượng. Khi mất kết nối, SDK chuyển sang phương thức vận chuyển dự phòng (HTTP streaming) mà không có độ trễ rõ rệt cho người dùng. Mức tiêu thụ lưu lượng trung bình là 0.5–1 KB mỗi phút ở chế độ chờ.

Thông báo đẩy — Ably hỗ trợ gửi thông báo đẩy qua APNs (Apple) và FCM (Firebase). Thông báo đẩy có thể được gửi đến một kênh cụ thể hoặc clientId. Nếu client đang hoạt động (WebSocket đã kết nối), tin nhắn được gửi qua kênh. Nếu client bị ngắt kết nối, tin nhắn được gửi dưới dạng thông báo đẩy. Điều này đảm bảo người dùng không bao giờ bỏ lỡ tin nhắn quan trọng.