前言
一行業(yè)務(wù)代碼還沒寫，框架代碼一大堆，不利于學(xué)習(xí)。
?？吹絡(luò)ava的學(xué)習(xí)資料或博客，標(biāo)題一般為《SpringBoot 整合 XXX》，所以仿照著寫了《.NET 6 整合 Autofac 依賴注入容器》這樣一個(gè)標(biāo)題。
以下是我自己的用法，可能不是最佳實(shí)踐。
一. 引用包
NuGet搜索并安裝：
Autofac
Autofac.Extensions.DependencyInjection文章來源：http://www.zghlxwxcb.cn/news/detail-426026.html
二. 配置代碼
var builder = WebApplication.CreateBuilder(args);
...省略
// ASP.NET Core整合Autofac
builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());//通過工廠替換，把Autofac整合進(jìn)來
builder.Host.ConfigureContainer<ContainerBuilder>(containerBuilder =>
{
ServiceFactory.SetBuilder(containerBuilder);
ServiceFactory.RegisterAssembly(Assembly.GetExecutingAssembly()); //注冊服務(wù)
});
var app = builder.Build();
ServiceFactory.SetContainer((app.Services as AutofacServiceProvider).LifetimeScope as IContainer);
Task.Run(async () => await ServiceFactory.StartAllService()); //啟動服務(wù)，注意：服務(wù)啟動完成之前，調(diào)用接口會異常
...省略
三. 服務(wù)的自動注冊、啟動、停止
IService接口
/// <summary>
/// 服務(wù)接口
/// </summary>
public interface IService
{
/// <summary>
/// 服務(wù)啟動
/// </summary>
Task OnStart();
/// <summary>
/// 服務(wù)停止
/// </summary>
Task OnStop();
}
RegisterServiceAttribute特性
/// <summary>
/// 注冊為服務(wù)
/// </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服務(wù)工廠類
public class ServiceFactory
{
private static ContainerBuilder _builder;
private static IContainer _container;
private static bool _isRunning; //服務(wù)是否正在運(yùn)行
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>
/// 獲取服務(wù)
/// </summary>
/// <typeparam name="T">接口類型</typeparam>
public static T Get<T>()
{
if (_isRunning)
{
return _container.Resolve<T>();
}
else
{
throw new Exception("服務(wù)尚未啟動完成");
}
}
/// <summary>
/// 獲取服務(wù)
/// </summary>
/// <param name="type">接口類型</param>
public static object Get(Type type)
{
if (_isRunning)
{
return _container.Resolve(type);
}
else
{
throw new Exception("服務(wù)尚未啟動完成");
}
}
#region 注冊程序集
/// <summary>
/// 注冊程序集
/// </summary>
/// <param name="serviceAssembly">服務(wù)程序集</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 啟動所有服務(wù)
/// <summary>
/// 啟動所有服務(wù)
/// </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("服務(wù) " + obj.GetType().FullName + " 已啟動");
}
catch (Exception ex)
{
LogUtil.Error(ex, "服務(wù) " + obj.GetType().FullName + " 啟動失敗");
}
}
});
_isRunning = true;
}
#endregion
#region 停止所有服務(wù)
/// <summary>
/// 停止所有服務(wù)
/// </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("服務(wù) " + obj.GetType().FullName + " 已停止");
}
catch (Exception ex)
{
LogUtil.Error(ex, "服務(wù) " + obj.GetType().FullName + " 停止失敗");
}
}
});
_isRunning = false;
}
#endregion
}
ServiceFactory的簡寫類
/// <summary>
/// ServiceFactory的簡寫
/// </summary>
public class SF
{
/// <summary>
/// 獲取服務(wù)
/// </summary>
/// <typeparam name="T">接口類型</typeparam>
public static T Get<T>()
{
return ServiceFactory.Get<T>();
}
/// <summary>
/// 獲取服務(wù)
/// </summary>
/// <param name="type">接口類型</param>
public static object Get(Type type)
{
return ServiceFactory.Get(type);
}
}
編寫服務(wù)類
服務(wù)類示例1
/// <summary>
/// 測試服務(wù)
/// </summary>
public class TestService : ServiceBase
{
public async Task<string> GetValue()
{
return await Task.FromResult("測試數(shù)據(jù)");
}
}
服務(wù)類示例2
重寫了OnStart和OnStop以實(shí)現(xiàn)服務(wù)的啟動和停止。文章來源地址http://www.zghlxwxcb.cn/news/detail-426026.html
/// <summary>
/// 定時(shí)任務(wù)管理
/// </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 * * * * ?");
}
}
構(gòu)造注入示例
[ApiController]
[Route("[controller]")]
public class TestController : ControllerBase
{
private readonly TestService _testService;
public TestController(TestService testService)
{
_testService = testService;
}
...省略
}
也可以這樣使用
var value = await SF.Get<TestService>().GetValue();
到了這里，關(guān)于.NET 6 整合 Autofac 依賴注入容器的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
