From 5571369af74927743905dfb6eedc1786afc6fab5 Mon Sep 17 00:00:00 2001 From: cli <377476583@qq.com> Date: Mon, 17 Mar 2025 08:35:19 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9A=82=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- readme.md | 4 +- .../EnergySystem/ICacheAppService.cs | 13 + .../CollectBusAppService.cs | 2 +- .../CollectBusApplicationModule.cs | 2 +- .../EnergySystem/CacheAppService.cs | 15 + .../BasicScheduledMeterReadingService.cs | 18 +- .../EnergySystems/Entities/TB_AmmeterInfo.cs | 259 ++++++++++++++++++ .../TableViews/V_FocusAmmeter.cs | 12 +- .../JiShe.CollectBus.Domain.csproj | 3 +- ...Module.cs => CollectBusFreeRedisModule.cs} | 7 +- .../FreeRedisProvider.cs | 47 ++++ .../FreeRedisProviderService.cs | 65 ----- .../IFreeRedisProvider.cs | 14 + .../IFreeRedisProviderService.cs | 30 -- 14 files changed, 373 insertions(+), 118 deletions(-) create mode 100644 src/JiShe.CollectBus.Application.Contracts/EnergySystem/ICacheAppService.cs create mode 100644 src/JiShe.CollectBus.Application/EnergySystem/CacheAppService.cs create mode 100644 src/JiShe.CollectBus.Domain/EnergySystems/Entities/TB_AmmeterInfo.cs rename src/JiShe.CollectBus.FreeRedisProvider/{FreeRedisProviderModule.cs => CollectBusFreeRedisModule.cs} (76%) create mode 100644 src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProvider.cs delete mode 100644 src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderService.cs create mode 100644 src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProvider.cs delete mode 100644 src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProviderService.cs diff --git a/readme.md b/readme.md index 28a0678..57cce20 100644 --- a/readme.md +++ b/readme.md @@ -17,7 +17,7 @@ - V4 → V5核心升级： - 微服务化架构改造 - 统一配置管理中心 - - 支持Kafka/RabbitMQ双引擎 + - 支持Kafka引擎 - 新增边缘计算能力 - 资源利用率提升40% @@ -82,7 +82,7 @@ Body: |----------------|------------|--------------| | 最大连接数 | 10,000 | 线性扩展 | | 数据处理延迟 | <50ms(p99) | - | -| 吞吐量 | 20,000 TPS | 百万级TPS | +| 吞吐量 | 20,000 TPS | 十万级TPS | | CPU利用率 | ≤70%@峰值 | 自动负载均衡 | ## 6. 高可用设计 diff --git a/src/JiShe.CollectBus.Application.Contracts/EnergySystem/ICacheAppService.cs b/src/JiShe.CollectBus.Application.Contracts/EnergySystem/ICacheAppService.cs new file mode 100644 index 0000000..629733d --- /dev/null +++ b/src/JiShe.CollectBus.Application.Contracts/EnergySystem/ICacheAppService.cs @@ -0,0 +1,13 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Volo.Abp.Application.Services; + +namespace JiShe.CollectBus.EnergySystem +{ + public interface ICacheAppService : IApplicationService + { + } +} diff --git a/src/JiShe.CollectBus.Application/CollectBusAppService.cs b/src/JiShe.CollectBus.Application/CollectBusAppService.cs index f45dda1..c634859 100644 --- a/src/JiShe.CollectBus.Application/CollectBusAppService.cs +++ b/src/JiShe.CollectBus.Application/CollectBusAppService.cs @@ -14,7 +14,7 @@ namespace JiShe.CollectBus; public abstract class CollectBusAppService : ApplicationService { public IFreeSqlProvider SqlProvider => LazyServiceProvider.LazyGetRequiredService(); - protected IFreeRedisProviderService FreeRedisProvider => LazyServiceProvider.LazyGetService()!; + protected IFreeRedisProvider FreeRedisProvider => LazyServiceProvider.LazyGetService()!; protected CollectBusAppService() { diff --git a/src/JiShe.CollectBus.Application/CollectBusApplicationModule.cs b/src/JiShe.CollectBus.Application/CollectBusApplicationModule.cs index 8078e48..4efe690 100644 --- a/src/JiShe.CollectBus.Application/CollectBusApplicationModule.cs +++ b/src/JiShe.CollectBus.Application/CollectBusApplicationModule.cs @@ -22,7 +22,7 @@ namespace JiShe.CollectBus; typeof(AbpDddApplicationModule), typeof(AbpAutoMapperModule), typeof(AbpBackgroundWorkersHangfireModule), - typeof(FreeRedisProviderModule), + typeof(CollectBusFreeRedisModule), typeof(CollectBusFreeSqlModule) )] public class CollectBusApplicationModule : AbpModule diff --git a/src/JiShe.CollectBus.Application/EnergySystem/CacheAppService.cs b/src/JiShe.CollectBus.Application/EnergySystem/CacheAppService.cs new file mode 100644 index 0000000..2a038a6 --- /dev/null +++ b/src/JiShe.CollectBus.Application/EnergySystem/CacheAppService.cs @@ -0,0 +1,15 @@ +using JiShe.CollectBus.IotSystems.Records; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Volo.Abp.Domain.Repositories; + +namespace JiShe.CollectBus.EnergySystem +{ + public class CacheAppService: CollectBusAppService,ICacheAppService + { + + } +} diff --git a/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs b/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs index 82a11ab..5ea6c6d 100644 --- a/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs +++ b/src/JiShe.CollectBus.Application/ScheduledMeterReading/BasicScheduledMeterReadingService.cs @@ -143,7 +143,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading keyValuePairs.TryAdd($"{ammeter.ID}", ammeter); } - await FreeRedisProvider.FreeRedis.HSetAsync(redisCacheKey, keyValuePairs); + await FreeRedisProvider.Instance.HSetAsync(redisCacheKey, keyValuePairs); } } @@ -158,7 +158,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading { //获取缓存中的电表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheAmmeterInfoKey, SystemTypeConst.Energy, 1)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(AmmeterScheduledMeterOneMinuteReading)} 1分钟采集电表数据处理时没有获取到缓存信息,-101"); @@ -187,7 +187,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading { //获取缓存中的电表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheAmmeterInfoKey, SystemTypeConst.Energy, 5)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(AmmeterScheduledMeterFiveMinuteReading)} 5分钟采集电表数据处理时没有获取到缓存信息,-101"); @@ -214,7 +214,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading { //获取缓存中的电表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheAmmeterInfoKey, SystemTypeConst.Energy, 15)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(AmmeterScheduledMeterFifteenMinuteReading)} 15分钟采集电表数据处理时没有获取到缓存信息,-101"); @@ -287,7 +287,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading keyValuePairs.TryAdd($"{subItem.ID}", subItem); } - await FreeRedisProvider.FreeRedis.HSetAsync(redisCacheKey, keyValuePairs); + await FreeRedisProvider.Instance.HSetAsync(redisCacheKey, keyValuePairs); } } _logger.LogInformation($"{nameof(InitAmmeterCacheData)} 初始化水表缓存数据完成"); @@ -301,7 +301,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading { //获取缓存中的水表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheWatermeterInfoKey, SystemTypeConst.Energy, 1)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(WatermeterScheduledMeterOneMinuteReading)} 1分钟采集水表据处理时没有获取到缓存信息,-101"); @@ -328,7 +328,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading //获取缓存中的水表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheWatermeterInfoKey, SystemTypeConst.Energy, 5)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(WatermeterScheduledMeterFiveMinuteReading)} 5分钟采集水表据处理时没有获取到缓存信息,-101"); @@ -354,7 +354,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading { //获取缓存中的水表信息 var redisKeyList = $"{string.Format(FreeRedisConst.CacheWatermeterInfoKey, SystemTypeConst.Energy, 15)}*"; - var oneMinutekeyList = await FreeRedisProvider.FreeRedis.KeysAsync(redisKeyList); + var oneMinutekeyList = await FreeRedisProvider.Instance.KeysAsync(redisKeyList); if (oneMinutekeyList == null || oneMinutekeyList.Length <= 0) { _logger.LogError($"{nameof(WatermeterScheduledMeterFifteenMinuteReading)} 15分钟采集水表据处理时没有获取到缓存信息,-101"); @@ -392,7 +392,7 @@ namespace JiShe.CollectBus.ScheduledMeterReading results[i] = {key, data} end return results"; - var oneMinuteAmmerterResult = await FreeRedisProvider.FreeRedis.EvalAsync(luaScript, redisKeys); //传递 KEYS + var oneMinuteAmmerterResult = await FreeRedisProvider.Instance.EvalAsync(luaScript, redisKeys); //传递 KEYS if (oneMinuteAmmerterResult == null) { _logger.LogError($"{nameof(WatermeterScheduledMeterOneMinuteReading)} 定时任务采集表数据处理时没有获取到缓存信息,-102"); diff --git a/src/JiShe.CollectBus.Domain/EnergySystems/Entities/TB_AmmeterInfo.cs b/src/JiShe.CollectBus.Domain/EnergySystems/Entities/TB_AmmeterInfo.cs new file mode 100644 index 0000000..a194d38 --- /dev/null +++ b/src/JiShe.CollectBus.Domain/EnergySystems/Entities/TB_AmmeterInfo.cs @@ -0,0 +1,259 @@ +using System; + +namespace JiShe.CollectBus.EnergySystems.Entities +{ + public class TB_AmmeterInfo + { + + /// + /// 电表信息 + /// + public int ID { get; set; } + + /// + /// 电表编号、电表型号 + /// + public string Code { get; set; } + + /// + /// 区域信息外键 + /// + public int AreaID { get; set; } + /// + /// 区域名 + /// + public string AreaName { get; set; } + + /// + /// 电表别名 + /// + public string Name { get; set; } + + /// + /// 电表类别 （1单相、2三相三线、3三相四线） + /// + public int TypeName { get; set; } + + /// + /// 电表安装地址 + /// + public string Location { get; set; } + /// + /// 电表安装时间 + /// + public DateTime? InstallTime { get; set; } + + /// + /// 电表密码 + /// + public string Password { get; set; } + + /// + /// 电表通信地址 + /// + public string Address { get; set; } + + /// + /// 采集器地址 + /// + public string CollectorAddress { get; set; } + + /// + /// 电压变比 + /// 电压互感器（PT） + /// + public double TimesV { get; set; } + + /// + /// 电流变比 + /// 电流互感器（CT） + /// + public double TimesA { get; set; } + + /// + /// 是否总表 + /// + public int IsSum { get; set; } + + /// + /// 总表ID + /// + public int ParentID { get; set; } + + /// + /// Explain + /// + public string Explain { get; set; } + + /// + /// AddDate + /// + public DateTime AddDate { get; set; } + + /// + /// State表状态: （对应枚举 MeterStateEnum） + /// 0新装（未下发），1运行(档案下发成功时设置状态值1)， 2暂停, 100销表（销表后是否重新启用）； + /// 特定State: -1 已删除 + /// + public int State { get; set; } + + + /// + /// 费率类型，单、多 (SingleRate :单费率（单相表1），多费率（其他0） ，与TypeName字段无关) + /// SingleRate ? "单" : "复" + /// [SingleRate] --0 复费率 false ， 1 单费率 true （与PayPlanID保持一致） + ///对应 TB_PayPlan.Type: 1复费率，2单费率 + /// + public bool SingleRate { get; set; } + + /// + /// 0 未下发 (false), 1 已下发 (true) + /// + public bool IsSend { get; set; } + + /// + /// 创建人ID + /// + public int CreateUserID { get; set; } + + /// + /// 波特率 default(2400) + /// + public int Baudrate { get; set; } + /// + /// 规约 -电表default(30) + /// + public int? Protocol { get; set; } + /// + /// 一个集中器下的[MeteringCode]必须唯一。 + /// + public int MeteringCode { get; set; } + /// + /// MeteringPort 端口就几个可以枚举。 + /// + public int MeteringPort { get; set; } + + /// + /// 对应[TB_PayPlan] + /// + public int PayPlanID { get; set; } + + + public int ProjectID { get; set; } + + public int FocusID { get; set; } + + /// + /// 集中器名称(扩展字段) + /// + public string FocusName { get; set; } + + /// + /// 跳合闸状态字段： 0 合闸，1 跳闸 + /// 电表：TripState （0 合闸-通电, 1 断开、跳闸）； + /// + public int TripState { get; set; } + /// + /// 最近阀控时间 + /// + public DateTime? TripTime { get; set; } + + /// + /// 排序字段 + /// + public int Sort { get; set; } + + /// + /// 电子表0 ， + /// 机械表1（德力西机械电表-Code） + /// (原有数据都默认：电子电表) + /// + public int MeterKind { get; set; } + + /// + /// 采集方案ID + /// + public int GatherPlanID { get; set; } + + /// + /// 采集项 + /// + public string ReadClass { get; set; } + + /// + /// 修改日期 + /// + public DateTime? EditDate { get; set; } + + /// + /// 修改用ID + /// + public int? EditUserID { get; set; } + + /// + /// 删除时间 + /// + public DateTime? RemoveDate { get; set; } + + /// + /// 删除用户ID + /// + public int? RemoveUserID { get; set; } + + /// + /// 掉电状态 (未上电=1，上电掉电中=2) + /// + public int? PowerDownStatus { get; set; } + + /// + /// 电流规格 + /// + public string CurrentSpec { get; set; } + + /// + /// 电压规格 + /// + public string VoltageSpec { get; set; } + + /// + /// 通讯状态 1：在线 0：离线 + /// + public int LineState { get; set; } + + /// + /// 特殊表 1：是 0：否 + /// + public int Special { get; set; } + + /* + /// + /// 采集项总数 + /// + public int GatherTotal { get; set; } + + /// + /// 采集项 + /// + public string GatherDataTypes { get; set; } + */ + + /// + /// 复费率类型（四费率=4，八费率=8） + /// + public int? MultipleRateType { get; set; } + } + + public class VMAmmeterInfo : TB_AmmeterInfo + { + public decimal? Rate { get; set; } + public decimal? Rate1 { get; set; } + public decimal? Rate2 { get; set; } + public decimal? Rate3 { get; set; } + + public decimal? Rate4 { get; set; } + + public decimal? Rate5 { get; set; } + + public decimal? Rate6 { get; set; } + } +} diff --git a/src/JiShe.CollectBus.Domain/EnergySystems/TableViews/V_FocusAmmeter.cs b/src/JiShe.CollectBus.Domain/EnergySystems/TableViews/V_FocusAmmeter.cs index 5ff30d6..b217972 100644 --- a/src/JiShe.CollectBus.Domain/EnergySystems/TableViews/V_FocusAmmeter.cs +++ b/src/JiShe.CollectBus.Domain/EnergySystems/TableViews/V_FocusAmmeter.cs @@ -1,4 +1,5 @@ -using System; +using JiShe.CollectBus.EnergySystems.Entities; +using System; using System.Collections.Generic; using System.Linq; using System.Text; @@ -6,8 +7,15 @@ using System.Threading.Tasks; namespace JiShe.CollectBus.EnergySystems.TableViews { - public class V_FocusAmmeter + public class V_FocusAmmeter: TB_AmmeterInfo { + public string FocusAddress { get; set; } + + public string FocusAreaCode { get; set; } + + public string FocusCode { get; set; } + + public string FocusState { get; set; } } } diff --git a/src/JiShe.CollectBus.Domain/JiShe.CollectBus.Domain.csproj b/src/JiShe.CollectBus.Domain/JiShe.CollectBus.Domain.csproj index 035298c..09edef1 100644 --- a/src/JiShe.CollectBus.Domain/JiShe.CollectBus.Domain.csproj +++ b/src/JiShe.CollectBus.Domain/JiShe.CollectBus.Domain.csproj @@ -33,8 +33,7 @@ - - + diff --git a/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderModule.cs b/src/JiShe.CollectBus.FreeRedisProvider/CollectBusFreeRedisModule.cs similarity index 76% rename from src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderModule.cs rename to src/JiShe.CollectBus.FreeRedisProvider/CollectBusFreeRedisModule.cs index 768332f..6485e92 100644 --- a/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderModule.cs +++ b/src/JiShe.CollectBus.FreeRedisProvider/CollectBusFreeRedisModule.cs @@ -1,16 +1,11 @@ using JiShe.CollectBus.FreeRedisProvider.Options; using Microsoft.Extensions.Configuration; using Microsoft.Extensions.DependencyInjection; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; using Volo.Abp.Modularity; namespace JiShe.CollectBus.FreeRedisProvider { - public class FreeRedisProviderModule : AbpModule + public class CollectBusFreeRedisModule : AbpModule { public override void ConfigureServices(ServiceConfigurationContext context) { diff --git a/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProvider.cs b/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProvider.cs new file mode 100644 index 0000000..b7f6a03 --- /dev/null +++ b/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProvider.cs @@ -0,0 +1,47 @@ +using FreeRedis; +using JetBrains.Annotations; +using JiShe.CollectBus.FreeRedisProvider.Options; +using Microsoft.Extensions.Options; +using System; +using System.Collections.Generic; +using System.Diagnostics; +using System.Linq; +using System.Text; +using System.Text.Json; +using System.Threading.Tasks; +using Volo.Abp.DependencyInjection; + +namespace JiShe.CollectBus.FreeRedisProvider +{ + + public class FreeRedisProvider : IFreeRedisProvider, ISingletonDependency + { + + private readonly FreeRedisOptions _option; + + /// + /// FreeRedis + /// + public FreeRedisProvider(IOptions options) + { + _option = options.Value; + GetInstance(); + } + + public RedisClient Instance { get; set; } = new (string.Empty); + + /// + /// 获取 FreeRedis 客户端 + /// + /// + public IRedisClient GetInstance() + { + var connectionString = $"{_option.Configuration},defaultdatabase={_option.DefaultDB}"; + Instance = new RedisClient(connectionString); + Instance.Serialize = obj => JsonSerializer.Serialize(obj); + Instance.Deserialize = (json, type) => JsonSerializer.Deserialize(json, type); + Instance.Notice += (s, e) => Trace.WriteLine(e.Log); + return Instance; + } + } +} \ No newline at end of file diff --git a/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderService.cs b/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderService.cs deleted file mode 100644 index b36001d..0000000 --- a/src/JiShe.CollectBus.FreeRedisProvider/FreeRedisProviderService.cs +++ /dev/null @@ -1,65 +0,0 @@ -using FreeRedis; -using JetBrains.Annotations; -using JiShe.CollectBus.FreeRedisProvider.Options; -using Microsoft.Extensions.Options; -using System; -using System.Collections.Generic; -using System.Diagnostics; -using System.Linq; -using System.Text; -using System.Text.Json; -using System.Threading.Tasks; -using Volo.Abp.DependencyInjection; - -namespace JiShe.CollectBus.FreeRedisProvider -{ - - public class FreeRedisProviderService : IFreeRedisProviderService, ISingletonDependency - { - private FreeRedisOptions _freeRedisOptions; - - /// - /// FreeRedis - /// - public FreeRedisProviderService(IOptions options) - { - _freeRedisOptions = options.Value; - } - - [NotNull] - public IRedisClient FreeRedis - { - get - { - return GetClient(); - } - } - - /// - /// 获取 FreeRedis 客户端 - /// - /// - public IRedisClient GetClient() - { - string connectionString = $"{_freeRedisOptions.Configuration},defaultdatabase={_freeRedisOptions.DefaultDB}"; - var redisClient = new RedisClient(connectionString); - redisClient.Serialize = obj => JsonSerializer.Serialize(obj); - redisClient.Deserialize = (json, type) => JsonSerializer.Deserialize(json, type); - redisClient.Notice += (s, e) => Trace.WriteLine(e.Log); - - return redisClient; - } - - /// - /// 切换Redis数据库 - /// - /// - /// - public IRedisClient GetDatabase(int index = 0) - { - var redisClient = GetClient(); - redisClient.GetDatabase(index); - return redisClient; - } - } -} \ No newline at end of file diff --git a/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProvider.cs b/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProvider.cs new file mode 100644 index 0000000..cc3ff02 --- /dev/null +++ b/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProvider.cs @@ -0,0 +1,14 @@ +using FreeRedis; + +namespace JiShe.CollectBus.FreeRedisProvider +{ + public interface IFreeRedisProvider + { + /// + /// 获取客户端 + /// + /// + RedisClient Instance { get; set; } + } +} + diff --git a/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProviderService.cs b/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProviderService.cs deleted file mode 100644 index 2e244dc..0000000 --- a/src/JiShe.CollectBus.FreeRedisProvider/IFreeRedisProviderService.cs +++ /dev/null @@ -1,30 +0,0 @@ -using FreeRedis; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; - -namespace JiShe.CollectBus.FreeRedisProvider -{ - public interface IFreeRedisProviderService - { - /// - /// 默认客户端 - /// - IRedisClient FreeRedis { get; } - - /// - /// 获取客户端 - /// - /// - IRedisClient GetClient(); - - /// - /// 切换Redis数据库 - /// - /// - /// - IRedisClient GetDatabase(int index = 0); - } -}