.NET 6 整合 Autofac 依赖注入容器

前言

一行业务代码还没写,框架代码一大堆,不利于学习。
常看到java的学习资料或博客,标题一般为《SpringBoot 整合 XXX》,所以仿照着写了《.NET 6 整合 Autofac 依赖注入容器》这样一个标题。
以下是我自己的用法,可能不是最佳实践。

一. 引用包

NuGet搜索并安装:
Autofac
Autofac.Extensions.DependencyInjection

二. 配置代码

var builder = WebApplication.CreateBuilder(args);

...省略

// ASP.NET Core整合Autofac
builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());//通过工厂替换,把Autofac整合进来
builder.Host.ConfigureContainer<ContainerBuilder>(containerBuilder =>
{
    ServiceFactory.SetBuilder(containerBuilder);
    ServiceFactory.RegisterAssembly(Assembly.GetExecutingAssembly()); //注册服务
});

var app = builder.Build();

ServiceFactory.SetContainer((app.Services as AutofacServiceProvider).LifetimeScope as IContainer);
Task.Run(async () => await ServiceFactory.StartAllService()); //启动服务,注意:服务启动完成之前,调用接口会异常

...省略

三. 服务的自动注册、启动、停止

IService接口

/// <summary>
/// 服务接口
/// </summary>
public interface IService
{
    /// <summary>
    /// 服务启动
    /// </summary>
    Task OnStart();

    /// <summary>
    /// 服务停止
    /// </summary>
    Task OnStop();
}

RegisterServiceAttribute特性

/// <summary>
/// 注册为服务
/// </summary>
public class RegisterServiceAttribute : Attribute
{
}

ServiceBase抽像类

[RegisterService]
public abstract class ServiceBase : IService
{
    #region OnStart
    public virtual Task OnStart()
    {
        return Task.CompletedTask;
    }
    #endregion

    #region OnStop
    public virtual Task OnStop()
    {
        return Task.CompletedTask;
    }
    #endregion

}

ServiceFactory服务工厂类

public class ServiceFactory
{
    private static ContainerBuilder _builder;

    private static IContainer _container;

    private static bool _isRunning; //服务是否正在运行

    public static void SetBuilder(ContainerBuilder builder)
    {
        _builder = builder;
    }

    public static void SetContainer(IContainer container)
    {
        _container = container;
    }

    /// <summary>
    /// Autofac.ContainerBuilder
    /// </summary>
    public static ContainerBuilder Builder
    {
        get
        {
            return _builder;
        }
    }

    /// <summary>
    /// 获取服务
    /// </summary>
    /// <typeparam name="T">接口类型</typeparam>
    public static T Get<T>()
    {
        if (_isRunning)
        {
            return _container.Resolve<T>();
        }
        else
        {
            throw new Exception("服务尚未启动完成");
        }
    }

    /// <summary>
    /// 获取服务
    /// </summary>
    /// <param name="type">接口类型</param>
    public static object Get(Type type)
    {
        if (_isRunning)
        {
            return _container.Resolve(type);
        }
        else
        {
            throw new Exception("服务尚未启动完成");
        }
    }

    #region 注册程序集
    /// <summary>
    /// 注册程序集
    /// </summary>
    /// <param name="serviceAssembly">服务程序集</param>
    public static void RegisterAssembly(Assembly serviceAssembly)
    {
        Type[] typeArr = serviceAssembly.GetTypes();

        foreach (Type type in typeArr)
        {
            if (type.GetCustomAttribute<RegisterServiceAttribute>() != null && !type.IsAbstract)
            {
                _builder.RegisterType(type).SingleInstance().AsImplementedInterfaces().AsSelf();
            }
            else
            {
                Type[] interfaceTypes = type.GetInterfaces();
                foreach (Type interfaceType in interfaceTypes)
                {
                    if (interfaceType.GetCustomAttribute<RegisterServiceAttribute>() != null && !type.IsAbstract)
                    {
                        _builder.RegisterType(type).SingleInstance().AsImplementedInterfaces().AsSelf();
                        break;
                    }
                }
            }
        }

        //_container = _builder.Build();
    }
    #endregion

