Я изучал, как можно разработать распределенную архитектуру, которая реализует запрос / ответ протокола, используя концепцию параллелизма между субъектами.
Я пришел к выводу, что лучший способ сделать это - создатьСистема ответов с синхронной обработкой Futures / Promises и вскоре после ответа, оставляя открытый канал для получения уведомлений.
Таким образом, архитектура, которая будет работать точно так же, как входящие сообщения.
Имеетнекоторые проблемы.
Таким образом, я должен был бы поддерживать две конечные точки (актеры на двух уровнях)?
Проблема: Модуль представления запрашивает, чтобы определенный элемент был обработан,Она отправляет эту команду для обработки через RemoteActor на сервер приложений.Этот сервер должен немедленно вернуть обещание, что уведомит вас, когда элемент будет обработан.После этого модуль представления будет ожидать уведомления о завершении обработки.
Как вы видите эту проблему?
Я использую Scala, Akka и Google Guice.
Я считаю, что это общая проблема, что каждый может использовать свои решения.Извините, если я нарушаю условия сайта stackoverflow.
Заранее спасибо