ASP.NETCore使用AutoFac依赖注入

Posted luckypc

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ASP.NETCore使用AutoFac依赖注入相关的知识,希望对你有一定的参考价值。

 

实现代码

1、新建接口类:IRepository.cs,规范各个操作类的都有那些方法,方便管理。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;

namespace CMS.Entity.Interfaces

    public  interface IRepository<T> where T:class
    
        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="entity">实体对象</param>
        void Add(T entity);
        /// <summary>
        /// 更新
        /// </summary>
        /// <param name="entity">实体对象</param>
        void Update(T entity);
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="entity">实体对象</param>
        void Delete(T entity);
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="where">条件(lambda表达式)</param>
        void Delete(Expression<Func<T, bool>> where);
        /// <summary>
        /// 根据ID获取一个对象
        /// </summary>
        /// <param name="Id">主键ID</param>
        /// <returns>对象</returns>
        T GetById(long Id);
        /// <summary>
        /// 根据ID获取一个对象
        /// </summary>
        /// <param name="Id">主键ID</param>
        /// <returns>对象</returns>
        T GetById(string Id);
        /// <summary>
        /// 根据条件获取一个对象
        /// </summary>
        /// <param name="where">条件(lambda表达式)</param>
        /// <returns>对象</returns>
        T Get(Expression<Func<T, bool>> where);
        /// <summary>
        /// 获取所有数据
        /// </summary>
        /// <returns>所有数据</returns>
        IQueryable<T> GetAll();
        /// <summary>
        /// 根据条件获取数据
        /// </summary>
        /// <param name="where">条件(lambda表达式)</param>
        /// <returns>数据</returns>
        IQueryable<T> GetMany(Expression<Func<T, bool>> where);
        /// <summary>
        /// 根据条件获取记录数
        /// </summary>
        /// <param name="where">条件(lambda表达式)</param>
        /// <returns></returns>
        int GetCount(Expression<Func<T, bool>> where);
        /// <summary>
        /// 关闭代理
        /// </summary>
        void CloseProxy();
        /// <summary>
        /// 打开代理
        /// </summary>
        void OpenProxy();
        /// <summary>
        /// 是否有指定条件的元素
        /// </summary>
        /// <param name="where">条件(lambda表达式)</param>
        /// <returns></returns>
        bool IsHasValue(Expression<Func<T, bool>> where);
    

2、新建仓储基础操作类RepositoryBase.cs,注意要一一对应实现IRepositroy接口的方法

using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;

namespace CMS.Entity.Interfaces

    public abstract class BaseRepository<T>  where T: class
    
        private BcmfDBContext db;//数据库上下文

        public BaseRepository(BcmfDBContext _db) 
            db = _db;
        

        public virtual void Save()
        
            db.SaveChanges();
        

        public  virtual  void Add(T entity)
        
            db.Set<T>().Add(entity);
        

        public virtual void CloseProxy()
        
            db.Database.CommitTransaction();
        

        public virtual void Delete(T entity)
        
            db.Set<T>().Remove(entity);
        

        public virtual void Delete(System.Linq.Expressions.Expression<Func<T, bool>> where)
        
            var dataList = db.Set<T>().Where(where).AsEnumerable();
            db.Set<T>().RemoveRange(dataList);
        

        public virtual T Get(System.Linq.Expressions.Expression<Func<T, bool>> where)
        
           return db.Set<T>().FirstOrDefault(where);
        

        public virtual System.Linq.IQueryable<T> GetAll()
        
            return db.Set<T>();
        

        public virtual T GetById(long Id)
        
            return db.Set<T>().Find(Id);
        

        public virtual T GetById(string Id)
        
            return db.Set<T>().Find(Id);
        

        public virtual int GetCount(System.Linq.Expressions.Expression<Func<T, bool>> where)
        
            return db.Set<T>().Count(where);
        

        public virtual System.Linq.IQueryable<T> GetMany(System.Linq.Expressions.Expression<Func<T, bool>> where)
        
            return db.Set<T>().Where(where);
        

        public virtual bool IsHasValue(System.Linq.Expressions.Expression<Func<T, bool>> where)
        
            return db.Set<T>().Any(where);
        

        public virtual void OpenProxy()
        
            db.Database.BeginTransaction();
        

        public virtual void Update(T entity)
        
            db.Set<T>().Attach(entity);
            db.Entry<T>(entity).State = Microsoft.EntityFrameworkCore.EntityState.Modified;
        
    

3、新建仓储类TUserRepository与TOperateLogRepository,TUserRepository用于操作用户表,TOperateLogRepository用于操作用户记录表,对应的User类与OperateLog类根据项目需求自行创建

