Castle IOC容器实践之Startable Facility(二)

本文涉及的产品
容器镜像服务 ACR,镜像仓库100个 不限时长
简介:



摘要:在Castle IOC容器实践之Startable Facility(一)中我们已经学会了如何去使用Startable Facility,本文将在此基础进一步对它的原理做一些分析。

 
主要内容
Startable Facility 原理分析
……
 
Castle IOC容器实践之Startable Facility(一)中我们已经看到了如何去使用Startable Facility,本文将对它的原理做一些分析。先看一下接口IStartable,它的实现代码如下:
public   interface  IStartable
{
    
void Start();

    
void Stop();
}

代码是相当的简单,只有两个方法,分别在组件创建的时候和销毁的时候执行,这就涉及到了组件的生命周期管理。在 Windsor中,接口 ILifecycleConcern 提供特定的组件生命周期管理:
public   interface  ILifecycleConcern
{
    
void Apply( ComponentModel model, object component );

}

现在我们要实现组件的自动创建和销毁,就需要实现接口 ILifecycleConcern ,在 Startable Facility 中分别用两个类来实现,第一个类StartConcern,它判断如果组件实现了接口IStartable,则直接调用它的Start()方法;如果组件是用特性startMethod,则获取并调用具有startMethod特性的方法:
public   class  StartConcern : ILifecycleConcern
{
    
private static readonly StartConcern _instance = new StartConcern();

    
protected StartConcern()
    
{

    }


    
public static StartConcern Instance
    
{
        
get return _instance; }
    }


    
public void Apply(ComponentModel model, object component)
    
{
        
if (component is IStartable)
        
{
            (component 
as IStartable).Start();
        }

        
else if (model.Configuration != null)
        
{
            String startMethod 
= model.Configuration.Attributes["startMethod"];
 
            
if (startMethod != null)
            
{

                MethodInfo method 
= model.Implementation.GetMethod(startMethod);

                method.Invoke(component, 
null);
            }

        }

    }

}

第二个类是 StopConcern ,它判断如果组件实现了接口IStartable,则直接调用它的Stop()方法;如果组件是用特性stopMethod,则获取并调用具有stopMethod特性的方法:
public   class  StopConcern : ILifecycleConcern
{
    
private static readonly StopConcern _instance = new StopConcern();

    
protected StopConcern()
    
{

    }


    
public static StopConcern Instance
    
{
        
get return _instance; }
    }


    
public void Apply(ComponentModel model, object component)
    
{
        
if(component is IStartable)
        
{
            (component 
as IStartable).Stop();
        }

        
else if (model.Configuration != null)
        
{
            String stopMethod 
= model.Configuration.Attributes["stopMethod"];

            
if (stopMethod != null)
            
{
                MethodInfo method 
= model.Implementation.GetMethod(stopMethod);

                method.Invoke(component, 
null);
            }

        }

    }

}

好了,知道了 Startable Facility如何管理组件的生命周期,我们就来看看真正的 Startable Facility是如何实现的。每一个 Facility都是满足这样的一个继承关系:
1 Facility继承关系图
其中的Abstract Facility提供了一些默认的实现,Facility可以直接实现IFacility,也可以继承于Abstract FacilityIFacility的实现如下:
public   interface  IFacility
{
    
void Init(IKernel kernel, IConfiguration facilityConfig);


    
void Terminate();

}

那么到底如何让组件满足依赖性后就自动执行呢?注意到再 Startable FacilityInit()注册了这样的两个事件:
protected   override   void  Init()
{
    converter 
= (ITypeConverter) Kernel.GetSubSystem(SubSystemConstants.ConversionManagerKey);


    Kernel.ComponentModelCreated 
+= 

        
new ComponentModelDelegate(OnComponentModelCreated);

    Kernel.ComponentRegistered 
+= 

        
new ComponentDataDelegate(OnComponentRegistered);

}
 
