RedisHelperTest

RedisStudyTest/RedisHelperTest.cs

@@ -3,6 +3,7 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using System.Net;
 using Xunit;
 using Xunit.Extensions;
 using Xunit.Abstractions;
@@ -17,6 +18,29 @@ namespace RedisStudyTest
 {
     public class RedisHelperTest
     {
+        [Fact]
+        public void ConnectionMultiplexer_Singleton_Test()
+        {
+            var connect = RedisHelper.GetConnectionMultiplexer();
+            var connect2 = RedisHelper.GetConnectionMultiplexer();
+
+            Assert.Same(connect, connect2);
+        }
+
+        [Fact]
+        public void ConnectionMultiplexerTest()
+        {
+            var connectionMultiplexer = RedisHelper.GetConnectionMultiplexer();
+
+            Assert.NotNull(connectionMultiplexer);
+
+            //验证配置项
+            var options = ConfigurationOptions.Parse(connectionMultiplexer.Configuration);
+            Assert.Equal(200, options.KeepAlive);
+            Assert.Equal(1, options.DefaultDatabase);
+            Assert.True(options.AllowAdmin);
+            Assert.Contains(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6379), options.EndPoints);
+        }
 
         [Fact]
         public void GetRedisDatabaseTest()
@@ -31,9 +55,17 @@ namespace RedisStudyTest
         [Fact]
         public void GetRedisDatabaseTest2()
         {
-            var db = RedisHelper.GetConnectionMultiplexer();
-            var db2 = RedisHelper.GetConnectionMultiplexer();
-            Assert.Equal(db, db2);
+            var db = RedisHelper.GetRedisDatabase(-1);
+            Assert.Equal(0, db.Database);
+
+            db = RedisHelper.GetRedisDatabase(16);
+            Assert.Equal(0, db.Database);
+
+            db = RedisHelper.GetRedisDatabase();
+            Assert.Equal(1, db.Database);
+
+            db = RedisHelper.GetRedisDatabase(1);
+            Assert.Equal(1, db.Database);
         }
 
         [Fact]
@@ -43,5 +75,14 @@ namespace RedisStudyTest
 
             Assert.NotNull(redisServer);
         }
+
+        [Fact]
+        public void GetAllServerTest()
+        {
+            var redisServer = RedisHelper.GetAllRedisServer();
+
+            Assert.NotNull(redisServer);
+            Assert.Single(redisServer);
+        }
     }
 }

RedisStuy/RedisHelper.cs

@@ -15,7 +15,6 @@ namespace RedisStuy
     /// </summary>
     public sealed class RedisHelper
     {
-
         private static readonly IConnectionMultiplexer connectionMultiplexer = IniConnection();
 
         private static IConnectionMultiplexer IniConnection()
@@ -44,7 +43,6 @@ namespace RedisStuy
             return connectionMultiplexer;
         }
 
-
         /// <summary>
         /// 获取 默认Reids服务器
         /// </summary>