ToB企服应用市场:ToB评测及商务社交产业平台

标题: 聊一聊为什么我要整合Microsoft.Extensions.DependencyInjection和Castle.C [打印本页]
作者: 张春    时间: 2024-4-4 15:20
标题: 聊一聊为什么我要整合Microsoft.Extensions.DependencyInjection和Castle.C
前言

如果用到动态代理，大家可能会有几种选择，排到前列的是Autofac+Castle、AspectCore和DoraInterception,
我将从我当时研究的经历，以及我遇到的场景，为大家展示下
聊一聊我为什么要费时费力的整合Microsoft.Extensions.DependencyInjection和Castle.Core
当时遇到的场景

直接上源码
  1.   public interface IEventHandler
  2.   {
  3.       Task<bool> HandleAsync(IEvent @event);
  5.       bool CanHandle(IEvent @event);
  6.   }
  8.   public interface IEventHandler<T> : IEventHandler
  9.       where T : class, IEvent
  10.   {
  11.       Task<bool> HandleAsync(T @event);
  13.       bool IEventHandler.CanHandle(IEvent @event) => @event.GetType() == typeof(T);//语言特性：默认实现 2024-1-15 10:23:10
  15.       Task<bool> IEventHandler.HandleAsync(IEvent @event) => CanHandle((T)@event) //语言特性：默认实现 2024-1-15 10:23:10
  16.           ? HandleAsync((T)@event)
  17.           : Task.FromResult(false);
  18.   }
  20. public interface IEvent
  21. {
  22.      public long Id { get; set; }
  23.      public DateTime OccurredOn { get; set; }
  24. }
复制代码
如上所示的接口定义了一个事件处理接口，其中HandleAsync方法是事件处理的入口，CanHandle方法用于判断事件是否可以处理，在程序解耦、异步、削峰填谷等场景中，如上的接口可以有很多的应用，也可以扩展到内存级别、RabbitMQ、Redis、Kafka、RocketMQ等中间件的适配的事件处理器，以提供更强大的性能和更丰富的应用场景。所以说这是一个比较通用的场景。
我们将为该处理器提供一个检查幂等的拦截器( Idempotent)
AspectCore

事件定义如下
  1. public class CatchLoggingOccurredEvent : IEvent
  2. {
  3.      protected CatchLoggingOccurredEvent()
  4.      {
  5.          OccurredOn = DateTime.Now;
  6.      }
  8.      public CatchLoggingOccurredEvent(long id)
  9.          : this()
  10.      {
  11.          Id = id;
  12.      }
  14.      public long Id { get; set; }
  15.      public DateTime OccurredOn { get; set; }
  16. }
复制代码
事件处理器及Aspecore定义的特性
  1. /// <summary>
  2. ///
  3. /// </summary>
  4. public class CatchLoggingOccurredEventHandler
  5. : IEventHandler<CatchLoggingOccurredEvent>
  6. {
  7.     [Idempotent]
  8.     public async virtual Task<bool> HandleAsync(CatchLoggingOccurredEvent @event)
  9.     {
  10.         await Console.Out.WriteLineAsync($"{nameof(CatchLoggingOccurredEventHandler)}处理事件：\t事件【{@event.Id}】@@@@@@发生于【{@event.OccurredOn}】");
  11.         return true;
  12.     }
  13. }
  14. [AttributeUsage(AttributeTargets.Method, AllowMultiple = false, Inherited = false)]
  15. internal class IdempotentAttribute
  16.      : AbstractInterceptorAttribute
  17. {
  18.      public override async Task Invoke(AspectContext context, AspectDelegate next)
  19.      {
  20.          var logger = context.ServiceProvider.GetRequiredService<ILogger<IdempotentAttribute>>();
  21.          logger.LogInformation("幂等检查");
  22.          await next(context);
  23.      }
  24. }