    #region 启动所有服务
    /// <summary>
    /// 启动所有服务
    /// </summary>
    public static async Task StartAllService()
    {
        Type iServiceInterfaceType = typeof(IService);
        IEnumerable<Type> types = _container.ComponentRegistry.Registrations.Select(a => a.Activator.LimitType);
        await Parallel.ForEachAsync(types, async (type, c) =>
        {
            if (iServiceInterfaceType.IsAssignableFrom(type))
            {
                object obj = _container.Resolve(type);

                try
                {
                    IService service = obj as IService;
                    await service.OnStart();
                    LogUtil.Info("服务 " + obj.GetType().FullName + " 已启动");
                }
                catch (Exception ex)
                {
                    LogUtil.Error(ex, "服务 " + obj.GetType().FullName + " 启动失败");
                }
            }
        });
        _isRunning = true;
    }
    #endregion

    #region 停止所有服务
    /// <summary>
    /// 停止所有服务
    /// </summary>
    public static async Task StopAllService()
    {
        Type iServiceInterfaceType = typeof(IService);
        IEnumerable<Type> types = _container.ComponentRegistry.Registrations.Select(a => a.Activator.LimitType);
        await Parallel.ForEachAsync(types, async (type, c) =>
        {
            if (iServiceInterfaceType.IsAssignableFrom(type))
            {
                object obj = _container.Resolve(type);
                IService service = obj as IService;

                try
                {
                    await service.OnStop();
                    LogUtil.Info("服务 " + obj.GetType().FullName + " 已停止");
                }
                catch (Exception ex)
                {
                    LogUtil.Error(ex, "服务 " + obj.GetType().FullName + " 停止失败");
                }
            }
        });
        _isRunning = false;
    }
    #endregion

}

ServiceFactory的简写类

/// <summary>
/// ServiceFactory的简写
/// </summary>
public class SF
{
    /// <summary>
    /// 获取服务
    /// </summary>
    /// <typeparam name="T">接口类型</typeparam>
    public static T Get<T>()
    {
        return ServiceFactory.Get<T>();
    }

    /// <summary>
    /// 获取服务
    /// </summary>
    /// <param name="type">接口类型</param>
    public static object Get(Type type)
    {
        return ServiceFactory.Get(type);
    }
}

编写服务类

服务类示例1

/// <summary>
/// 测试服务
/// </summary>
public class TestService : ServiceBase
{
    public async Task<string> GetValue()
    {
        return await Task.FromResult("测试数据");
    }
}

服务类示例2

重写了OnStart和OnStop以实现服务的启动和停止。

/// <summary>
/// 定时任务管理
/// </summary>
public class ScheduleJobs : ServiceBase
{
    #region 变量
    private IScheduler _scheduler;
    #endregion

    #region OnStart
    public override async Task OnStart()
    {
        try
        {
            NameValueCollection options = new NameValueCollection();
            string schedulerName = "DefaultQuartzScheduler";
            options.Add("quartz.scheduler.instanceName", schedulerName);
            StdSchedulerFactory schedulerFactory = new StdSchedulerFactory(options);
            _scheduler = await schedulerFactory.GetScheduler(schedulerName);
            if (_scheduler == null)
            {
                _scheduler = await schedulerFactory.GetScheduler();
            }
            await _scheduler.Start();
            AddJobs(_scheduler);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.ToString());
        }
    }
    #endregion

    #region OnStop
    public override async Task OnStop()
    {
        await _scheduler.Shutdown();
    }
    #endregion

    #region ScheduleJob
    private async Task ScheduleJob<T>(IScheduler scheduler, string cronString) where T : IJob
    {
        IJobDetail jobDetail = JobBuilder.Create<T>().Build();
        ITrigger trigger = TriggerBuilder.Create().WithCronSchedule(cronString).Build();
        await scheduler.ScheduleJob(jobDetail, trigger);
    }
    #endregion

    private async void AddJobs(IScheduler scheduler)
    {
        await ScheduleJob<TestJob>(scheduler, "0/30 * * * * ?");
    }

}

构造注入示例

[ApiController]
[Route("[controller]")]
public class TestController : ControllerBase
{
    private readonly TestService _testService;

    public TestController(TestService testService)
    {
        _testService = testService;
    }

    ...省略
}

