Giới thiệu NFlux
NFlux ra đời sau nhiều năm tôi vật lộn với mã sự kiện boilerplate trong các nền tảng giao dịch. Mục tiêu của tôi là giúp các nhà phát triển khác tránh những cạm bẫy tương tự và tăng tốc hành trình của họ vào kiến trúc hướng sự kiện.
NFlux là gì?
Thiết kế hệ thống thời gian thực là một trong những thách thức lớn nhất trong kỹ thuật phần mềm hiện đại.
Dù bạn đang xây dựng nền tảng giao dịch, ứng dụng IoT hay API có thông lượng cao, bạn cần kiến trúc hướng sự kiện có độ trễ thấp, chịu lỗi và có khả năng mở rộng.
Đó chính xác là lý do NFlux được tạo ra.
NFlux là một framework mã nguồn mở được xây dựng trên nền tảng .NET 9, giúp dễ dàng hơn trong việc thiết kế, điều phối và quan sát các miền hướng sự kiện. Thay vì viết mã boilerplate không ngừng, bạn có thể tập trung vào logic kinh doanh của mình, trong khi NFlux xử lý việc điều phối, quản lý vòng đời, khả năng quan sát và các mẫu tích hợp.
Tại sao chọn NFlux?
Hãy thẳng thắn mà nói:
Việc viết các nhà xuất bản và tiêu thụ sự kiện bằng tay là rất lặp đi lặp lại.
Việc theo dõi các chu kỳ miền, các lần thử lại và bộ hẹn giờ điều phối là rất khó khăn.
Việc thêm các số liệu, nhật ký và theo dõi thường trở thành một suy nghĩ muộn màng.
NFlux loại bỏ những ma sát đó. Nó cung cấp cho bạn một cách có cấu trúc để:
✅ Định nghĩa các miền phản ứng với sự kiện và lệnh
✅ Điều phối các chu kỳ người dùng với các bộ hẹn giờ tích hợp (không hoạt động, tái chế, thử lại)
✅ Chuẩn hóa và xử lý dữ liệu trong các pipeline thời gian thực
✅ Tiết lộ các endpoint với tính năng phát hiện tự động
✅ Thu thập số liệu từ đầu ra sử dụng OpenTelemetry
Các khái niệm cốt lõi
1. Các miền
Trong NFlux, một miền đại diện cho một khả năng kinh doanh tự chứa.
Mỗi miền phản ứng với các sự kiện và thực hiện các lệnh.
Điều này tương ứng tự nhiên với DDD (Thiết kế hướng miền): động cơ giao dịch của bạn, trình theo dõi ký hiệu của bạn, hoặc quản lý rủi ro của bạn đều có thể trở thành các miền độc lập.
2. Sự kiện & Lệnh
Sự kiện mô tả những gì đã xảy ra.
Lệnh mô tả điều gì nên xảy ra tiếp theo.
NFlux giúp việc xuất bản và xử lý các đối tượng này trở nên đơn giản, đồng thời cung cấp các kho lưu trữ sự kiện trong bộ nhớ để thử nghiệm và đảm bảo chất lượng.
3. Các bộ điều phối
Mọi hệ thống thời gian thực đều cần điều phối.
NFlux cung cấp BaseSocketOrchestratorHostedService, quản lý:
- Vòng đời khởi động/dừng
- Bộ hẹn giờ không hoạt động
- Chu kỳ tái chế
- Chu kỳ kích hoạt (thông qua các sự kiện)
Điều này đảm bảo rằng các miền vẫn hoạt động mà không cần người giám sát thủ công.
4. Quan sát đầu tiên
NFlux tích hợp với IMeterFactory và OpenTelemetry.
Mỗi cuộc gọi endpoint, xử lý sự kiện và chu kỳ đều được theo dõi với các số liệu.
Điều đó có nghĩa là bạn nhận được histogram độ trễ, bộ đếm lỗi và số liệu ký hiệu mà không cần viết một dòng mã nào.
Ví dụ sử dụng: Giám sát ký hiệu thời gian thực
Hãy tưởng tượng bạn cần giám sát các cặp giao dịch crypto trong thời gian thực.
Với NFlux, bạn:
- Định nghĩa một miền DownloadSymbols để lấy dữ liệu thị trường thô.
- Chuẩn hóa các ký hiệu thành các đối tượng kinh doanh nhất quán (giá đóng cửa, khối lượng, biểu đồ sparkline, chỉ báo kỹ thuật).
- Điều phối các ticker thời gian thực thông qua RealtimeSymbolsOrchestrator.
Tiết lộ các endpoint QA:
- /qa/metrics → xem tình trạng và số lượng của hệ thống
- /qa/registry/{TenantId} → xem trạng thái hiện tại của registry
- /qa/watcher/publish → tiêm các ticker giả để kiểm tra E2E
Các nhà phát triển của bạn có thể thử nghiệm toàn bộ pipeline bằng cách xuất bản các ticker giả và quan sát dòng cập nhật qua hệ thống.
Trải nghiệm của nhà phát triển
- Một trong những điểm mạnh lớn nhất của NFlux là năng suất của nhà phát triển.
- Các bài kiểm tra tích hợp xác thực các miền trong chế độ cô lập.
- Các bài kiểm tra đầu-cuối (E2E) chạy trên các môi trường Aspire với các endpoint QA.
- Các registry và kho lưu trữ sự kiện trong bộ nhớ đơn giản hóa việc thử nghiệm cục bộ.
- Tính năng phát hiện tự động các endpoint giữ cho các bộ điều khiển đơn giản.
Điều này có nghĩa là các chu kỳ lặp lại nhanh hơn, ít mã boilerplate hơn và nhiều sự tự tin hơn trong việc triển khai sản xuất.
Lợi ích tổng quan
🔹 Các sự kiện và lệnh kiểu mạnh (không có tin nhắn kiểu yếu)
🔹 Điều phối hướng sự kiện với nhận thức về người dùng
🔹 Quan sát cắm và chạy với các số liệu OpenTelemetry
🔹 Hỗ trợ tích hợp cho các endpoint QA và thử nghiệm
🔹 Hoạt động liền mạch với .NET 9 và Aspire
Bước tiếp theo cho NFlux
- Phát hành các bản ổn định trên NuGet.org
- Mở rộng tài liệu với các nghiên cứu trường hợp
- Cung cấp các mẫu sẵn sàng sử dụng cho các dự án Aspire
- Phát triển cộng đồng với các đóng góp và plugin
Kết luận
NFlux không chỉ là một thư viện .NET khác.
Nó là một framework cho việc xây dựng các hệ thống đáng tin cậy, hướng sự kiện, nơi các miền, điều phối và khả năng quan sát hòa quyện vào nhau.
Nếu bạn đã từng vật lộn với mã sự kiện boilerplate, thiếu số liệu, hoặc các thủ thuật điều phối, NFlux sẽ thay đổi điều đó.
👉 Khám phá repo trên GitHub
👉 Cài đặt từ NuGet (sắp ra mắt)
👉 Tham gia cộng đồng và đóng góp
Bạn đã từng xây dựng các hệ thống hướng sự kiện trong .NET chưa? Những thách thức lớn nhất bạn gặp phải là gì? Để lại bình luận — tôi rất muốn nghe những trải nghiệm của bạn và bắt đầu một cuộc thảo luận.