using System;
using System.Collections.Generic;
using System.Text;
using CMS.Entity.Repository;
using CMS.Entity.Entity;
using Microsoft.EntityFrameworkCore;
using System.Linq;
using CMS.Entity.Interfaces;

namespace CMS.Entity.Repository

    public class TUserRepository :BaseRepository<User>,IUserRepository
    
        public TUserRepository(BcmfDBContext db) : base(db)  
    
    public interface IUserRepository : IRepository<User>  
using System;
using System.Collections.Generic;
using System.Text;
using CMS.Entity.Repository;
using CMS.Entity.Entity;
using Microsoft.EntityFrameworkCore;
using System.Linq;
using CMS.Entity.Interfaces;

namespace CMS.Entity.Repository


    public class TOperateLogRepository : BaseRepository<OperateLog>, IOperateLogRepository
    
        public TOperateLogRepository(BcmfDBContext db) : base(db)  
    
    public interface IOperateLogRepository : IRepository<OperateLog>
    
    

 

4、分别在UserController与OperateLogController控制器中的构造函数注入仓储类

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using CMS.Entity;
using CMS.Entity.Entity;
using Newtonsoft.Json;
using CMS.WebApi.Core;
using Microsoft.EntityFrameworkCore.Query;
using CMS.Entity.Repository;

namespace CMS.WebApi.Controllers

    /// <summary>
    /// 用户中心
    /// </summary>
    //[Produces("application/json")]
    [Route("api/[controller]")]
    [ApiController]
    public class UsersController : ControllerBase
    

        private readonly IUserRepository userRepository;
        public UsersController(IUserRepository _userRepository)
        
            userRepository = _userRepository;
        


        /// <summary>
        /// 获取用户列表
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        public string Get()
        
            var userList= userRepository.GetAll().ToList();
            return JsonConvert.SerializeObject(userList);
        
    
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using CMS.Entity.Repository;
using Newtonsoft.Json;

namespace CMS.WebApi.Controllers

    [Route("api/[controller]")]
    [ApiController]
    public class OperateLogController : ControllerBase
    
        private readonly IOperateLogRepository operateLogRepository;
        public OperateLogController(IOperateLogRepository _operateLogRepository)
        
            operateLogRepository = _operateLogRepository;
        

        [HttpGet]
        public string Get()
        
            var result = operateLogRepository.GetMany(m=>m.ActionLogId<100);
            return JsonConvert.SerializeObject(result);
        
    

5、完成上述操作后,运行获取数据时会系统报错,那是由于还没将仓储类注入到服务中,接下来就实现用AutoFac注入仓储类到项目服务中

添加引用Autofac,Auto.Configuration,Autofac.Extensions.DependencyInjection到项目中

 

技术图片

这里贴出Nuget程序控制台命令:

Install-Package Autofac -Version 4.9.2
Install-Package Autofac.Configuration -Version 4.1.0
Install-Package Autofac.Extensions.DependencyInjection -Version 4.4.0

6、打开项目Startup.cs,找到ConfigureServices方法,将void改为IServiceProvider返回值,如下

 //先引用命名空间
using Autofac;
using Autofac.Extensions.DependencyInjection;

public IServiceProvider ConfigureServices(IServiceCollection services) ... ////批量匹配注入,使用AutoFac提供的容器接管当前项目默认容器 var builder = new ContainerBuilder(); //注入entity层的repository类builder.RegisterType(typeof(TUserRepository)).As(typeof(IUserRepository)).InstancePerDependency(); //批量注入Repository的类   builder.RegisterAssemblyTypes(typeof(TUserRepository).Assembly) .Where(t => t.Name.EndsWith("Repository")) .AsImplementedInterfaces(); builder.Populate(services); var container = builder.Build(); //ConfigureServices方法由void改为返回IServiceProvider return new AutofacServiceProvider(container);

7、重新生成发布项目,完成

 

以上是关于ASP.NETCore使用AutoFac依赖注入的主要内容,如果未能解决你的问题,请参考以下文章

ASP.NET Core Web 应用程序系列- 在ASP.NET Core中使用Autofac替换自带DI进行构造函数和属性的批量依赖注入(MVC当中应用)

ASP.NETCore 3.0 Autofac替换及控制器属性注入及全局容器使用

ASP.NET Core Web 应用程序系列- 在ASP.NET Core中使用Autofac替换自带DI进行构造函数和属性的批量依赖注入(MVC当中应用)

Autofac - ASP.NET Core 中的动作过滤器中的属性注入

如何编写一个简单的依赖注入容器

ASP.Net Core 使用啥依赖注入框架?