添加excel模块

Yi.Framework.Net6/src/module/Yi.Framework.Caching.Redis/RedisCacheClient.cs

@@ -0,0 +1,165 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.DependencyInjection;
+using StartupModules;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Yi.Framework.Caching;
+using Microsoft.Extensions.Options;
+using Yi.Framework.Caching.Redis;
+using static CSRedis.CSRedisClient;
+using CSRedis;
+
+namespace Yi.Framework.Caching.Redis
+{
+    public class RedisCacheClient : CacheManager
+    {
+        private readonly CachingConnOptions _RedisOptions;
+
+        private CSRedisClient _client;
+
+        public RedisCacheClient(IOptionsMonitor<CachingConnOptions> redisConnOptions)
+        {
+            this._RedisOptions = redisConnOptions.CurrentValue;
+            _client = new CSRedisClient($"{_RedisOptions.Host}:{_RedisOptions.Prot},password={_RedisOptions.Password},defaultDatabase ={_RedisOptions.DB}");
+        }
+        public override bool Exits(string key)
+        {
+            return _client.Exists(key);
+        }
+        public override T Get<T>(string key)
+        {
+            return _client.Get<T>(key);
+        }
+
+        public override bool Set<T>(string key, T data, TimeSpan time)
+        {
+            return _client.Set(key, data, time);
+        }
+
+        public override bool Set<T>(string key, T data)
+        {
+            return _client.Set(key, data);
+        }
+
+        public override long Del(string key)
+        {
+            return _client.Del(key);
+        }
+
+        public override bool HSet(string key, string fieId, object data)
+        {
+            return _client.HSet(key, fieId, data);
+        }
+
+        public override bool HSet(string key, string fieId, object data, TimeSpan time)
+        {
+            var res = _client.HSet(key, fieId, data);
+            var res2 = _client.Expire(key, time);
+            return res && res2;
+        }
+
+        public override T HGet<T>(string key, string field)
+        {
+            return _client.HGet<T>(key, field);
+        }
+
+
+        public override long HDel(string key, params string[] par)
+        {
+            return _client.HDel(key, par);
+        }
+
+        public override long HLen(string key)
+        {
+            return _client.HLen(key);
+        }
+
+        public override Dictionary<string, string> HGetAll(string key)
+        {
+            return _client.HGetAll(key);
+        }
+
+        /// <summary>
+        /// 简单发布
+        /// </summary>
+        /// <param name="channel"></param>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        public override long Publish(string channel, string message)
+        {
+            return _client.Publish(channel, message);
+        }
+
+        /// <summary>
+        /// 简单订阅：广播，无持久化，需要Publish写入队列
+        /// </summary>
+        /// <param name="channels"></param>
+        /// <returns></returns>
+        public  SubscribeObject Subscribe(params (string, Action<SubscribeMessageEventArgs>)[] channels)
+        {
+            return _client.Subscribe(channels);
+        }
+
+        /// <summary>
+        /// 多端争抢模式订阅，需要Lpush写入队列
+        /// </summary>
+        /// <param name="listKey"></param>
+        /// <param name="onMessage"></param>
+        /// <returns></returns>
+        public  SubscribeListObject SubscribeList(string listKey, Action<string> onMessage)
+        {
+            return _client.SubscribeList(listKey, onMessage);
+        }
+
+        /// <summary>
+        /// 多端非争抢模式订阅，需要Lpush写入队列
+        /// </summary>
+        /// <param name="listKey"></param>
+        /// <param name="clientId"></param>
+        /// <param name="onMessage"></param>
+        /// <returns></returns>
+        public  SubscribeListBroadcastObject SubscribeListBroadcast(string listKey, string clientId, Action<string> onMessage)
+        {
+            return _client.SubscribeListBroadcast(listKey, clientId, onMessage);
+        }
+
+        public override bool LSet(string key, long index, object value)
+        {
+            return _client.LSet(key, index, value);
+        }
+
+
+
+        /// <summary>
+        /// 列表插入头部
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public override long LPush<T>(string key, params T[] value)
+        {
+            return _client.LPush<T>(key, value);
+        }
+
+        /// <summary>
+        /// 列表弹出头部
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public override T LPop<T>(string key)
+        {
+            return _client.LPop<T>(key);
+        }
+
+        public override string[] Keys(string pattern)
+        {
+            return _client.Keys(pattern);
+        }
+
+    }
+}

Yi.Framework.Net6/src/module/Yi.Framework.Caching.Redis/Yi.Framework.Caching.Redis.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="CSRedisCore" Version="3.8.670" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\framework\Yi.Framework.Core\Yi.Framework.Core.csproj" />
+    <ProjectReference Include="..\Yi.Framework.Caching\Yi.Framework.Caching.csproj" />
+  </ItemGroup>
+
+</Project>

Yi.Framework.Net6/src/module/Yi.Framework.Caching.Redis/YiFrameworkCachingRedisModule.cs

@@ -0,0 +1,22 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.DependencyInjection;
+using StartupModules;
+using Yi.Framework.Core.Configuration;
+
+namespace Yi.Framework.Caching.Redis
+{
+
+    public class YiFrameworkCachingRedisModule : IStartupModule
+    {
+        public void Configure(IApplicationBuilder app, ConfigureMiddlewareContext context)
+        {
+        }
+
+        public void ConfigureServices(IServiceCollection services, ConfigureServicesContext context)
+        {
+            services.Configure<CachingConnOptions>(Appsettings.appConfiguration("CachingConnOptions"));
+            services.AddSingleton<CacheManager, RedisCacheClient>();
+        }
+    }
+
+}