net下新開發框架never

来源:https://www.cnblogs.com/shelldudu/archive/2019/06/26/10944952.html
-Advertisement-
Play Games

【一】 摘要 never是純c#語言開發的一個框架，同時可在netcore下運行。 該框架github地址：https://github.com/shelldudu/never 同時，配合never_web，never_component，never_application （demo）可對比代碼學 ...


【一】 摘要

never是純c#語言開發的一個框架，同時可在netcore下運行。 該框架github地址：https://github.com/shelldudu/never

同時，配合never_web，never_component，never_application （demo）可對比代碼學習。

引用其圖片說明該構架所涉及到的工具

never      

使用emit技術所實現的核心功能點   

never

其中使用包含了一些開發設計模式，比如message的訂閱與發佈，熔斷機制等。

【二】整體設計

1、以ApplicationStartup開始，啟動服務，註冊不同組件，這裡是netcore的部分代碼

/// <summary>
/// 該方法被ConfigureServices裡面的base.ConfigureServicese調用，由於ConfigureServices方法會使用不同的組件方案，所以在其後面啟支，是將這些組件方案所註冊的ioc規則加入到自己的ioc規則裡面去
/// 同時替換了系統IServiceCollection自己生成的IServiceProvider對象
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Startup_OnStarting(object sender, Never.StartupEventArgs e)
{
    //ddd的command裡面使用了恢復（即一些命令出錯後被保存後過段時間再執行），當前使用sqlite本地資料庫方式
    var commandfile = new FileInfo(AppContext.BaseDirectory + "\\App_Data\\command_demo.db");
    //ddd的event跟上面的一樣
    var eventfile = new FileInfo(AppContext.BaseDirectory + "\\App_Data\\event_demo.db");
    //使用nlog組件
    var logfile = new FileInfo(AppContext.BaseDirectory + "\\App_Config\\nlog.config");
    //配置文件的讀取
    var configReader = new AppConfigReader(this.Configuration);
}

 我們先對程式集過濾與開啟IoC

//註冊程式集過濾，因為整個啟動過程會分析程式集裡面的Type對象，很多dll我們不用分析，只焦點到我們現在註入的2個規則就行，"Never" + "B2C",正則只要匹配到該字元就加載入到待分析的dll集合中
e.Startup.RegisterAssemblyFilter("B2C".CreateAssemblyFilter()).RegisterAssemblyFilter("Never".CreateAssemblyFilter());
//ioc分2種啟動方法，主要原因如下：（1）服務啟動有先後順序，不同的系統組件所註冊的順序不同的，但有些組件要求在所有環境下都只有第一或最後啟動（2）由於使用環境自動註冊這種設計下，一些組件要手動註冊會帶自己的規則就會被自動註冊覆蓋
e.Startup.UseEasyIoC(
    (x, y, z) =>
    {
        //先啟動該服務註冊組件，
    },
    (x, y, z) =>
    {
        //再按自己的個性化註冊組件，比如Controller在下麵UseApiDependency後會自動註入，但是我想HomeController註入的時候使用memecahed，這種情況就要手動註入了
        //x.RegisterType<Controllers.HomeController, Controllers.HomeController>().WithParameter<Never.Caching.ICaching>("memcached");
        //註入query與repository實例，為什麼不用自動註入？哈哈，因為在framework或netcore等各種不同的環境下大家讀取配置文件是不同的，一旦寫死在B2C.Message.SqlData.Query裡面讀取配置文件，則使用不同的host技術就出現極大問題，
        //比如netcore沒有connectionString這種配置（或者有人說可以手動引用System.Configuration，這不是嫌麻煩嗎）
        x.RegisterInstance(new B2C.Message.SqlData.Query.QueryDaoBuilder(Infrastructure.SqldbType.sqlserver, () => configReader["message_conn"]));
        x.RegisterInstance(new B2C.Message.SqlData.Repository.RepositoryDaoBuilder(Infrastructure.SqldbType.sqlserver, () => configReader["message_conn"]));
    });

註冊各種組件

