2016-04-18 24 views
6

Tôi đang cố hiểu phần mở rộng của luồng Akka mà tôi đã thấy các câu trả lời khác nhau ở đây, nhưng vẫn không hiểu cách chức năng này được hoàn thành.Dòng Akka chạy trên các nút cụm

Có ActorPublisher/Subscribers mà từ những gì tôi hiểu có nghĩa là tương tác với luồng, nhưng đồng thời nó nói rằng những điều này không thể từ xa.

Làm cách nào để tôi có thể sử dụng các cụm akka được phân tách bằng luồng? Tôi có phải để GraphStage "thuê ngoài" công việc của mình cho một diễn viên từ xa không? Hoặc bản thân graphStage có thể được chạy trên một nút cụm sao?

Trường hợp sử dụng của tôi là có một đường ống chứa một số giai đoạn tính toán nặng với các phép nối và hợp nhất và có thể cần phân phối một số giai đoạn này.

Cập nhật
Theo Crawling the Web with Akka Streams này, tôi thấy rằng một biểu đồ duy nhất không thể trải ra thành nhiều cụm. Điều gì sẽ là cách trong trường hợp này theo chiều ngang?

+0

bạn chỉ có thể sử dụng các luồng cục bộ. Bất cứ điều gì bạn làm giữa các nút từ xa phải được thực hiện theo cách "cũ". –

Trả lời

9

suối Akka chưa hỗ trợ phân cụm. Tôi khuyên bạn nên xem Apache Kafka làm phần mềm trung gian để vận chuyển nếu bạn cần một số giải pháp phân cụm và reactive-kafka. Nhưng, tất nhiên, bạn có thể thực hiện lớp vận chuyển của riêng bạn với các diễn viên và chạy nó trong cụm Akka.

Các vấn đề liên quan