复制代码
执行
报错如下
System.TypeLoadException:“Declaration referenced in a method implementation cannot be a final method.  Type: 'AspectCore.DynamicGenerated.CatchLoggingOccurredEventHandler'.  Assembly: 'AspectCore.DynamicProxy.Generator, Version=0.0.0.0, Culture=neutral, PublicKeyToken=null'.”
应该是AspectCore认为我的handle方法为一个不可覆写的方法所以抛错，该问题我已提issue至 https://github.com/dotnetcore/AspectCore-Framework/issues/319 等待解决
DoraInterception
  1. /// <summary>
  2. ///
  3. /// </summary>
  4. public class CatchLoggingOccurredEventHandler
  5. : IEventHandler<CatchLoggingOccurredEvent>
  6. {
  7.      private readonly ILogger<CatchLoggingOccurredEventHandler> _logger;
  9.      public CatchLoggingOccurredEventHandler(ILogger<CatchLoggingOccurredEventHandler> logger)
  10.      {
  11.          _logger = logger;
  12.      }
  14.      [Idempotent]
  15.      public async virtual Task<bool> HandleAsync(CatchLoggingOccurredEvent message)
  16.      {
  17.          await Console.Out.WriteLineAsync($"{nameof(CatchLoggingOccurredEventHandler)}处理事件：\t事件【{message.Id}】@@@@@@发生于【{message.OccurredOn}】");
  18.          return true;
  19.      }
  20. }
  21. [AttributeUsage(AttributeTargets.Method, AllowMultiple = false, Inherited = false)]
  22. internal class IdempotentAttribute
  23.     : InterceptorAttribute
  24. {
  25.     /// <summary>
  26.     ///
  27.     /// </summary>
  28.     /// <param name="invocationContext"></param>
  29.     /// <returns></returns>
  30.     public async ValueTask InvokeAsync(InvocationContext invocationContext)
  31.     {
  32.         var logger = invocationContext.InvocationServices.GetRequiredService<ILogger<IdempotentAttribute>>();
  33.         logger.LogInformation("幂等检查");
  34.         await invocationContext.ProceedAsync();
  35.     }
  36. }
复制代码
执行 报错如下：Dora.Interception.InterceptionException:“It fails to generate proxy class.   (69,130): error CS0234: 命名空间“Microsoft.Extensions”中不存在类型或命名空间名“Logging”(是否缺少程序集引用?) (69,220): error CS0012: 类型“ILogger”在未引用的程序集中定义。必须添加对程序集“Microsoft.Extensions.Logging.Abstractions, Version=6.0.0.0, Culture=neutral, PublicKeyToken=adb9793829ddae60”的引用。”
dorainterception 使用 SourceGenerator，这个技术处理的复杂度比较高，根据报错是 处理器中依赖的Logging组件无法解析，这个问题比较严重，因为依赖注入这个太重要了。该问题见于 pr https://github.com/jiangjinnan/Dora/pull/13
Autofac+Castle

为什么不想使用Autofac,笔者的考虑是Autofac虽然功能繁多，但是其实真正实际能用到的功能少之又少，大部分的功能都可以自己扩展出来。
借用下 https://github.com/dadhi/DryIoc  的一张性能比拼图

可见其实我们已经手握了一个高性能而且简单易用易扩展的ioc框架，合并要去另寻他处，如果因为AOP技术选型的原因,选择了autofac+Castle，那何不试下 整合 Microsoft.Extensions.DependencyInjection和Castle.Core
综上

截止发稿为止，已经将本系列文章的研究成果总结至 https://github.com/gainorloss/microsoft-castle.git，并以发nuget至 https://www.nuget.org/packages/CastleCore.Extensions.DependencyInjection/1.1.0，
基准测试结果差强人意。castle代理的性能是原生的几百倍分之一，考虑到castle的广泛受众和稳定性，可堪一用。
本文但图一乐，请各位看官谨慎采纳，有意见请留言。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4