C#自定义应用程序上下文对象+IOC自己实现依赖注入

2021-04-01 02:25

阅读:611

标签:create   catch   ext.get   nts   art   ado   void   summary   项目   

以前的好多代码都丢失了,加上最近时间空一些,于是想起整理一下以前的个人半拉子项目,试试让它们重生。自从养成了架构师视觉 搭建框架之后,越来 越看不上以前搭的框架了。先撸个上下文对象加上实现依赖注入。由于还是要依赖.net 4,所以像Autofac这样的就用不了,于是仿照着实现了。

 

    /// 
    /// 自定义应用程序上下文对象
    /// 
    public class AppContextExt : IDisposable
    {
        /// 
        /// app.config读取
        /// 
        public Configuration AppConfig { get; set; }
        /// 
        /// 真正的ApplicationContext对象
        /// 
        public ApplicationContext Application_Context { get; set; }
        //服务集合
        public static Dictionary Services = new Dictionary();
        //服务订阅事件集合
        public static Dictionary>> ServiceEvents = new Dictionary>>();
        //上下文对象的单例
        private static AppContextExt _ServiceContext = null;
        private readonly static object lockObj = new object();
        /// 
        /// 禁止外部进行实例化
        /// 
        private AppContextExt()
        {
        }
        /// 
        /// 获取唯一实例,双锁定防止多线程并发时重复创建实例
        /// 
        /// 
        public static AppContextExt GetInstance()
        {
            if (_ServiceContext == null)
            {
                lock (lockObj)
                {
                    if (_ServiceContext == null)
                    {
                        _ServiceContext = new AppContextExt();
                    }
                }
            }
            return _ServiceContext;
        }
        /// 
        /// 注入Service到上下文
        /// 
        /// 接口对象
        /// Service对象
        /// 服务实例更新时订阅的消息
        public static void RegisterService(T t, Action servicesChangeEvent = null) where T : class
        {
            if (t == null)
            {
                throw new Exception(string.Format("未将对象实例化,对象名:{0}.", typeof(T).Name));
            }
            if (!Services.ContainsKey(typeof(T)))
            {
                try
                {
                    Services.Add(typeof(T), t);
                    if (servicesChangeEvent != null)
                    {
                        var eventList = new List>();
                        eventList.Add(servicesChangeEvent);
                        ServiceEvents.Add(typeof(T), eventList);
                    }
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
            if (!Services.ContainsKey(typeof(T)))
            {
                throw new Exception(string.Format("注册Service失败,对象名:{0}.", typeof(T).Name));
            }
        }
        /// 
        /// 动态注入dll中的多个服务对象
        /// 
        /// 
        public static void RegisterAssemblyServices(string serviceRuntime)
        {
            if (serviceRuntime.IndexOf(".dll") != -1 && !File.Exists(serviceRuntime))
                throw new Exception(string.Format("类库{0}不存在!", serviceRuntime));
            try
            {
                Assembly asb = Assembly.LoadFrom(serviceRuntime);
                var serviceList = asb.GetTypes().Where(t => t.GetCustomAttributes(typeof(ExportAttribute), false).Any()).ToList();
                if (serviceList != null && serviceList.Count > 0)
                {
                    foreach (var service in serviceList)
                    {
                        var ifc = ((ExportAttribute)service.GetCustomAttributes(typeof(ExportAttribute), false).FirstOrDefault()).ContractType;
                        //使用默认的构造函数实例化
                        var serviceObject = Activator.CreateInstance(service, null);
                        if (serviceObject != null)
                            Services.Add(ifc, serviceObject);
                        else
                            throw new Exception(string.Format("实例化对象{0}失败!", service));
                    }
                }
                else
                {
                    throw new Exception(string.Format("类库{0}里没有Export的Service!", serviceRuntime));
                }
            }
            catch (Exception ex)
            { 
                throw ex;
            } 
        }
        /// 
        /// 获取Service的实例
        /// 
        /// 接口对象
        /// 
        public static T Resolve()
        {
            if (Services.ContainsKey(typeof(T)))
                return (T)Services[typeof(T)];
            return default(T);
        }
        /// 
        /// 重置Service对象,实现热更新
        /// 
        /// 接口对象
        /// 新的服务对象实例
        public static void ReLoadService(T t)
        {
            if (t == null)
            {
                throw new Exception(string.Format("未将对象实例化,对象名:{0}.", typeof(T).Name));
            }
            if (Services.ContainsKey(typeof(T)))
            {
                try
                {
                    Services[typeof(T)] = t;
                    if (ServiceEvents.ContainsKey(typeof(T)))
                    {
                        var eventList = ServiceEvents[typeof(T)];
                        foreach (var act in eventList)
                        {
                            act.Invoke(t);
                        }
                    }
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
            else if (!Services.ContainsKey(typeof(T)))
            {
                throw new Exception(string.Format("Service实例不存在!对象名:{0}.", typeof(T).Name));
            }
        }
        /// 
        /// 激活上下文
        /// 
        public void Start()
        {
            GetInstance();
        }
        /// 
        /// 激活上下文
        /// 
        /// 真正的ApplicationContext对象
        public void Start(ApplicationContext appContext)
        {
            Application_Context = appContext;
            GetInstance();
        }
        /// 
        /// 激活上下文
        /// 
        /// Configuration
        public void Start(Configuration config)
        {
            AppConfig = config;
            GetInstance();
        }
        /// 
        /// 激活上下文
        /// 
        /// 真正的ApplicationContext对象
        /// Configuration
        public void Start(ApplicationContext appContext, Configuration config)
        {
            AppConfig = config;
            Application_Context = appContext;
            GetInstance();
        }
        /// 
        /// Using支持
        /// 
        public void Dispose()
        {
            Services.Clear();
            ServiceEvents.Clear();
            if (Application_Context != null)
            {
                Application_Context.ExitThread();
            }
        }
    }

使用:

 AppContextExt.GetInstance().Start();
            AppContextExt.RegisterAssemblyServices(AppDomain.CurrentDomain.BaseDirectory + "ModuleService.dll");
ILogService svr = AppContextExt.Resolve();
            if (svr != null)
                svr.LogInfo("OK");

解决方案截图:

技术分享图片

C#自定义应用程序上下文对象+IOC自己实现依赖注入

标签:create   catch   ext.get   nts   art   ado   void   summary   项目   

原文地址:https://www.cnblogs.com/datacool/p/datacool_AppContext_IOC.html


评论


亲,登录后才可以留言!