ZMQ 1-n в очереди на многопоточность

Question

Im заинтересовался концептуальной эффективностью 1-n против многопоточности в ZMQ.

позвольте мне начать, давая conseptual проблему:

У меня есть 20 клиентов и один сервер. (Я буду использовать разъемы push и pull для удобства, но им интересно, если ответ будет изменен с rep, req, дилером, маршрутизатором).

Если клиенты имеют push-разъемы и сервер, то все сообщения попадают в одно нажатие на сервер. ZMQ будет честно размещать push-сообщения на сервере, а контексту может быть задан аргумент инициализации для количества используемых потоков.

Но что происходит под капотом? это опрос входов или многопотоковых сообщений между ними. Принесут ли какие-либо выгоды от их многопоточности?

Я вижу три способа сделать описанную выше систему (20 клиентов на одном сервере).

1) используйте один разъем на сервере и нажимайте на каждого клиента.

2) используйте 20 разъемов на сервере, используя опрос zmq, чтобы выбрать из них действия. клиенты по-прежнему имеют push-разъем.

3) использовать 20 тяговых игроков на сервере каждый в пределах своей собственной нити (например, 20 потоков). Клиенты имеют одинаковые 20 точечных разъемов (по 1 штуки).

Я понимаю, что не используя вариант 1, теряющий динамический характер вновь присоединенных клиентов, а опция 2 удаляет честную очередь, но им просто интересно в эффективности.

Это мой вопрос, потоки клиентов? или просто использовать zmq 1-n?

Answer 1

Под капотом ZMQ использует такие вещи, как select(), epoll() и т. Д. Эти фоновые потоки запускают протокол zmqtp, который используется для транспортировки ваших сообщений, реализации шаблонов и т. Д. Ваша программа взаимодействует с этими потоками, используя zmq_send(), zmq_recv(), и также также zmq_poll(), который сам использует select(). Таким образом, AFAIK все достаточно эффективно, все блокируется, когда ничего не происходит, и нет ничего, что можно было бы получить путем многопоточности всего этого.

По этой причине транспорт IPC не работает в Windows. Нет выбора() для труб в Windows, тогда как на * nix-каналах, сокетах, файлах и т. Д. Все дескрипторы файлов и select() работают для них всех.

Эта особенность Windows была крупной PITA для таких вещей, как Cygwin; они реализовали функцию select() POSIX в Windows, запустив поток на дескриптор файла без сокета и опросив именованные каналы, последовательные порты и т. д. Таким образом, в Cygwin вы можете создавать каналы и включать их в вызов select(), но, следовательно, есть куча нитей, опробовавших нижние окна Windows, что неэффективно. Авторы ZMQ решили не делать этого.

Вам нужно будет выполнить только 2) или 3), если время обслуживания каждого клиента в 1) больше времени, необходимого для передачи сообщений от клиента на сервер. Помните, что все это - ваш Ethernet-сетевой адаптер, все равно все это происходит. Наличие большего количества потоков на сервере не сделает Ethernet более быстрым.