.netCore+Vue 搭建的簡捷開發框架 (5)

文章目錄：.netCore+Vue 搭建的簡捷開發框架--目錄

上兩節的內容介紹了一些關於。netCore 相關的一些基礎知識。介紹這些的目的，最主要的還是為了我們的架構搭建服務。

上一節中，我們介紹了有關NetCore DI的一些概念。 整個框架，我們的倉儲層、服務層都是通過依賴注入的方式進行加載調用的。

下面就來看一下倉儲層和服務層是如何注入的：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Sincere.Core.IRepository.Base;
using Sincere.Core.IServices.Base;
using Sincere.Core.Model.EFCore;
using Sincere.Core.Model.Models;
using Sincere.Core.Repository.Base;
using Sincere.Core.Services.Base;
using Sincere.Core.WebAPI.ServiceExtension;

namespace Sincere.Core.WebAPI
{
    public class Startup
    {
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        public IConfiguration Configuration { get; }

        // This method gets called by the runtime. Use this method to add services to the container.
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);

            services.AddDbContextPool<BaseCoreContext>(options =>
                options.UseSqlServer(BaseDBConfig.ConnectionString));
            services.AddScoped<IBaseContext, BaseCoreContext>();
            //泛型引用方式
            services.AddScoped(typeof(IBaseServices<>), typeof(BaseServices<>));

            services.AddScoped(typeof(IBaseRepository<>), typeof(BaseRepository<>));

            services.RegisterAssembly("IServices");
            services.RegisterAssembly("IRepository");
        }

        // 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();
        }
    }
}

 

 標記1 的部分，是關於EF，以及DbContext 的相關引用，這里涉及到一個AddDbContextPool的概念，我個人的理解就是可以把他當成我們使用ADO.net 時的數據庫連接池。

另外需要說明的一點就是，采用AddScoped 的方式，整個數據庫鏈接的上下文，在整個請求過程中，只會被實例化一次。

標記2的部分，時我們對倉儲的基礎類，和服務層基礎類的引用，注意這些基礎類是泛型的方式，所以引用的時候，需要采用泛型的方式來實現。在這個地方，剛開始的時候，不知道AddScoped支持泛型的方式，還寫過一個工廠類來進行注入。

剩下的方法，services.RegisterAssembly 其實是一個比較巧妙的方式，為了避免每寫一個service、repository就在ConfigureServices中注入一次。所以在這里采用了反射的機制。利用反射和我們的約定，將整個程序集中的Service和Repository進行一個引用。

webAPI工程下新建一個ServiceExtension目錄，並添加RuntimeHelper類和ServiceExtension。

如下圖：

 

 代碼如下：

using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;

namespace Sincere.Core.WebAPI.ServiceExtension
{
    /// <summary>
    /// IServiceCollection擴展
    /// </summary>
    /// <summary>
    /// IServiceCollection擴展
    /// </summary>
    public static class ServiceExtension
    {
        /// <summary>
        /// 用DI批量注入接口程序集中對應的實現類。
        /// <para>
        /// 需要注意的是，這里有如下約定：
        /// IUserService --> UserService, IUserRepository --> UserRepository.
        /// </para>
        /// </summary>
        /// <param name="service"></param>
        /// <param name="interfaceAssemblyName">接口程序集的名稱（不包含文件擴展名）</param>
        /// <returns></returns>
        public static IServiceCollection RegisterAssembly(this IServiceCollection service, string interfaceAssemblyName, ServiceLifetime serviceLifetime = ServiceLifetime.Scoped)
        {
            if (service == null)
                throw new ArgumentNullException(nameof(service));
            if (string.IsNullOrEmpty(interfaceAssemblyName))
                throw new ArgumentNullException(nameof(interfaceAssemblyName));

            var assembly = RuntimeHelper.GetAssembly(interfaceAssemblyName);
            if (assembly == null)
            {
                throw new DllNotFoundException($"the dll \"{interfaceAssemblyName}\" not be found");
            }

            //過濾掉非接口及泛型接口
            var types = assembly.GetTypes().Where(t => t.GetTypeInfo().IsInterface && !t.GetTypeInfo().IsGenericType);

            foreach (var type in types)
            {
                var implementTypeName = type.Name.Substring(1);
                var implementType = RuntimeHelper.GetImplementType(implementTypeName, type);
                if (implementType != null)
                {
                    switch (serviceLifetime)
                    {
                        //根據條件，選擇注冊依賴的方法
                        case ServiceLifetime.Scoped:
                            //將獲取到的接口和類注冊進去
                            service.AddScoped(type, implementType);
                            break;
                        case ServiceLifetime.Singleton:
                            service.AddSingleton(type, implementType);
                            break;
                        case ServiceLifetime.Transient:
                            service.AddTransient(type, implementType);
                            break;
                    }

                }
            }
            return service;
        }

       
    }
}

