上传项目

.gitignore

@@ -0,0 +1,13 @@
+################################################################################
+# 此 .gitignore 文件已由 Microsoft(R) Visual Studio 自动创建。
+################################################################################
+
+/DemoRedis/DemoRedis01/obj
+/DemoRedis/DemoRedis01/bin/Debug/netcoreapp2.0
+/DemoRedis/DemoRedis01
+/DemoRedis/DemoRedis00/obj
+/DemoRedis/DemoRedis00/bin/Debug/netcoreapp2.0
+/DemoRedis/DemoRedis00
+/DemoRedis/.vs
+/DemoRedis
+/.vs

DemoRedis/DemoRedis.sln

@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 15
+VisualStudioVersion = 15.0.27130.2024
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DemoRedis01", "DemoRedis01\DemoRedis01.csproj", "{FB4BAB46-35BD-443B-BB08-FFDD3D69D982}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DemoRedis00", "DemoRedis00\DemoRedis00.csproj", "{9039E667-C9E2-4F8B-8E17-2751404062E3}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{FB4BAB46-35BD-443B-BB08-FFDD3D69D982}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FB4BAB46-35BD-443B-BB08-FFDD3D69D982}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FB4BAB46-35BD-443B-BB08-FFDD3D69D982}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{FB4BAB46-35BD-443B-BB08-FFDD3D69D982}.Release|Any CPU.Build.0 = Release|Any CPU
+		{9039E667-C9E2-4F8B-8E17-2751404062E3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{9039E667-C9E2-4F8B-8E17-2751404062E3}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{9039E667-C9E2-4F8B-8E17-2751404062E3}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{9039E667-C9E2-4F8B-8E17-2751404062E3}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {46487A81-74EA-43A0-A229-76943410C93D}
+	EndGlobalSection
+EndGlobal

DemoRedis/DemoRedis00/DemoRedis00.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.5" />
+    <PackageReference Include="StackExchange.Redis.StrongName" Version="1.2.6" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Reference Include="Microsoft.Extensions.Configuration.Abstractions">
+      <HintPath>C:\Program Files\dotnet\sdk\NuGetFallbackFolder\microsoft.extensions.configuration.abstractions\2.0.0\lib\netstandard2.0\Microsoft.Extensions.Configuration.Abstractions.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+
+</Project>

DemoRedis/DemoRedis00/Program.cs

@@ -0,0 +1,32 @@
+using System;
+using System.IO;
+using Microsoft.Extensions.Configuration;
+
+namespace DemoRedis00
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            var builder = new ConfigurationBuilder()
+             .SetBasePath(Directory.GetCurrentDirectory())
+             .AddJsonFile("appsettings.json");
+            IConfiguration configuration = builder.Build();
+
+            var redisClient = RedisClientSingleton.GetInstance(configuration);
+            var redisDatabase = redisClient.GetDatabase("Redis_Default");
+
+            //redisDatabase.StringSet("TestStrKey", "TestStrValue");
+
+            Console.WriteLine($"写入值redisDatabase.StringSet()  {redisDatabase.StringSet("TestStrKey", "TestStrValue")}");
+            Console.WriteLine($"写入值异步redisDatabase.StringSetAsync()  {redisDatabase.StringSetAsync("TestStrKey", "TestStrValue").Result}");
+            Console.WriteLine($"获取值 redisDatabase.StringGet()  {redisDatabase.StringGet("TestStrKey")}");
+            Console.WriteLine($"获取值异步 redisDatabase.StringGetAsync()  {redisDatabase.StringGetAsync("TestStrKey").Result}");
+
+
+
+
+            Console.ReadKey();
+        }
+    }
+}

DemoRedis/DemoRedis00/RedisClient.cs

