История изменений
Исправление ya-betmen, (текущая версия) :
У тебя есть хранилище с очередью задач и очередями ответов. К нему могут цепляться клиенты и воркеры. Клиент открывает стрим и кидает задачу в хранилище, хранилище рассылает уведомдение воркерам, что есть таска, воркеры приходят и первый получает первую из списка и идет делать. Когда он закончит, то пришлёт в хранилище где искать ответ, и получит следующую задачу. Клиент если подцеплен к хранилищу получит уведомдение. Если он отпадал то когда прицепится - получит все ответы, которые продолбал.
Ты можешь цеплять/отцеплять и клиентов и воркеры. Опционально можно сложить таски и ответы в редис, чтобы пережить падение.
Исходная версия ya-betmen, :
У тебя есть хранилище с очередью задач и очередями ответов. К нему могут цепляться клиенты и воркеры. Клиент открывает стрим и кидает задачу в хранилище, хранилище рассылает уведомдение воркерам, что есть таска, воркеры приходят и первый получает мервую из списка и идет делать. Когда он закончит, то пришлёт в хранилище где искать ответ, и получит следующую задачу. Клиент если подцеплен к хранилищу получит уведомдение. Если он отпадал то когда прицепится - получит все ответы, которые продолбал.
Ты можешь цеплять/отцеплять и клиентов и воркеры. Опционально можно сложить таски и ответы в редис, чтобы пережить падение.