也可以这样使用

var value = await SF.Get<TestService>().GetValue();

原文链接:https://www.cnblogs.com/s0611163/p/17356403.html

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:.NET 6 整合 Autofac 依赖注入容器 - Python技术站

(0)
上一篇 2023年5月3日
下一篇 2023年5月4日

相关文章

  • 十分钟打造AutoComplete自动完成效果代码

    AutoComplete自动完成效果是一种常见的交互式UI组件,它可以帮助用户快速找到他们正在寻找的内容。本文将提供详解如何在十分钟内打造AutoComplete自动完成效果的完整攻略,包括使用jQuery UI的autocomplete方法、使用Bootstrap的typeahead插件等。同时,本文还提供两个示例,演示如何使用jQuery UI和Boot…

    C# 2023年5月15日
    00
  • asp.net+Ligerui实现grid导出Excel和Word的方法

    下面是“asp.net+Ligerui实现grid导出Excel和Word的方法”的完整攻略。 一、前置条件 在开始实现导出Excel和Word的方法前,需要确保已经安装了以下环境: Visual Studio以及.NET Framework Ligerui框架 二、实现导出Excel和Word的方法 1. 导出Excel 步骤一:添加NuGet包 在Vis…

    C# 2023年5月31日
    00
  • android studio集成unity导出工程的实现

    下面是详细讲解“android studio集成unity导出工程的实现”的完整攻略: 简介 在开发中,我们可能需要在Android项目中集成Unity项目,以实现更加丰富的功能和用户体验。下面我们将详细讲解如何将Unity项目导出为Android Studio项目,并在Android Studio中进行集成和开发。 Unity项目导出为Android St…

    C# 2023年5月15日
    00
  • Windows中利用计划任务实现自动备份文件

    在Windows中,可以使用计划任务(Task Scheduler)来定期自动备份文件。计划任务是Windows自带的一种工具,可以在指定的时间自动运行程序或脚本。本文将介绍如何使用计划任务实现自动备份文件的完整攻略。 步骤一:创建备份脚本 首先,需要创建一个备份脚本,用于备份指定的文件或目录。以下是一个备份脚本的示例: #!/bin/bash # 备份源目…

    C# 2023年5月15日
    00
  • 基于动态修改App.Config与web.Config的使用详解

    基于动态修改App.Config与web.Config的使用详解 在.NET应用程序中,App.Config和web.Config文件通常用于存储应用程序的配置信息。这些文件可以包含应用程序的各种设置,例如数据库连接字符串、日志级别、缓存大小等。在运行时,我们可以动态修改这些配置文件,以便在不重启应用程序的情况下更改应用程序的行为。本文将介绍如何使用C#动态…

    C# 2023年5月15日
    00
  • c#使用linq把多列的List转化为只有指定列的List

    想要使用LINQ将多列的列表转化为只有指定列的列表,可以按照以下步骤进行操作: 首先创建一个包含多列数据的列表,可以使用下面的代码创建一个实例用于演示: List<Person> persons = new List<Person>() { new Person() { Id = 1, Name = "Tom", …

    C# 2023年6月1日
    00
  • C#调用C++动态库接口函数和回调函数方法

    C#调用C++动态库接口函数和回调函数方法是一个常见的集成方式,下面是完整的攻略。 一、准备工作 在开始之前,需要先准备好以下内容: 编写C++动态库代码,并编译成DLL文件。 编写C#代码,用于调用C++动态库的接口函数和回调函数。 二、调用C++动态库接口函数 1. 导入DLL 在C#代码中导入C++动态库,可以使用DllImport特性。在此之前,需要…

    C# 2023年6月1日
    00
  • c#通用登录模块分享

    C#通用登录模块分享 在网站或应用程序中,用户通常需要进行登录才能使用其功能。为了节省开发人员的时间和精力,我们可以编写一个通用登录模块,以供多个网站或应用程序共用。本篇文章将详细介绍如何实现这个通用登录模块。 实现基础功能 创建用户表 首先,我们需要在数据库中创建一个用户表(如MySQL、SQL Server、Oracle等),用于保存用户的登录信息。用户…

    C# 2023年5月31日
    00
合作推广
合作推广
分享本页
返回顶部