Vert.x cho IoT: Phản ứng, Bất đồng bộ và Gốc JVM

Vert.x là một bộ công cụ để xây dựng các hệ thống phản ứng, phân tán trên JVM. Lời hứa cốt lõi của nó: I/O bất đồng bộ, không chặn trên một vòng lặp sự kiện duy nhất, xử lý hàng triệu sự kiện mỗi giây mà không có độ phức tạp của đa luồng. Đối với IoT, nơi số lượng thiết bị và khối lượng tin nhắn bùng nổ, kiến trúc đó là một sự phù hợp tự nhiên.

Các thành phần sẵn sàng cho IoT

Vert.x cung cấp một số thành phần phù hợp với khối lượng công việc IoT:

• Máy chủ HTTP (Core) — hỗ trợ HTTP/1.1 và HTTP/2 cho các API RESTful. Quen thuộc với các nhà phát triển web/di động tham gia IoT.
• Máy chủ MQTT — không phải là một broker đầy đủ, mà là một API để xử lý các kết nối và tin nhắn MQTT. Các nhà phát triển xây dựng logic kinh doanh trên đó — dịch giao thức, kết nối Event Bus hoặc một broker tùy chỉnh.
• Cầu nối Proton & AMQP — một lớp bọc mỏng xung quanh Apache Qpid Proton cho AMQP 1.0. Cầu nối kết nối AMQP với Event Bus của Vert.x, cho phép các verticle giao tiếp với các hệ thống AMQP một cách minh bạch.
• Trình khách Kafka — gửi/tiêu thụ từ các chủ đề Kafka. Nhiều đường ống IoT dựa vào Kafka để tiếp nhận hàng triệu tin nhắn mỗi giây.

Tại sao nó hoạt động cho IoT

Các nguyên tắc của tuyên ngôn phản ứng — đáp ứng, co giãn, kiên cường, hướng thông điệp — ánh xạ trực tiếp đến các yêu cầu IoT. Thiết bị không đáng tin cậy, các đợt tăng đột biến lưu lượng rất khắc nghiệt và kỳ vọng về độ trễ rất chặt chẽ. Mô hình vòng lặp sự kiện của Vert.x tránh chi phí thread-per-connection, giữ bộ nhớ phẳng trong khi thông lượng mở rộng.

Thành phần máy chủ MQTT đặc biệt thực tế: thay vì ép buộc một ngăn xếp broker đầy đủ, nó hiển thị các sự kiện kết nối và tin nhắn. Bạn quyết định định tuyến — đến Kafka, đến một broker AMQP, đến Event Bus hoặc đến một điểm cuối TCP tùy chỉnh. Sự linh hoạt đó quan trọng khi kiến trúc của bạn là một tập hợp các giao thức.

“Nhà phát triển không cần biết MQTT hoạt động trên dây như thế nào về mặt mã hóa/giải mã tin nhắn.” — Paolo Patierno, Red Hat

Tại thời điểm viết bài (Vert.x 3.3.3), Proton và cầu nối AMQP đã ổn định; máy chủ MQTT và trình khách Kafka đang được phát triển cho phiên bản 3.4.0. Hệ sinh thái đã trưởng thành kể từ đó, nhưng các nguyên tắc kiến trúc vẫn không thay đổi.