Làm thế nào để ConnectionMultiplexer đối phó với ngắt kết nối?

Question

Tài liệu Basic Usage cho StackExchange.Redis giải thích rằng ConnectionMultiplexer là thời gian tồn tại lâu dài và dự kiến ​​sẽ được sử dụng lại.

Nhưng điều gì sẽ xảy ra khi kết nối với máy chủ bị hỏng? Liệu ConnectionMultiplexer tự động kết nối lại, hoặc là nó cần thiết để viết mã như trong this answer (trích dẫn câu trả lời):

 if (RedisConnection == null || !RedisConnection.IsConnected) 
     { 
      RedisConnection = ConnectionMultiplexer.Connect(...); 
     } 
     RedisCacheDb = RedisConnection.GetDatabase(); 

Là mã một cái gì đó ở trên tốt để xử lý phục hồi từ ngắt kết nối, hoặc nó sẽ thực sự dẫn đến nhiều ConnectionMultiplexer trường? Dọc theo cùng một dòng, làm thế nào nên các tài sản IsConnected được giải thích?

[Bên cạnh: Tôi tin rằng mã trên là một dạng khởi tạo lười biếng khá tệ, đặc biệt trong môi trường đa luồng - xem Jon Skeet's article on Singletons].

Answer 1

Đây là pattern recommended by the Azure Redis Cache team:

private static Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() => { 
    return ConnectionMultiplexer.Connect("mycache.redis.cache.windows.net,abortConnect=false,ssl=true,password=..."); 
}); 

public static ConnectionMultiplexer Connection { 
    get { 
     return lazyConnection.Value; 
    } 
} 

Một vài điểm quan trọng:

• Nó sử dụng Lazy <T> để xử lý thread-safe khởi
• Nó đặt "abortConnect = false", điều đó có nghĩa là nếu lần thử kết nối ban đầu không thành công, thì ConnectionMultiplexer sẽ âm thầm thử lại dưới nền thay vì ném một ngoại lệ.
• Nó không kiểm tra thuộc tính IsConnected, vì ConnectionMultiplexer sẽ tự động thử lại trong nền nếu kết nối bị ngắt.

Answer 2

Có, bạn cần loại xác minh đó để khắc phục các kết nối bị hỏng. Một số chủ đề an toàn cũng nên được yếu tố trong là tốt. Đây là cách tôi thường làm điều này:

private static ConnectionMultiplexer _redis; 
private static readonly Object _multiplexerLock = new Object(); 

private void ConnectRedis() 
{ 
    try 
    { 
     _redis = ConnectionMultiplexer.Connect("...<connection string here>..."); 
    } 
    catch (Exception ex) 
    { 
     //exception handling goes here 
    } 
} 


private ConnectionMultiplexer RedisMultiplexer 
{ 
    get 
    { 
     lock (_multiplexerLock) 
     { 
      if (_redis == null || !_redis.IsConnected) 
      { 
       ConnectRedis(); 
      } 
      return _redis; 
     } 
    } 
} 

Sau đó, tôi sử dụng RedisMultiplexer sở hữu ở khắp mọi nơi tôi cần phải gọi endpoint Redis. Tôi thường không lưu trữ kết quả của cuộc gọi GetDatabase() vì tài liệu cho biết đó là một cuộc gọi khá nhẹ.