Вместо това можете да използвате два списъка за този тип разпределен шаблон. Предлагам това главно поради естеството на PubSub да „застреля и забрави“, без да гарантира доставка. Предполагам, че във вашия случай не искате това.
Ето предложения поток – първо ще трябва да настроите два блокиращи „слушатели“:
- Сървър1:
BRPOP completed
- Сървър2:
BRPOP requests
След това, когато потребител влезе:
- Сървър1:
LPUSH requests data
- Сървър2:деблокира, обработва данни,
LPUSH completed data
и се върнете към блокиране на поп - Сървър1:деблокира, прави каквото и да е, върнете се към блокиране на изскачане