//使用環境下自動註冊組件，
e.Startup.UseAutoInjectingAttributeUsingIoC(new IAutoInjectingEnvironmentProvider[]
{
    //在message該環境下，所有單例註冊組件只有匹配message的才註冊，（1）有些組件是線程的，那麼不會被描述和註入中，除非再加個線程provider；（2）即使是單例provider,但所運行不是message環境，所以也不會註入
    SingletonAutoInjectingEnvironmentProvider.UsingRuleContainerAutoInjectingEnvironmentProvider("message"),
})
//使用統一配置中心讀取配置文件，實用性在後面有講到
.UseConfigClient(new IPEndPoint(IPAddress.Parse(configReader["config_host"]), configReader.IntInAppConfig("config_port")), out var configFileClient);
configFileClient.Startup(TimeSpan.FromMinutes(10), new[] { new ConfigFileClientRequest { FileName = "message_api" } }, (c, t) =>
{
    var content = t;
    if (c != null && c.FileName == "message_api")
    {
        System.IO.File.WriteAllText(System.IO.Path.Combine(this.Environment.ContentRootPath, "appsettings.app.json"), content);
    }
}).Push("message_api").GetAwaiter().GetResult();
e.Startup
    .UseCounterCache() //使用countcache
    .UseConcurrentCache() //使用安全countcache
    .UseDataContractJson() //使用datacontract技術的序列化，實現了IJsonSerialize介面
    .UseEasyJson(string.Empty) //使用easyjson技術的序列化，實現了IJsonSerialize介面
    .UseNLog(logfile) //使用nlog
    .UseAppConfig(configReader) //將IConfigReader註入
    .UseForceCheckAggregateRootImplIHandle() //這幾個Force都是為了檢查ddd開發一些要求，比如是否繼承某個類，某些介面
    .UseForceCheckCommandAppDomainAttribute() //檢查所有的command是否帶了特定attribute
    .UseForceCheckCommandEvenWithNoParamaterCtor() //檢查所有的commandhandler所要的構造參數是否被註入中
    .UseForceCheckCommandHandlerCtor() //檢查所有的eventhandler所要的構造參數是否被註入中
    .UseForceCheckEventAppDomainAttribute()//檢查所有的event是否帶了特定attribute
    .UseForceCheckEventHandlerCtor() //檢查所有的eventhandler所要的構造參數是否被註入中
    .UseForceCheckMessageSubscriberCtor() //使用消息的訂單與發佈
    .UseInjectingCommandHandlerEventHandler(Never.IoC.ComponentLifeStyle.Singleton) //註入所有的commandhandler，在commandbus執行其對象行為
    .UseSqliteEventProviderCommandBus<DefaultCommandContext>(new SqliteFailRecoveryStorager(commandfile, eventfile)) //使用cqrs組件，指定sqlite作為恢復組件，
    .UseApiModelStateValidation() //mvc,webapi的模型參數驗證
    .UseApiActionCustomRoute(e.Collector as IServiceCollection) //自定義路由，相同於在controller可以使用httpget等route技術
    .UseApiDependency(e.Collector as IServiceCollection);//註入所有的controller

最後啟動過程中檢查整個系統是否正常

//配置中心更新配置文件後，系統不一定馬上能重新載入
e.Startup.Startup(TimeSpan.FromSeconds(1), (x) =>
{
    //我們在此啟動看看所使用組件是否正常啟動
    using (var sc = x.ServiceLocator.BeginLifetimeScope())
    {
        sc.Resolve<ICommandBus>();
        sc.Resolve<ILoggerBuilder>();
        sc.Resolve<IJsonSerializer>();
        var home = sc.Resolve<Controllers.MessageController>();

        var logger = sc.Resolve<ILoggerBuilder>().Build(typeof(Startup));
        logger.Info("startup at " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
    }
});
}

2、Controller的註入，使用構造函數的方法註入

private readonly IEmailCodeQuery emailCodeQuery = null;
private readonly IMobileCodeQuery mobileCodeQuery = null;
private readonly ICommandBus commandBus = null;
private readonly ILoggerBuilder loggerBuilder = null;
private readonly IJsonSerializer jsonSerializer = null;
public VCodeController(ICommandBus commandBus,
    ILoggerBuilder loggerBuilder,
    IJsonSerializer jsonSerializer,
    IEmailCodeQuery emailCodeQuery,
    IMobileCodeQuery mobileCodeQuery)
{
    this.commandBus = commandBus;
    this.loggerBuilder = loggerBuilder;
    this.jsonSerializer = jsonSerializer;
    this.emailCodeQuery = emailCodeQuery;
    this.mobileCodeQuery = mobileCodeQuery;
}

3、Action代碼處理

