Я ищу пример кода для актера libcppa, который прослушивает порт для нового соединения, а затем порождает новых акторов для обработки нового соединения.
Любая помощь будет оценена.
Спасибо
Вы хотите, чтобы актеры читали / писали прямо из / в сокет? Надлежащая абстракция ввода-вывода на основе акторов еще не реализована, но это запланированная функция для следующей версии libcppa (следите за обновлениями). Если вы хотите распространять своих актеров только по сети, взгляните на пару функций publish / remote_actor.
/редактировать:
На данный момент вы можете использовать утилиту libcppa для запуска и запуска блокирующей версии:
using namespace cppa;
spawn<detached>([] {
auto ack = network::ipv4_acceptor::create(4242);
for (;;) {
auto spair = ack->accept_connection();
spawn<detached>([spair] {
// spair.first is the input stream
// spair.second is the output stream
// please see http://neverlord.github.io/libcppa/namespacecppa_1_1network.html
});
}
);
Это делает не хорошо масштабируется, потому что вы создадите поток для каждого соединения, и это не очень элегантно. Кроме того, трудно мультиплексировать между сообщениями, полученными через сокет, и сообщениями, полученными от других участников. Более элегантное решение уже в пути. 😉
Других решений пока нет …