Bây giờ chúng ta thảo luận về một kiến trúc microservice cho vấn đề, do khả năng mở rộng cần thiết của ứng dụng trong sản xuất. Ngoài ra, đối với mục đích phát triển, điều này rất quan trọng, vì Task1 và Task2 gần đây đã được thêm các tính năng / thông số mới và mở rộng quy mô khác nhau trong quá trình phát triển.
Đây chính xác là những gì một nền tảng xử lý luồng đang làm tốt. Tôi khuyên bạn nên sử dụng một hệ thống như Apache Kafka hoặc Apache Pulsar cho vấn đề này.
Nên có ít nhất hai dịch vụ khác nhau cho Task1 và Task2 và thậm chí có thể một dịch vụ cho điều khiển trạng thái lặp / mô phỏng thực tế?
Task1 và Task2 được gọi là bộ xử lý luồng , họ đọc (đăng ký) một chủ đề , thực hiện một số thao tác / chuyển đổi và viết (xuất bản) sang chủ đề khác .
Câu hỏi chính ở đây là các đối số cho một kiến trúc microservice có thể là do tắc nghẽn mạng / truyền thông có thể là gì? Cách duy nhất để tăng tốc độ này là sinh ra tất cả dữ liệu cần thiết cho tác vụ mô phỏng trong bộ nhớ và giữ nó ở đó suốt thời gian, để tránh tắc nghẽn mạng?
Một lần nữa, đây chính xác là vấn đề mà một hệ thống như Apache Kafka hoặc Apache Pulsar đang làm tốt. Để quy mô ghi và đọc trong hệ thống xử lý luồng, bạn có thể phân vùng chủ đề của bạn .