/// <summary>
/// 校驗郵箱驗證碼
/// </summary>
/// <param name="reqs"></param>
/// <returns></returns>
[ApiActionRemark("a9a900aee8c6", "HttpPost"), HttpPost]
public ApiResult<string> CheckEmailValidateCode(CheckEmailValidateCodeReqs reqs)
{
    if (!this.TryValidateModel(reqs))
    {
        return Anonymous.NewApiResult(ApiStatus.Fail, string.Empty, this.ModelErrorMessage);
    }

    //實際上不用try + catch了，因為在startup統一日誌處理了。
    //發送命令後交給commandhandler去處理領域，commandbus + eventbus
    var handler = this.commandBus.Send(new DestroyEmailCodeCommand(NewId.GenerateGuid())
    {
        Email = reqs.Email,
        UsageType = reqs.UsageType,
        VCode = reqs.VCode,
    });

    if (handler == null)
    {
        return Anonymous.NewApiResult(ApiStatus.Fail, string.Empty, "驗證失敗");
    }

    if (handler.Status != CommandHandlerStatus.Success)
    {
        return Anonymous.NewApiResult(ApiStatus.Error, string.Empty, this.HandlerMerssage(handler));
    }

    return Anonymous.NewApiResult(ApiStatus.Success, string.Empty);
}

【三】組成部分

  1. ApplicationStartup 整個系統的初始化中心點，可以是Web環境，也可以是Service環境。
  2. Emit 避免使用反射帶來的損耗，並且對OpCode的使用封裝變成方法的調用，可容易理解與使用，是後面所有技術的支撐點。
  3. IoC 簡單實現三種生命周期，單例 + 作用域 + 短暫，註入指定參數，可以生成代理註入攔截器。
  4. Aop 加入上下文日誌跟蹤（如LoggerAttribte自動寫日誌）；Mock對象等。
  5. CQRS 實現了一套commandbus + eventbus設計，commandbus執行命令後，若聚合對象有事件，則通過eventbus發佈到訂閱者；中間使用sqlite來保存訂閱失敗的隊列，用於後期的恢複發布訂閱。
  6. SqlClient 配置極其簡單，使用也很容易的一個sql執行方法，使用xml文件配置管理sql語句，可執行事務，對xml內容進行縮進使得好看；也可以直接寫sql語句。使用typehander，用於處理阻抗失敗的情況。
  7. Mapper 直接映射對象，效率比emitmapper差一點。
  8. Message 消息的發佈與訂閱，可以在記憶體，mq方式發佈到不同的機器。
  9. Socket 使用SocketAsyncEventArgs實現的一套高性能方案，讀取與發送分開隊列，可以設置心跳。
  10. Remoting 在socket的基礎上實現一套通訊。
  11. Configuration 配置中心，對文件（夾）進行監控，修改文件會觸發所有應用程式的配置更新；設置了共用級+應用級配置文件，不用的應用級配置文件可以直接link共用級的配置，共用級的配置可以讀取文件，也可以到資料庫查詢。
  12. Deployment 對WebApi裡面的Service直接生成代理類，封裝了web請求的參數，路由等信息，還可以使用熔斷機制，在客戶端發現服務不可用的時候自動返回友好結果。
  13. Workflow 實現了一套工作流內容，每一步驟都可以獨立為插件或一個類，並且可組合不同步驟，包含等待，重試，中斷等不同狀態。
  14. Memcached 一個memcached客戶端，文本協議+二進位協議，還有Gzip壓縮，Binary序列化；定義的介面可以很方便使用protobuf等技術的自由擴展。
  15. JsonSerializerjson 序列化，可動態配置不用類型的輸出結構，通過emit後緩存提高性能，還能支持用戶自定義序列介面。

【四】快速開發

我們打開startup文件或global文件來看看，整個構架的初始化都在global或startup裡面實現的，環境的搭建比較簡單，可以直接開發業務而不關心組件實現方式。

摘要裡面一些代碼展示：

1、介面與實現使用IoC管理，加上靈活的AOP，可統一日誌管理的管理

[Logger]
public class EmailCodeCommandHandler : ICommandHandler<CreateEmailCodeCommand>, ICommandHandler<DestroyEmailCodeCommand> { }

2、對遠程方法的調用，封裝成本地調用方式

//實際上這裡是web遠程方法,使用代理生成類，帶熔斷，
var api = this.validateCodeService.CreateMobileValidateCode(new Message.Contract.Request.CreateMobileValidateCodeReqs()
{
    Mobile = model.UserName,
    ClientIP = this.GetAppIP(),
    Platform = this.GetAppPlatform(),
    Length = 4,
    UsageType = Message.Contract.EnumTypes.UsageType.註冊,
});

3、友好的參數驗證，用戶自己加驗證參數規則。