@@ -0,0 +1,107 @@
+
+using Microsoft.Extensions.Configuration;
+using StackExchange.Redis;
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace DemoRedis00
+{
+    public class RedisClient : IDisposable
+    {
+        private IConfiguration _config;
+        private ConcurrentDictionary<string, ConnectionMultiplexer> _connections;
+        public RedisClient(IConfiguration config)
+        {
+            _config = config;
+            _connections = new ConcurrentDictionary<string, ConnectionMultiplexer>();
+        }
+        /// <summary>
+        /// 获取ConnectionMultiplexer
+        /// </summary>
+        /// <param name="redisConfig">RedisConfig配置文件</param>
+        /// <returns></returns>
+        private ConnectionMultiplexer GetConnect(IConfigurationSection redisConfig)
+        {
+            var redisInstanceName = redisConfig["InstanceName"];
+            var connStr = redisConfig["Connection"];
+            return _connections.GetOrAdd(redisInstanceName, p => ConnectionMultiplexer.Connect(connStr));
+        }
+        /// <summary>
+        /// 检查入参数
+        /// </summary>
+        /// <param name="configName">RedisConfig配置文件中的 Redis_Default/Redis_6 名称</param>
+        /// <returns></returns>
+        private IConfigurationSection CheckeConfig(string configName)
+        {
+            IConfigurationSection redisConfig = _config.GetSection("RedisConfig").GetSection(configName);
+            if (redisConfig == null)
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的RedisConfig配置！");
+            }
+            var redisInstanceName = redisConfig["InstanceName"];
+            var connStr = redisConfig["Connection"];
+            if (string.IsNullOrEmpty(redisInstanceName))
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的InstanceName");
+            }
+            if (string.IsNullOrEmpty(connStr))
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的Connection");
+            }
+            return redisConfig;
+        }
+        /// <summary>
+        /// 获取数据库
+        /// </summary>
+        /// <param name="configName"></param>
+        /// <param name="db">默认为0：优先代码的db配置，其次config中的配置</param>
+        /// <returns></returns>
+        public IDatabase GetDatabase(string configName = null, int? db = null)
+        {
+            int defaultDb = 0;
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            if (db.HasValue)
+            {
+                defaultDb = db.Value;
+            }
+            else
+            {
+                var strDefalutDatabase = redisConfig["DefaultDatabase"];
+                if (!string.IsNullOrEmpty(strDefalutDatabase) && Int32.TryParse(strDefalutDatabase, out var intDefaultDatabase))
+                {
+                    defaultDb = intDefaultDatabase;
+                }
+            }
+            return GetConnect(redisConfig).GetDatabase(defaultDb);
+        }
+
+        public IServer GetServer(string configName = null, int endPointsIndex = 0)
+        {
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            var connStr = redisConfig["Connection"];
+
+            var confOption = ConfigurationOptions.Parse((string)connStr);
+            return GetConnect(redisConfig).GetServer(confOption.EndPoints[endPointsIndex]);
+        }
+
+        public ISubscriber GetSubscriber(string configName = null)
+        {
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            return GetConnect(redisConfig).GetSubscriber();
+        }
+
+        public void Dispose()
+        {
+            if (_connections != null && _connections.Count > 0)
+            {
+                foreach (var item in _connections.Values)
+                {
+                    item.Close();
+                }
+            }
+        }
+    }
+}

DemoRedis/DemoRedis00/RedisClientSingleton.cs

@@ -0,0 +1,30 @@
+using Microsoft.Extensions.Configuration;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace DemoRedis00
+{
+    public class RedisClientSingleton
+    {
+        private static RedisClient _redisClinet;
+        private RedisClientSingleton() { }
+
+        private static object _lockObj = new object();
+        public static RedisClient GetInstance(IConfiguration config)
+        {
+            if (_redisClinet == null)
+            {
+                lock (_lockObj)
+                {
+                    if (_redisClinet == null)
+                    {
+                        _redisClinet = new RedisClient(config);
+                    }
+                }
+            }
+            return _redisClinet;
+        }
+    }
+}

DemoRedis/DemoRedis00/appsettings.json

@@ -0,0 +1,13 @@
+{
+  "RedisConfig": {
+    "Redis_Default": {
+      "Connection": "127.0.0.1:6379",
+      "InstanceName": "Redis1:"
+    },
+    "Redis_6": {
+      "Connection": "127.0.0.1:6379",
+      "DefaultDatabase": 6,
+      "InstanceName": "Redis2:"
+    }
+  }
+}

