Я использую MailboxProcessor классы, чтобы держать отдельных агентов, которые занимаются своими делами. Обычно агенты могут взаимодействовать друг с другом в одном процессе, но я хочу, чтобы агенты общались друг с другом, когда они находятся в разных процессах или даже на разных машинах. Какой механизм лучше всего подходит для осуществления связи между ними? Есть какое-то стандартное решение?
Обратите внимание, что я использую экземпляры Ubuntu для запуска агентов.
Я думаю, вам придется написать свои собственные процедуры для сериализации сообщений, передачи их через границы процесса, а затем отправки их на другую сторону. Это также потребует реализации системы идентификаторов, в которой каждый почтовый ящик имеет идентификатор, а процессы могут отправлять сообщения на идентификаторы, а не только на Mailbox.Send. Это непросто, поскольку локальные ящики будут иметь доступ к локальной памяти, а удаленные почтовые ящики - нет.
Я бы посмотрел на что-то вроде RPyC (http://rpyc.wikidot.com/), поскольку он предоставляет протокол, похожий на то, что вы ищете.
В основном ответ - «нет», на самом деле нет хорошего способа сделать это.
pid ! "foo" pid - это просто идентификатор процесса, которому "foo" отправляется. Поскольку разделяемой памяти нет, а процессы уже имеют pid, работа в сети так же проста, как создание словаря сопоставлений pid с IP и передача сообщений на основе этой информации. Проблема с этим методом заключается в том, что все коммуникации должны осуществляться через передачу сообщений, и в настоящее время также включает в себя копию сообщения в памяти. С точки зрения производительности это не всегда лучший вариант. У меня нет опыта работы со Scala.
- person Timothy Baldridge; 08.02.2011