分别为OnComponentModelCreatedOnComponentRegistered。当我们注册一个组件时首先会出发OnComponentRegistered事件,在它里面判断组件是否满足依赖性,如果不满足,则添加到一个等待列表中,否则就直接启动,然后再对这个等待列表进行检测,看添加改组件后,列表中是否有组件满足了依赖性:
private   void  OnComponentRegistered(String key, IHandler handler)
{
    
bool startable = (bool) handler.ComponentModel.ExtendedProperties["startable"];

    
if (startable)
    
{
        
if (handler.CurrentState == HandlerState.WaitingDependency)
        
{
            waitList.Add( handler );
        }

        
else
        
{
            Start( key );
        }

    }


    CheckWaitingList();
}


private   void  CheckWaitingList()
{
    IHandler[] handlers 
= (IHandler[]) waitList.ToArray( typeof(IHandler) );

    IList validList 
= new ArrayList();

    
foreach(IHandler handler in handlers)
    
{
        
if (handler.CurrentState == HandlerState.Valid)
        
{
            validList.Add(handler);

            waitList.Remove(handler);
        }

    }


    
foreach(IHandler handler in validList)
    
{
        Start( handler.ComponentModel.Name );
    }

}

刚才说到,如果满足了依赖性,则会请求创建这个组件:
private   void  Start(String key)
{
    
object instance = Kernel[key];
}

