Я хочу получать данные в реальном времени с помощью redis pub / sub. Производитель продолжает публиковать данные в Redis. И потребитель подписывается на это; Но я обнаружил, что при закрытии моей производственной программы все еще будет обрабатываться много данных. Поэтому я решил изменить размер очереди Redis, как я могу это сделать?