/// <summary>
/// 用戶Model
/// </summary>
[Serializable, Validator(typeof(RequestValidator))]
public class UserViewModel
{
    #region prop

    /// <summary>
    /// 用戶名
    /// </summary>
    [DisplayName("用戶名")]
    public string UserName { get; set; }

    #endregion prop

    #region validator

    private class RequestValidator : Validator<UserViewModel>
    {
        public override IEnumerable<KeyValuePair<Expression<Func<UserViewModel, object>>, string>> RuleFor(UserViewModel target)
        {
            if (target.UserName.IsNullOrWhiteSpace())
                yield return new KeyValuePair<Expression<Func<UserViewModel, object>>, string>(m => m.UserName, "手機號碼為空");
        }
    }

    #endregion validator
}

4、可靠的性能：json的序列化與反序列化，在反序列化timespan下（字元串："00:10:00")， 2700x + 32g記憶體1000萬次測試，jsonnet 使用12.6秒（GC=3.7萬），easyser使用2.6秒（GC=3.7K)，jil使用0.8秒（GC=1.2k）

5、簡單的配置：系統初始化過程風格統一，還有組件eqsysql只需要xml文件 + 鏈接字元串，就可以實現ORM管理（如QueryForObject<T>，QueryForEnumerable<T>）

 

章節導航：

  1. sqlcient 一套容易上手性能又不錯的sqlhelper
  2. easySql使用xml管理帶事務的orm
  3. ioc工具easyioc

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1.shell編程-變數的高級用法
    1.1.變數替換 變數替換的六種形式 實例：非貪婪和貪婪的區別 從頭部刪除 從尾部刪除 字元串替換，把bin替換成大寫的BIN，單斜線和雙斜線的區別 1.2.字元串處理 計算字元串長度 方法一 方法二 string有空格，則必須加雙引號 實例 獲取子串在字元串中的索引位置 實例 會把子串分割成一個一 ...
  • LinqMethod 實現 LeftJoin
    有時候我們想實現 leftJoin 但是 Linq 提供的 Join 相當於是 `INNER JOIN`，於是就打算實現一個 `LeftJoin` 的擴展。 ...
  • 搭建基於.NetFrameWork的私有nuget服務端及打包項目發佈上傳
    一、私有Nuget服務端搭建 1.創建一個.NetFramework web項目 2.在nuget管理中 安裝 nuget.server包 3.安裝完成後修改web.config裡面的 apikey 和 packagesPath apikey：推送包到nuget服務端 packpage: 上傳上來的 ...
  • 淺談Linq查詢
    一.Var關鍵字 在學習Linq查詢之前，我們先來學習var關鍵字的用法，看看微軟官方的定義：從Visual C＃3.0開始，在方法範圍聲明的變數可以具有隱式“類型” var。隱式類型的局部變數是強類型的，就像您自己聲明瞭類型一樣，但編譯器確定了類型。從這個定義我們有兩點需要註意，首先用var申明的 ...
  • DataTable去除重覆行
    DataTable去除重覆行 利用DataView的ToTable()方法，方法第一個參數代表是否去除重覆，true則去除，第二個參數傳列名。 ...
  • 記錄一次關於Cookie、Json中文亂碼的解決方法
    今天工作上遇到一個問題，需要把一個對象集合List<Model>存入一個Cookie，按照原來都封裝方法存入都ok，但是到取值都時候中文會變成亂碼。 首先，我們可以確認Json和Cookie都有可能亂碼，我們可以在轉換Json和寫入寫出Cookie的時候都加入調試代碼，這樣可以看到轉換Json和Co ...
  • C# 釘釘第三方開發接入
    釘釘開放平臺 本文是針對釘釘開放平臺的基於dotNetCore服務端開發和配置的描述 釘釘可開發的程式包括 企業內部應用，第三方企業應用，第三方個人應用 一、環境搭建 1.釘釘開發需要企業釘釘賬號，如果學習測試環境的話可以自己註冊一個企業號。 2.根據需求創建程式。註意伺服器出口IP，即Ip白名單， ...
  • .NET中擴展方法和Enumerable(System.Linq)
    LINQ是我最喜歡的功能之一，程式中到處是data.Where(x=x>5).Select(x)等等的代碼，她使代碼看起來更好，更容易編寫，使用起來也超級方便，foreach使迴圈更加容易，而不用for int..，linq用起來那麼爽，那麼linq內部是如何實現的？我們如何自定義linq？我們這裡 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類