DemoRedis/DemoRedis01/Controllers/ValuesController.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Configuration;
+using StackExchange.Redis;
+
+namespace DemoRedis01.Controllers
+{
+    [Route("[controller]/[action]")]
+    public class ValuesController : Controller
+    {
+        private IConfiguration _configuration;
+        private IDatabase _redisDatabase;
+        public ValuesController(IConfiguration configuration)
+        {
+            _configuration = configuration;
+            var redisClient = RedisClientSingleton.GetInstance(_configuration);
+            _redisDatabase = redisClient.GetDatabase("Redis_Default");
+        }
+        public string Set(string key, string value)
+        {
+            var flag = _redisDatabase.StringSet(key, value);
+            return $"写入值 {flag.ToString()} ";
+        }
+
+        public string Get(string key)
+        {
+            var value = _redisDatabase.StringGet(key);
+            return $"获取值 {value}";
+        }
+
+        public async Task<string> SetAsync(string key, string value)
+        {
+            var flag = await _redisDatabase.StringSetAsync(key, value);
+            return $"写入值 {flag.ToString()}";
+        }
+
+        public async Task<string> GetAsync(string key)
+        {
+            var value = await _redisDatabase.StringGetAsync(key);
+            return $"获取值 {value}";
+        }
+    }
+}

DemoRedis/DemoRedis01/DemoRedis01.csproj

@@ -0,0 +1,20 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Folder Include="wwwroot\" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.5" />
+    <PackageReference Include="StackExchange.Redis.StrongName" Version="1.2.6" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <DotNetCliToolReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Tools" Version="2.0.2" />
+  </ItemGroup>
+
+</Project>

DemoRedis/DemoRedis01/DemoRedis01.csproj.user

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
+    <DebuggerFlavor>ProjectDebugger</DebuggerFlavor>
+  </PropertyGroup>
+  <PropertyGroup>
+    <ActiveDebugProfile>DemoRedis01</ActiveDebugProfile>
+  </PropertyGroup>
+</Project>

DemoRedis/DemoRedis01/Program.cs

@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace DemoRedis01
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            BuildWebHost(args).Run();
+        }
+
+        public static IWebHost BuildWebHost(string[] args) =>
+            WebHost.CreateDefaultBuilder(args)
+                .UseStartup<Startup>()
+                .Build();
+    }
+}

DemoRedis/DemoRedis01/Properties/launchSettings.json

@@ -0,0 +1,29 @@
+{
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:24617/",
+      "sslPort": 0
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "api/values",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "DemoRedis01": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "api/values",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "applicationUrl": "http://localhost:24618/"
+    }
+  }
+}

DemoRedis/DemoRedis01/RedisClient.cs

