Abp.Runtime.Caching.Redis.AbpRedisCacheDatabaseProvider.GetDatabase() on a clustered redis #12404

6 Answer(s)

• 

  0

  oguzhanagir created one year ago

  Support Team

  Hi @pliaspzero

  Can you share the Connection String structure with us after hiding the private fields? It should be in the following structure.

  "Abp": {
    "RedisCache": {
      "ConnectionString": "your.redis.server:6379,password=yourpassword,ssl=True",
      "DatabaseId": 0
    }
  }
  

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel
• 

  0

  pliaspzero created one year ago

  Hi,

  yes - done like that - I even try this own configuration - still no luck:

                      var redisOptions = new ConfigurationOptions
                      {
                          EndPoints = { "<myServer>redns.redis-cloud.com:18070" },
                          User = "default",
                          Password = "mYPassword",
                          Ssl = true,
                          SslHost = "<myServer>redns.redis-cloud.com",
                          AbortOnConnectFail = false
                      };
  

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel
• 

  0

  pliaspzero created one year ago

  working:

                      var muxer = ConnectionMultiplexer.Connect(
                         new ConfigurationOptions
                         {
                             EndPoints = { { "myRedis.redns.redis-cloud.com", 18070 } },
                             User = "default",
                             Password = "MyPassword"
                         }
                     );
  
                     var db = muxer.GetDatabase(0); // or your actual DB ID
  
                     // Write a test key
                     db.StringSet("test:key", "Hello from .NET");
  
                     // Read it back
                     string value = db.StringGet("test:key");
  

  – NOT WORKING - BUT I NEED THIS

                      var redisOptions = new ConfigurationOptions
                     {
                         EndPoints = { "myRedis.redns.redis-cloud.com:18071" },
                         User = "default",
                         Password = "MyPassword",
                         AbortOnConnectFail = false,
                         ConnectTimeout = 10000,
                         SyncTimeout = 10000,
                         AsyncTimeout = 10000,
                         DefaultDatabase = 0,
                         Ssl = true,
                         SslHost = "myRedis.redns.redis-cloud.com"
                     };
  
  
  
                      services.AddSignalR().AddStackExchangeRedis(options =>
                     {
                         options.Configuration = redisOptions;
                     });
  

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel
• 

  0

  oguzhanagir created one year ago

  Support Team

  Hi @pliaspzero

  Can you configure your Redis and SignalR settings as specified in the sample code below and check if this works in your scenario?

  var redisOptions = new ConfigurationOptions
  {
      EndPoints = { "myRedis.redns.redis-cloud.com:18071" },
      User = "default",
      Password = "MyPassword",
      AbortOnConnectFail = false,
      ConnectTimeout = 10000,
      SyncTimeout = 10000,
      AsyncTimeout = 10000,
      DefaultDatabase = 0,
      Ssl = true,
      SslHost = "myRedis.redns.redis-cloud.com"
  };
  
  services.AddSignalR().AddStackExchangeRedis(redisOptions.EndPoints.ToString(), options =>
  {
      options.ConnectionFactory = async writer =>
      {
          return await ConnectionMultiplexer.ConnectAsync(redisOptions, writer);
      };
  });
  

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel
• 

  0

  pliaspzero created one year ago

  Hi,

  thanks - still no luck - same error - Chat proposed me this - what do you think?

  1. CustomAbpRedisCacheDatabaseProvider.cs

  public class CustomAbpRedisCacheDatabaseProvider : IAbpRedisCacheDatabaseProvider { private readonly Lazy<IDatabase> _database;

  public CustomAbpRedisCacheDatabaseProvider(IConfiguration configuration)
  {
      _database = new Lazy<IDatabase>(() =>
      {
          var redisConnectionString = configuration["Abp:RedisCache:ConnectionString"];
          var redisPassword = configuration["Abp:RedisCache:RedisPassword"];
          var redisDatabaseId = configuration.GetValue<int>("Abp:RedisCache:DatabaseId");
  
          var options = new ConfigurationOptions
          {
              EndPoints = { redisConnectionString },
              Password = redisPassword,
              DefaultDatabase = redisDatabaseId,
              Ssl = true,
              AbortOnConnectFail = false,
              ClientName = "AbpRedisCache"
          };
  
          // Zertifikat laden
          var baseCertPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Certificates");
          var caCertPath = Path.Combine(baseCertPath, configuration["Abp:RedisCache:CaCertificateFile"]);
          var caCertificates = new X509Certificate2Collection();
          caCertificates.ImportFromPemFile(caCertPath);
  
          options.CertificateValidation += (sender, cert, chain, errors) =>
          {
              var cust_chain = new X509Chain();
              cust_chain.ChainPolicy.RevocationMode = X509RevocationMode.NoCheck;
              cust_chain.ChainPolicy.TrustMode = X509ChainTrustMode.CustomRootTrust;
              cust_chain.ChainPolicy.CustomTrustStore.AddRange(caCertificates);
              return cust_chain.Build(new X509Certificate2(cert));
          };
  
          var muxer = ConnectionMultiplexer.Connect(options);
          return muxer.GetDatabase();
      });
  }
  
  public IDatabase GetDatabase()
  {
      return _database.Value;
  }
  

  }

  2. Registrierung in deinem Startup-Modul

  context.Services.Replace( ServiceDescriptor.Singleton<IAbpRedisCacheDatabaseProvider, CustomAbpRedisCacheDatabaseProvider>() );

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel
• 

  0

  oguzhanagir created one year ago

  Support Team

  Hi @pliaspzero

  You can make certificate settings in Startup. It would be more correct to make Redis database settings in the PreInitialize method of the WebCore module class. However, the method you specified can also be used in Startup. Make sure that the connection string and certificate paths are correct here.

  Test Redis with ping:

  var isConnected = muxer.GetDatabase().Ping();
  

  Define the ConfigureRedis Method: You can configure the Redis connection settings in the ConfigureRedis() method, including the certificate selection.

  You can add the following to your Startup.cs file.

  public IServiceProvider ConfigureServices(IServiceCollection services)
  {
      //...
  
      services.AddSingleton< IConnectionMultiplexer >(provider => ConfigureRedis());
  }
  

  private IConnectionMultiplexer ConfigureRedis()
  {
      var redisConfig = new ConfigurationOptions
      {
          Ssl = true,
          AllowAdmin = true,
          AbortOnConnectFail = false,
      };
  
      // Load certificates for secure connection
      redisConfig.CertificateSelection += (sender, targetHost, localCertificates, remoteCertificate, acceptableIssuers) =>
      {
          // Load the client certificate (redis-client-cert.pem) and client private key (redis-client-key.pem)
          var cert = new X509Certificate2("path/to/redis-client-cert.pfx", "your-cert-password", X509KeyStorageFlags.MachineKeySet);
  
          // Load the CA certificate (ca-cert.pem)
          var caCert = new X509Certificate2("path/to/ca-cert.pem");
  
          // Add the CA certificate to the certificate collection
          localCertificates.Add(caCert);
  
          return cert;
      };
  
      return ConnectionMultiplexer.Connect(redisConfig);
  }
  

  Markdown is supported

  Copy & paste or drag & drop images (max 30 MB per image)

  Save Cancel