using Microsoft.Extensions.DependencyModel;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Runtime.Loader;
using System.Threading.Tasks;

namespace Sincere.Core.WebAPI.ServiceExtension
{
    public class RuntimeHelper
    {
        /// <summary>
        /// 獲取項目程序集，排除所有的系統程序集(Microsoft.***、System.***等)、Nuget下載包
        /// </summary>
        /// <returns></returns>
        public static IList<Assembly> GetAllAssemblies()
        {
            var list = new List<Assembly>();
            var deps = DependencyContext.Default;
            var libs = deps.CompileLibraries.Where(lib => !lib.Serviceable && lib.Type != "package");//排除所有的系統程序集、Nuget下載包
            foreach (var lib in libs)
            {
                try
                {
                    var assembly = AssemblyLoadContext.Default.LoadFromAssemblyName(new AssemblyName(lib.Name));
                    list.Add(assembly);
                }
                catch (Exception)
                {
                    // ignored
                }
            }
            return list;
        }

        public static Assembly GetAssembly(string assemblyName)
        {
            return GetAllAssemblies().FirstOrDefault(assembly => assembly.FullName.Contains(assemblyName));
        }

        public static IList<Type> GetAllTypes()
        {
            var list = new List<Type>();
            foreach (var assembly in GetAllAssemblies())
            {
                var typeInfos = assembly.DefinedTypes;
                foreach (var typeInfo in typeInfos)
                {
                    list.Add(typeInfo.AsType());
                }
            }
            return list;
        }

        public static IList<Type> GetTypesByAssembly(string assemblyName)
        {
            var list = new List<Type>();
            var assembly = AssemblyLoadContext.Default.LoadFromAssemblyName(new AssemblyName(assemblyName));
            var typeInfos = assembly.DefinedTypes;
            foreach (var typeInfo in typeInfos)
            {
                list.Add(typeInfo.AsType());
            }
            return list;
        }

        public static Type GetImplementType(string typeName, Type baseInterfaceType)
        {
            return GetAllTypes().FirstOrDefault(t =>
            {
                if (t.Name == typeName &&
                    t.GetTypeInfo().GetInterfaces().Any(b => b.Name == baseInterfaceType.Name))
                {
                    var typeInfo = t.GetTypeInfo();
                    return typeInfo.IsClass && !typeInfo.IsAbstract && !typeInfo.IsGenericType;
                }
                return false;
            });
        }
    }
}

 

 這樣類似的代碼網上挺多的。大家可以參考借鑒一下。另外這個地方其實不用太過於關心反射帶來的性能問題，因為只有在程序啟動的時候，加載一次。

倉儲層和服務層都注入進來以后，接下來就是怎么去使用了。

來一起看一下我們是怎么在ValuesController里面進行實現的。

 

  1.定義服務層接口

 2.在ValuesController初始化的時候，將服務層接口注入進來。

 3.使用接口，調用數據。

代碼如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Sincere.Core.IServices;

namespace Sincere.Core.WebAPI.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class ValuesController : ControllerBase
    {
        readonly IAdvertisementServices _advertisementServices;
        public ValuesController(IAdvertisementServices advertisementServices)
        {
            _advertisementServices = advertisementServices;
        }

        // GET api/values
        [Route("")]
        [HttpGet]
        public async Task<ActionResult<IEnumerable<string>>> Get()
        {
            var t = await _advertisementServices.ReadAllAd();

            return new string[] { "value1", "value2" };
        }

        // GET api/values/5
        [HttpGet("{id}")]
        public ActionResult<string> Get(int id)
        {
            return "value";
        }

        // POST api/values
        [HttpPost]
        public void Post([FromBody] string value)
        {
        }

        // PUT api/values/5
        [HttpPut("{id}")]
        public void Put(int id, [FromBody] string value)
        {
        }

        // DELETE api/values/5
        [HttpDelete("{id}")]
        public void Delete(int id)
        {
        }
    }
}

關於ReadAllAd()方法，之前的章節中已經有過描述。

 

 調用成功，說明框架的整體流程已經跑通了！晚上加個雞腿，慶祝一下！

按照之前的腦圖，不知道大家還記得不？

 

 

紅框里面的內容，到這一節，基本就結束了。接下來，會逐步的豐富我們的框架。加入日志，異常處理，權限驗證。以及其他腦圖中列出來的內容。

希望整個過程對於想學習、了解netCore 的同學們有所幫助！

 

 源碼已經更新：https://github.com/xzhencheng/Sincere.Core