@@ -0,0 +1,107 @@
+
+using Microsoft.Extensions.Configuration;
+using StackExchange.Redis;
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace DemoRedis01
+{
+    public class RedisClient : IDisposable
+    {
+        private IConfiguration _config;
+        private ConcurrentDictionary<string, ConnectionMultiplexer> _connections;
+        public RedisClient(IConfiguration config)
+        {
+            _config = config;
+            _connections = new ConcurrentDictionary<string, ConnectionMultiplexer>();
+        }
+        /// <summary>
+        /// 获取ConnectionMultiplexer
+        /// </summary>
+        /// <param name="redisConfig">RedisConfig配置文件</param>
+        /// <returns></returns>
+        private ConnectionMultiplexer GetConnect(IConfigurationSection redisConfig)
+        {
+            var redisInstanceName = redisConfig["InstanceName"];
+            var connStr = redisConfig["Connection"];
+            return _connections.GetOrAdd(redisInstanceName, p => ConnectionMultiplexer.Connect(connStr));
+        }
+        /// <summary>
+        /// 检查入参数
+        /// </summary>
+        /// <param name="configName">RedisConfig配置文件中的 Redis_Default/Redis_6 名称</param>
+        /// <returns></returns>
+        private IConfigurationSection CheckeConfig(string configName)
+        {
+            IConfigurationSection redisConfig = _config.GetSection("RedisConfig").GetSection(configName);
+            if (redisConfig == null)
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的RedisConfig配置！");
+            }
+            var redisInstanceName = redisConfig["InstanceName"];
+            var connStr = redisConfig["Connection"];
+            if (string.IsNullOrEmpty(redisInstanceName))
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的InstanceName");
+            }
+            if (string.IsNullOrEmpty(connStr))
+            {
+                throw new ArgumentNullException($"{configName}找不到对应的Connection");
+            }
+            return redisConfig;
+        }
+        /// <summary>
+        /// 获取数据库
+        /// </summary>
+        /// <param name="configName"></param>
+        /// <param name="db">默认为0：优先代码的db配置，其次config中的配置</param>
+        /// <returns></returns>
+        public IDatabase GetDatabase(string configName = null, int? db = null)
+        {
+            int defaultDb = 0;
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            if (db.HasValue)
+            {
+                defaultDb = db.Value;
+            }
+            else
+            {
+                var strDefalutDatabase = redisConfig["DefaultDatabase"];
+                if (!string.IsNullOrEmpty(strDefalutDatabase) && Int32.TryParse(strDefalutDatabase, out var intDefaultDatabase))
+                {
+                    defaultDb = intDefaultDatabase;
+                }
+            }
+            return GetConnect(redisConfig).GetDatabase(defaultDb);
+        }
+
+        public IServer GetServer(string configName = null, int endPointsIndex = 0)
+        {
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            var connStr = redisConfig["Connection"];
+
+            var confOption = ConfigurationOptions.Parse((string)connStr);
+            return GetConnect(redisConfig).GetServer(confOption.EndPoints[endPointsIndex]);
+        }
+
+        public ISubscriber GetSubscriber(string configName = null)
+        {
+            IConfigurationSection redisConfig = CheckeConfig(configName);
+            return GetConnect(redisConfig).GetSubscriber();
+        }
+
+        public void Dispose()
+        {
+            if (_connections != null && _connections.Count > 0)
+            {
+                foreach (var item in _connections.Values)
+                {
+                    item.Close();
+                }
+            }
+        }
+    }
+}

DemoRedis/DemoRedis01/RedisClientSingleton.cs

@@ -0,0 +1,30 @@
+using Microsoft.Extensions.Configuration;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace DemoRedis01
+{
+    public class RedisClientSingleton
+    {
+        private static RedisClient _redisClinet;
+        private RedisClientSingleton() { }
+
+        private static object _lockObj = new object();
+        public static RedisClient GetInstance(IConfiguration config)
+        {
+            if (_redisClinet == null)
+            {
+                lock (_lockObj)
+                {
+                    if (_redisClinet == null)
+                    {
+                        _redisClinet = new RedisClient(config);
+                    }
+                }
+            }
+            return _redisClinet;
+        }
+    }
+}

DemoRedis/DemoRedis01/Startup.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+
+namespace DemoRedis01
+{
+    public class Startup
+    {
+        public Startup(IConfiguration configuration)
+        {
+            Configuration = configuration;
+            //ConfigurationRoot = configurationRoot;
+        }
+
+        public IConfiguration Configuration { get; }
+        //public IConfiguration ConfigurationRoot { get; }
+
+        // This method gets called by the runtime. Use this method to add services to the container.
+        public void ConfigureServices(IServiceCollection services)
+        {
+            services.AddMvc();
+
+        }
+
+        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
+        {
+            if (env.IsDevelopment())
+            {
+                app.UseDeveloperExceptionPage();
+            }
+            
+            app.UseMvc();
+
+
+
+        }
+    }
+}

DemoRedis/DemoRedis01/appsettings.Development.json

@@ -0,0 +1,10 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Debug",
+      "System": "Information",
+      "Microsoft": "Information"
+    }
+  }
+}

DemoRedis/DemoRedis01/appsettings.json

@@ -0,0 +1,23 @@
+{
+
+  "Logging": {
+    "IncludeScopes": false,
+    "Debug": {
+      "LogLevel": {
+        "Default": "Warning"
+      }
+    },
+    "Console": {
+      "LogLevel": {
+        "Default": "Warning"
+      }
+    }
+  },
+  "RedisConfig": {
+    "Redis_Default": {
+      "Connection": "192.168.85.129: 9001",
+      "InstanceName": "Redis1: "
+
+    }
+  }
+}