У меня есть простой код, который подписывается на канал, получает одно сообщение и затем отписывается.
Я использую Stackexchange.Redis
, который, насколько я вижу, имеет одно соединение с Redis для подписок.
Метод, который я описал, будет вызываться несколькими потоками одновременно, и канал является динамическим c. Меня интересует, что произойдет, если один из потоков не сможет выполнить отписку (например, из-за исключения).
Если это будет продолжаться, у меня будет много бесполезных устаревших подписок, которых никто не имеет. прослушивание, поскольку, насколько я понимаю, подписка не закрывается после того, как ChannelMessageQueue
выходит из области видимости и в конечном итоге собирается мусором.
Есть ли хороший способ справиться с этой ситуацией?