М
смотри, у меня есть процесс. который иницирует соединение с шардами которые селектят блоки, один такой процесс подключается ко всем 10 шардам. ещё один воркер делает тоже самое. и так пока все воркеры не получат каждому свой сет коннектов
Size: a a a
2021 June 24
М
они их держат пока живы
VO
в первом приближении если форк сделать послек акцепта то ты как раз в нескольких процессах и будешь слушать один коннект
W
У вас опять все в кучу смешалось
М
видимо я тупой :)
W
Давай пока без треша, ладно.
W
Бывает. Признание проблемы - половина решения ее ))
W
Давайте так... Терминология:
Шард - процесс который умеет слушать коннекты и по заданию из коннекта искать то что вам надо внутри своих данных.
Аггрегатор - процесс который принимает запросы от пользователя (системы) и разсылает запросы на шарды так, чтобы запрос выполнился на всем наборе данных и только один раз.
Шард - процесс который умеет слушать коннекты и по заданию из коннекта искать то что вам надо внутри своих данных.
Аггрегатор - процесс который принимает запросы от пользователя (системы) и разсылает запросы на шарды так, чтобы запрос выполнился на всем наборе данных и только один раз.
М
верно
YK
ну это как async-работа с бд (можно посмотреть async DBD::Pg) - в одном соединении можно обработать только один запрос, если соединение занято, то нужно брать следующее из пула или открывать новое
W
От одного аггрегатора может быть только один коннект к конкретному шарду, верно?..
М
W
Почему?
М
один агрегатор коннектится ко всем шардам. он же должен получить списки подходящих блоков со всех них
AP
я извиняюсь, что вклиниваюсь в научный спор, но может быть вам просто нужен Gearman?
М
ааааа
М
верно
М
можно сделать пул коннектов 😊
W
Не надо.
W
Получается что у шарда может быть до "кол-во аггрегаторов" коннектов, так? (Тут как настроите)