.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日

相关文章

  • C#实现简单飞行棋小游戏

    首先来讲一下“C#实现简单飞行棋小游戏”的完整攻略。 简介 飞行棋,是一种以飞行为主题的棋类游戏,是一种常见的亲子游戏。游戏规则简单、易于上手,非常适合大众化的群体。 游戏规则 游戏地图共有 100 个格子,分别标记着不同的内容,如酒驾、炸弹、地雷、停机坪、幸福、喜事等等。同时,每个玩家有 4 个棋子,起点和终点不同,各自从起点进入,经过终点,返回起点,先完…

    C# 2023年6月7日
    00
  • C# 生成验证码取随机数字加字母(改进版)

    生成验证码是图片验证码的一种,常用于防止机器人恶意注册、登录等场景。在C#中生成验证码,可以使用System.Drawing类库,通过画布绘制字符、干扰线等实现。本攻略将讲解如何生成具有随机数字和字母的验证码,并介绍针对该实现方案的优化方案。 1. 实现随机数字和字母生成函数 首先,我们需要实现一个函数,用于生成指定长度的随机数字和字母组合。可以使用Rand…

    C# 2023年6月1日
    00
  • Entity Framework Core种子数据Data-Seeding

    Entity Framework Core 种子数据(Data Seeding)可以帮助开发者在应用程序中使用预定义的数据填充数据库。本篇文章将从概览、设计、实现等方面详细地介绍 Entity Framework Core 种子数据的完整攻略,包括,如何配置数据模型和 DbContext,如何添加种子数据,以及如何在应用启动时自动应用种子数据等。 1. 概述…

    C# 2023年6月3日
    00
  • c#基础之数组与接口使用示例(遍历数组 二维数组)

    我很乐意为您讲解“c#基础之数组与接口使用示例(遍历数组 二维数组)”,以下是详细攻略: 一、先了解什么是数组 在编程中,我们需要用到一种有序的数据结构,即数组。数组是一种由相同类型的元素组成的有序集合。每个元素在数组中都有一个唯一的序号,称为下标,通过下标可以访问到数组中的元素。在C#中,数组是引用类型,需要使用new运算符来创建数组对象。 以下是一个简单…

    C# 2023年6月1日
    00
  • C# 串口通信

    这里浅说一下蓝牙与串口的区别:         蓝牙:连接以mac地址为主,显示名称可以更改,低功耗蓝牙还需要配置服务与特征(服务有读,写,可读可写区别) 特点:不同设备连接同一台蓝牙设备,mac地址与显示名称都是唯一的         串口:连接以端口名称为主,例如com1,com2,连接时需要配置参数较多 特点:不同设备接入同一个串口模块,显示的名称可能…

    C# 2023年5月5日
    00
  • c# 几个常见的TAP异步操作

    关于C#中常见的TAP异步操作,我们可以分为如下几个方面进行详细讲解: 1. TAP(Task-based Asynchronous Pattern)异步操作 TAP即Task-based Asynchronous Pattern,是一种处理异步操作的方法模式,它可以方便地将异步操作以任务(Task)的形式进行组织和管理。一般地,TAP异步操作包含以下几个步…

    C# 2023年6月6日
    00
  • WinForm调用百度地图接口用法示例

    下面是关于“WinForm调用百度地图接口用法示例”的完整攻略。 什么是百度地图接口? 百度地图接口是百度提供的用于开发者在自己的应用中集成百度地图功能的一组API,通过它可以满足不同应用场景的地图需求,包括地图显示、POI搜索、路径规划、定位等功能。 WinForm调用百度地图接口用法示例 步骤1:申请百度地图开发者账号 在开始使用百度地图接口之前,需要先…

    C# 2023年6月6日
    00
  • C# Partial:分部方法和分部类代码实例

    下面是详细讲解“C# Partial:分部方法和分部类代码实例”的完整攻略: 概述 C# Partial 是一种将类或方法分成多个部分的技术。在大型项目中,为了方便管理和维护,可以将类或者方法按照功能或者逻辑进行划分,分成多个文件进行编写。这时就需要用到 C# Partial 技术。 C# Partial 分部类 1. 定义 C# Partial 分部类是指…

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