1、配置文件
说明：此处有两个容器的节点，用来分别初始化两个容器，可以应对需要注入两个dbContext的情况。
代码：
创新互联-专业网站定制、快速模板网站建设、高性价比酉阳土家族苗族网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式酉阳土家族苗族网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖酉阳土家族苗族地区。费用合理售后完善，十多年实体公司更值得信赖。
2、初始化容器
说明：创建了一个枚举，用来对应配置文件中的两个节点，然后通过扩展方法获取到枚举值在配置文件中的节点名称，用来分别初始化不同的容器。
代码：
容器的工厂：
public class DIFactory
{
private static readonly object _SyncHelper = new object();
private static volatile Dictionary _UnityContainerDictionary = new Dictionary();
public static IUnityContainer GetContainer(EnContainer enContainer)
{
if (!_UnityContainerDictionary.ContainsKey(enContainer))
{
lock (_SyncHelper)
{
if (!_UnityContainerDictionary.ContainsKey(enContainer))
{
//配置UnityContainer
IUnityContainer container = new UnityContainer();
ExeConfigurationFileMap fileMap = new ExeConfigurationFileMap();
fileMap.ExeConfigFilename = Path.Combine(AppDomain.CurrentDomain.BaseDirectory + "CfgFiles\\Unity.Config");
Configuration configuration = ConfigurationManager.OpenMappedExeConfiguration(fileMap, ConfigurationUserLevel.None);
UnityConfigurationSection configSection = (UnityConfigurationSection)configuration.GetSection(UnityConfigurationSection.SectionName);
string strSection = enContainer.Speccn();
configSection.Configure(container, strSection);
_UnityContainerDictionary.Add(enContainer, container);
}
}
}
return _UnityContainerDictionary[enContainer];
}
} 枚举： public enum EnContainer
{
[Speccn("yydyoaSection")]
YYDYOA = 1,
[Speccn("managerSection")]
MANAGER = 2
} 特性： [AttributeUsage(AttributeTargets.All, AllowMultiple = false, Inherited = true)]
public class SpeccnAttribute : Attribute
{
private string Speccn { get; set; }
public SpeccnAttribute(string speccn)
{
this.Speccn = speccn;
}
public string GetSpeccn()
{
return this.Speccn;
}
} 扩展方法： public static class EnumExtend
{
public static string Speccn(this Enum enContainer)
{
Type type = enContainer.GetType();
FieldInfo field = type.GetField(enContainer.ToString());
if (field.IsDefined(typeof(SpeccnAttribute), true))
{
SpeccnAttribute speccnAttribute = (SpeccnAttribute)field.GetCustomAttribute(typeof(SpeccnAttribute));
return speccnAttribute.GetSpeccn();
}
else
{
return enContainer.ToString();
}
}
}3、接口和实现类的代码
接口：
public interface IDoWork
{
string Show(string arg);
} 实现类： public class StudentDoWork : IDoWork
{
public string Show(string arg)
{
Console.WriteLine($"{this.GetType().Name}_DoWork Before");
Console.WriteLine($"{this.GetType().Name}_DoWork After");
return nameof(StudentDoWork);
}
}
public class TeacherDoWork : IDoWork
{
public string Show(string arg)
{
Console.WriteLine($"{this.GetType().Name}_DoWork");
return nameof(TeacherDoWork);
}
} 4、AOP扩展类的代码：
参数检查： public class ParameterCheckBehavior : IInterceptionBehavior
{
public bool WillExecute => true;
public IEnumerable GetRequiredInterfaces()
{
return Type.EmptyTypes;
}
public IMethodReturn Invoke(IMethodInvocation input, GetNextInterceptionBehaviorDelegate getNext)
{
Console.WriteLine("ParameterCheckBehavior");
if (input.Inputs[0].ToString().Length < 10)//可以过滤一下敏感词
{
//返回一个异常
return input.CreateExceptionMethodReturn(new Exception("密码长度不能小于10位"));
}
else
{
Console.WriteLine("参数检测无误");
return getNext().Invoke(input, getNext);
}
}
} 日志： public class LogBeforeBehavior : IInterceptionBehavior
{
public bool WillExecute => true;
public IEnumerable GetRequiredInterfaces()
{
return Type.EmptyTypes;
}
public IMethodReturn Invoke(IMethodInvocation input, GetNextInterceptionBehaviorDelegate getNext)
{
Console.WriteLine("LogBehavior before");
IMethodReturn method = getNext()(input, getNext);
Console.WriteLine("LogBehavior after");
return method;
}
} 异常： public class ExpessionBehavior : IInterceptionBehavior
{
public bool WillExecute => true;
public IEnumerable GetRequiredInterfaces()
{
return Type.EmptyTypes;
}
public IMethodReturn Invoke(IMethodInvocation input, GetNextInterceptionBehaviorDelegate getNext)
{
Console.WriteLine("ExpessionBehavior before");
IMethodReturn method = getNext()(input, getNext);
if (method.Exception != null)
Console.WriteLine($"异常:{method.Exception.Message}");
Console.WriteLine("ExpessionBehavior after");
return method;
}
} 缓存： public class CachingBehavior : IInterceptionBehavior
{
public IEnumerable GetRequiredInterfaces()
{
return Type.EmptyTypes;
}
private static Dictionary CachingBehaviorDictionary = new Dictionary();
public IMethodReturn Invoke(IMethodInvocation input, GetNextInterceptionBehaviorDelegate getNext)
{
string key = $"{input.MethodBase.Name}_{Newtonsoft.Json.JsonConvert.SerializeObject(input.Inputs)}";
if (CachingBehaviorDictionary.ContainsKey(key))
{
return input.CreateMethodReturn(CachingBehaviorDictionary[key]);
}
else
{
IMethodReturn result = getNext().Invoke(input, getNext);
if (result.ReturnValue != null)
{
CachingBehaviorDictionary.Add(key, result.ReturnValue);
Console.WriteLine("CachingBehavior");
}
return result;
}
}
public bool WillExecute
{
get { return true; }
}
} 5、测试代码 static void Main(string[] args)
{
IUnityContainer yydyoaContainer = DIFactory.GetContainer(EnContainer.YYDYOA);
IDoWork doWork = yydyoaContainer.Resolve();
doWork.Show("12345678901234");
yydyoaContainer = DIFactory.GetContainer(EnContainer.MANAGER);
doWork = yydyoaContainer.Resolve();
doWork.Show("123");
Console.ReadKey();
} 6、总结
AOP扩展的进入顺序是根据配置文件从上到下进入，业务逻辑与拓展逻辑的执行顺序是根据getNext().Invoke(input, getNext)代码的位置决定。
