Tôi làm cách nào để xuất bản hoặc đăng ký biểu đồ luồng Akka Stream được thực hiện?

Question

Tôi đang chơi với Akka Stream và tôi đang cố gắng tìm ra sự linh hoạt của nó sau khi thực hiện.

Một cách để làm điều đó là sử dụng ở mức độ thấp phản ứng suối API: http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource

Tuy nhiên, bạn cần phải xác định những điểm này để công bố hoặc đăng ký. Có cách nào để xuất bản hoặc đăng ký một nút biểu đồ luồng vật chất tùy ý không? Điều này có thể xảy ra, vì biểu đồ luồng vật chất hóa không là gì ngoài tập hợp các diễn viên.

Ví dụ: Thứ nhất, triển khai đồ thị dòng 1: A ~> B ~> C

Sau đó, triển khai dòng đồ thị 2 và 3: D ~> BB ~> E

Answer 1

Không thể thay đổi hoàn toàn cấu trúc của các đường ống xử lý dòng. Chúng tôi đã thấy trước một số loại giai đoạn xử lý động (như một "fanout cho người lao động có thể đến và đi"), nhưng nói chung luồng và đường ống xử lý luồng phải có bố cục xác định trước khi materialisation. Điều này cũng có ý nghĩa vì các cơ chế áp suất ngược được sử dụng trong dòng akka và reactive-streams nói chung - nó phải được quản lý một cách cẩn thận trong nội bộ, và cho phép tương tác tùy ý không phải là một cái gì đó mà mô hình streaming này được thiết kế cho.

Nếu bạn muốn tương tác tùy ý, Diễn viên phải phù hợp với bạn tốt hơn. Nếu bạn muốn có một phần tử xử lý có thể lấy tín hiệu bên ngoài để điều khiển đường ống xử lý, nó sẽ là một phần tử đặc biệt bên trong đường ống vật chất được thiết kế để đưa vào các tín hiệu này, không chỉ bất kỳ phần tử nào.

---

Kể từ khi tôi xuất bản bài viết này chúng tôi đã thêm một số tính năng động, có thể quan tâm đến những người hạ cánh trên trang web này, đáng chú ý nhất MergeHub và BroadcastHub

Xin lưu ý rằng như ow bằng văn bản cho ổn định phiên bản của Akka Streams là 2.4.16.