Booksleeve로 열린 Redis PubSub 구독 유지

Question

Redis pubsub 채널을 사용하여 작업자 프로세스 풀에서 ASP.NET 응용 프로그램으로 메시지를 보냅니다. 메시지가 수신되면, 어플리케이션은 SignalR로 클라이언트의 브라우저로 메시지를 전달합니다.

Redis에 열린 연결을 유지하기 위해 this solution을 찾았지만 연결을 다시 만들 때 구독을 고려하지 않습니다.

나는 현재 내에서 Global.asax 파일에 레디 스의 pubsub 메시지를 처리 ​​해요 :

public class Application : HttpApplication 
{ 
    protected void Application_Start() 
    { 
     var gateway = Resolve<RedisConnectionGateway>(); 
     var connection = gateway.GetConnection(); 
     var channel = connection.GetOpenSubscriberChannel(); 

     channel.PatternSubscribe("workers:job-done:*", OnExecutionCompleted); 
    } 

    /// <summary> 
    /// Handle messages received from workers through Redis.</summary> 
    private static void OnExecutionCompleted(string key, byte[] message) 
    { 
     /* forwarded the response to the client that requested it */ 
    } 
} 

현재 RedisConnection가 어떤 이유로 폐쇄 될 때 문제가 발생합니다. 가장 간단한 해결책은 연결이 재설정되었을 때 RedisConnectionGateway 클래스에서 이벤트를 시작하고 새로운 RedisSubscriberChannel을 사용하여 다시 구독하는 것입니다. 그러나 연결이 재설정되는 동안 채널에 게시 된 모든 메시지는 손실됩니다.

이 상황을 처리하는 데 권장되는 방법의 예가 있습니까?

Answer 1

예, 연결이 끊어지면 (네트워크 불안정성, 재 마스터링 등) 사용자가 만든 모든 구독을 다시 적용해야합니다. 다시 연결하고 다시 가입하는 이벤트는 매우 정상적이며 여기서는 SE/SO에서 사용하는 것과 매우 다르지 않습니다 (일반적으로 더 세분화 된 구독을 추적하고 모든 것을 처리하는 래퍼 코드가 있음).

예, 연결이 끊어진 동안 게시 된 모든 이벤트가 사라졌습니다. 저것은 redis pub/sub의 본질이다; 연결이 끊어진 클라이언트에 대한 배달을 보장하지는 않습니다. 이 이것을 약속하거나 redis를 사용하여 대기열을 구동하는 대신 목록의 반대쪽으로 /에서 터벅 터벅 터벅으로 이동하는 것은 일반적으로 합리적인 대안이며 손실되지 않도록합니다 (소프트웨어가 ' 목록에서 그것을 터뜨린 후 드롭하십시오). 도움이된다면 블로킹 팝 방법을 추가하라는 요청을 내 목록에 올렸습니다. 멀티플렉서의 의도를 완전히 파기했지만 어떤 경우에는 진정한 용도로 사용하기 때문에 추가하는 것이 아닙니다.