这时就触发了 OnComponentModelCreated事件,这时就该用到开始我们所讲的那两生命周期处理的类了:
private   void  OnComponentModelCreated(ComponentModel model)
{
    
bool startable = 

        CheckIfComponentImplementsIStartable(model) 
|| HasStartableAttributeSet(model);

    model.ExtendedProperties[
"startable"= startable;

    
if (startable)
    
{
        model.LifecycleSteps.Add( 

            LifecycleStepType.Commission, StartConcern.Instance );

        model.LifecycleSteps.Add( 

            LifecycleStepType.Decommission, StopConcern.Instance );

    }

}

首先还是先判断组件是否实现了 IStartable接口或这时候有特性 startable,如果没有那也就不用自动启动了,否则就把 StartConcernStopConcern分别注册为组件的生命周期开始行为和生命周期结束行为,(关于组件的生命周期的详细内容可以参考我前面写的 Castle IOC容器组件生命周期管理)。此时组件进入生命周期开始,会调用 StartConcernApply()方法,这时就触发组件的 Start()方法,同样在组件销毁时调用 StopConcernApply()方法,这时就会调用组件的 Stop()方法。这样就完成整个了组件的自动执行与销毁的全过程。















本文转自lihuijun51CTO博客,原文链接: http://blog.51cto.com/terrylee/67685 ,如需转载请自行联系原作者



相关文章
|
7月前
|
Kubernetes Cloud Native Docker
云原生时代的容器化实践:Docker和Kubernetes入门
【10月更文挑战第37天】在数字化转型的浪潮中,云原生技术成为企业提升敏捷性和效率的关键。本篇文章将引导读者了解如何利用Docker进行容器化打包及部署,以及Kubernetes集群管理的基础操作,帮助初学者快速入门云原生的世界。通过实际案例分析,我们将深入探讨这些技术在现代IT架构中的应用与影响。
306 2
|
1月前
|
XML Java 数据格式
Spring IoC容器的设计与实现
Spring 是一个功能强大且模块化的 Java 开发框架,其核心架构围绕 IoC 容器、AOP、数据访问与集成、Web 层支持等展开。其中,`BeanFactory` 和 `ApplicationContext` 是 Spring 容器的核心组件,分别定位为基础容器和高级容器,前者提供轻量级的 Bean 管理,后者扩展了事件发布、国际化等功能。
|
3月前
|
Ubuntu 关系型数据库 MySQL
容器技术实践:在Ubuntu上使用Docker安装MySQL的步骤。
通过以上的操作,你已经步入了Docker和MySQL的世界,享受了容器技术给你带来的便利。这个旅程中你可能会遇到各种挑战,但是只要你沿着我们划定的路线行进,你就一定可以达到目的地。这就是Ubuntu、Docker和MySQL的灵魂所在,它们为你开辟了一条通往新探索的道路,带你亲身感受到了技术的力量。欢迎在Ubuntu的广阔大海中探索,用Docker技术引领你的航行,随时准备感受新技术带来的震撼和乐趣。
181 16
|
4月前
|
监控 Kubernetes Cloud Native
基于阿里云容器服务Kubernetes版(ACK)的微服务架构设计与实践
本文介绍了如何基于阿里云容器服务Kubernetes版(ACK)设计和实现微服务架构。首先概述了微服务架构的优势与挑战,如模块化、可扩展性及技术多样性。接着详细描述了ACK的核心功能,包括集群管理、应用管理、网络与安全、监控与日志等。在设计基于ACK的微服务架构时,需考虑服务拆分、通信、发现与负载均衡、配置管理、监控与日志以及CI/CD等方面。通过一个电商应用案例,展示了用户服务、商品服务、订单服务和支付服务的具体部署步骤。最后总结了ACK为微服务架构提供的强大支持,帮助应对各种挑战,构建高效可靠的云原生应用。
|
4月前
|
监控 Cloud Native Java
基于阿里云容器服务(ACK)的微服务架构设计与实践
本文介绍如何利用阿里云容器服务Kubernetes版(ACK)构建高可用、可扩展的微服务架构。通过电商平台案例,展示基于Java(Spring Boot)、Docker、Nacos等技术的开发、容器化、部署流程,涵盖服务注册、API网关、监控日志及性能优化实践,帮助企业实现云原生转型。
|
6月前
|
人工智能 运维 监控
阿里云ACK容器服务生产级可观测体系建设实践
本文整理自2024云栖大会冯诗淳(花名:行疾)的演讲,介绍了阿里云容器服务团队在生产级可观测体系建设方面的实践。冯诗淳详细阐述了容器化架构带来的挑战及解决方案,强调了可观测性对于构建稳健运维体系的重要性。文中提到,阿里云作为亚洲唯一蝉联全球领导者的容器管理平台,其可观测能力在多项关键评测中表现优异,支持AI、容器网络、存储等多个场景的高级容器可观测能力。此外,还介绍了阿里云容器服务在多云管理、成本优化等方面的最新进展,以及即将推出的ACK AI助手2.0,旨在通过智能引擎和专家诊断经验,简化异常数据查找,缩短故障响应时间。
阿里云ACK容器服务生产级可观测体系建设实践
|
6月前
|
存储 人工智能 调度
容器服务:智算时代云原生操作系统及月之暗面Kimi、深势科技实践分享
容器技术已经发展成为云计算操作系统的关键组成部分,向下高效调度多样化异构算力,向上提供统一编程接口,支持多样化工作负载。阿里云容器服务在2024年巴黎奥运会中提供了稳定高效的云上支持,实现了子弹时间特效等创新应用。此外,容器技术还带来了弹性、普惠的计算能力升级,如每分钟创建1万Pod和秒级CPU资源热变配,以及针对大数据与AI应用的弹性临时盘和跨可用区云盘等高性能存储解决方案。智能运维方面,推出了即时弹性节点池、智能应用弹性策略和可信赖集群托管运维等功能,进一步简化了集群管理和优化了资源利用率。
|
6月前
|
运维 Kubernetes 调度
阿里云容器服务 ACK One 分布式云容器企业落地实践
阿里云容器服务ACK提供强大的产品能力,支持弹性、调度、可观测、成本治理和安全合规。针对拥有IDC或三方资源的企业,ACK One分布式云容器平台能够有效解决资源管理、多云多集群管理及边缘计算等挑战,实现云上云下统一管理,提升业务效率与稳定性。
|
6月前
|
人工智能 Cloud Native 调度
阿里云容器服务在AI智算场景的创新与实践
本文源自张凯在2024云栖大会的演讲,介绍了阿里云容器服务在AI智算领域的创新与实践。从2018年推出首个开源GPU容器共享调度方案至今,阿里云容器服务不断推进云原生AI的发展,包括增强GPU可观测性、实现多集群跨地域统一调度、优化大模型推理引擎部署、提供灵活的弹性伸缩策略等,旨在为客户提供高效、低成本的云原生AI解决方案。
|
7月前
|
安全 持续交付 Docker
深入理解并实践容器化技术——Docker 深度解析
深入理解并实践容器化技术——Docker 深度解析
231 2