|
摘要:这篇文章描述了在eclipse rcp中引入依赖注射机制的一个简单方法。为了避免污染eclipse平台的基础设施并且透明的为rcp添加ioc框架,我们使用了动态字节码操作(使用objectweb asm类库),java类加载agent以及java标注技术的组合。 eclipse胖客户端平台(rich client platform,rcp)是一个功能强大的软件基础(software foundation),它基于相互联系并协作的插件,允许开发人员创建通用的应用程序。rcp使得开发人员可以更加关注应用程序的业务逻辑而不是花大量时间来重新发明轮子去编写大量的应用程序管理逻辑。 控制翻转(ioc)和依赖注射是一种减少程序耦合性的设计模式。它们遵循了一个简单的原则:你不必自己创建对象,你只需要描述如何创建对象。你不必去实例化或者定位你的组件需要的服务,你只需要去描述哪个组件需要哪个服务,其他组件(通常是容器)来负责将它组装好。这也就是著名的好莱坞原则:不要打电话给我们,我们会打给你。 这篇文章描述了在eclipse rcp中引入依赖注射机制的一个简单方法。为了避免污染eclipse平台的基础设施并且透明的为rcp添加ioc框架,我们使用了动态字节码操作(使用objectweb asm类库),java类加载agent以及java标注技术的组合。 什么是eclipse胖客户端平台? 简单来说,eclipse胖客户端平台是一组类库,软件框架以及运行环境,它可以用来创建独立运行并且经常需要与网络交互的应用程序。 尽管eclipse是作为一个集成开发环境(ide)框架设计的,但是,从3.0版本开始,整个项目已经被重构成各种独立的组件,以便于可以使用这些组件的一个子集来构建任意的应用程序。这个子集构成了rcp,它包含以下几种组件:基本运行环境,用户接口组件(swt和jface),插件以及osgi层。图1展示了eclipse平台的主要组件。 整个eclipse平台是基于插件和扩展点(extensions points)这样一个关键概念的。一个插件是可以独立开发和发布的功能的最小单元。它一般会打包成一个jar文件并且通过增加功能来扩充eclipse平台(例如,增加一个编辑器,工具栏按钮或者一个编译器)。整个平台就是一组互相联系并通讯的一组插件的集合。一个扩展点是一个已经存在的互相联系的端点,可以被其他插件用来添加功能(功能:在eclipse术语中叫做扩展)。扩展和扩展点通过xml配置文件定义并绑定在插件中。 尽管插件已经使用了关注点分离这样一个重要的模式,但是插件之间的强相互联系和通讯会导致他们之间的强依赖关系。一个典型的例子就是需要定位应用程序需要的各种单例(singleton)服务,例如数据库连接池,日志处理器,或者用户偏爱(preference)的设置信息的保存等。控制反转和依赖注射是消除这些依赖的可行解决方案。 控制反转和依赖注射 +控制反转是一种设计模式,它主要关注如何将服务(或者应用程序组件)的定义和服务如何定位它们依赖的服务进行分离。为了完成这种分离,一般都会依赖一个容器,或者定位框架(locator framework),维护现存服务的列表+提供一种方法来将组件和它们依赖的服务绑定在一起。 +提供一种方法让应用程序代码可以请求一个已经配置好的对象(例如,一个所有依赖都已经满足的对象),这样就可以保证该对象所有相关的服务都已经可用了。 现存的框架一般都使用下面三种基本技术的组合来绑定服务和组件: +类型一(基于接口):服务对象需要实现一个专门的接口,这个接口为这些服务对象提供了一个对象,服务可以通过这个对象来查询它们的依赖。这是一些早期的容器使用的模式,例如excalibur. +类型二(基于setter):通过javabean属性的setter方法将依赖的服务赋值给服务对象。hivemind和spring都是通过这种方式来实现的。 +类型三(基于构造函数):依赖的服务通过构造函数的参数提供(不通过javabean属性暴露)。这是picocontainer使用的唯一方式。hivemind和spring也使用了这种方式。 我们将采用第二种方式的变种,通过带标注的方法来提供服务。(示例应用的源代码在资源中可以找到)。声明依赖可以采用以下方式: @injected public void aservicingmethod( service s1, anotherservice s2) { // save s1 and s2 into class variables // to use them when needed} 控制反转容器会查找injected标注并且使用需要的参数来调用这个方法。在我们为eclipse平台引入ioc的过程中,在服务和可服务对象间建立绑定关系的代码被封装在一个eclipse插件中。这个插件定义了一个扩展点(com.onjava.servicelocator.servicefactory),用来为应用程序提供服务工厂。当一个可服务对象需要配置时,插件会向工厂请求服务的实例。正如下面的代码,servicelocator类将会完成所有的工作。(我们会跳过那些处理扩展点解析的代码,因为这些代码会很简单) /** * injects the requested dependencies into the * parameter object. it scans the serviceable * object looking for methods tagged with the * {@link injected} annotation.parameter types are * extracted from the matching method. an instance * of each type is created from the registered * factories (see {@link iservicefactory})。 when * instances for all the parameter types have been * created the method is invoked and the next one * is examined. * * @param serviceable the object to be serviced * @throws serviceexception */ public static void service(object serviceable) throws serviceexception { servicelocator sl = getinstance(); if (sl.isalreadyserviced(serviceable)) { // prevent multiple initializations due to // constructor hierarchies system.out.println( "object " + serviceable + " has already been configured "); return; } system.out.println("configuring " + serviceable); // parse the class for the requested services for (method m : serviceable.getclass()。getmethods()) { boolean skip=false; injected ann=m.getannotation(injected.class) ; if (ann != null) { object[] services = new object[m.getparametertypes()。length]; int i = 0; for(class<?> klass :m.getparametertypes()){ iservicefactory factory = sl.getfactory(klass,ann.optional()); if (factory == null) { skip = true; break; } object service = factory.getserviceinstance(); // sanity check: verify that the returned // service's class is the expected one // from the method assert(service.getclass()。equals(klass) || klass.isassignablefrom(service.getclass())); services[i++] = service ; } try { if (!skip) m.invoke(serviceable, services); } catch(illegalaccessexception iae) { if (!ann.optional()) throw new serviceexception( "unable to initialize services on " + serviceable + ": " + iae.getmessage(),iae); } catch(invocationtargetexception ite) { if (!ann.optional()) throw new serviceexception( "unable to initialize services on " + serviceable + ": " + ite.getmessage(),ite); } } } sl.setasserviced(serviceable);} 既然这个服务工厂返回的服务同样可以是一个可服务对象,这个策略允许定义一种服务层次(但是,目前并不提供对循环依赖的支持)。
asm and java.lang.instrument agents 以上介绍的各种注射策略都依赖于容器的存在,依赖容器提供一个入口点来使得应用程序可以使用该入口点来请求已经得到正确配置的对象。但是,我们想在开发我们的ioc插件的时候使用一种透明的方式,这主要有两个原因:+rcp采用了复杂的classloader以及初始化策略(考虑一下createexecutableextension())来维护插件的隔离性以及可见性的限制。我们不想修改或者替代这种策略来引入我们的基于容器的初始化规则。 +对这样一个入口点(这个例子中,是service locator插件中定义的service()方法)的显式引用将会强迫应用程序开发人员采用一种显式的模式和逻辑来获取初始化的组件。这样就会有一些应用-锁定的类库出现在程序代码中。我们想要定义一个合作的插件,这个插件并不需要显示的引用这些代码。 出于以上原因,我们要引入定义在java.lang.instrument包中的java转换代理,这个包出现在j2se5.0以及以后的版本中。一个转换代理是一个实现了java.lang.instrument.classfiletransformer接口的对象,这个接口只有唯一一个方法,transform()。当一个转换器的实例注册到jvm中后,当jvm要创建任何类的时候,这个代理的transform()会被调用。转换器可以在jvm加载类之前访问这个类的字节码并且可以对其进行修改。 转换代理可以采用-javaagent:jarpath[=options]的形式的命令行参数来注册到jvm,其中jarpath是包含了这个代理类的jar文件,options是传递给该代理的一个参数字符串。这个代理jar文件使用一个特殊的manifest属性来指明真正的代理类,这个代理类必须定义一个public static void premain(string options, instrumentation inst)方法。这个premain()方法将会在应用程序的main方法被调用之前调用,并且将一个真正的变换器注册到传递进来的java.lang.instrument.instrumentation类的实例中。 在我们的示例程序中,我们定义一个代理来透明的进行字节码操作并且动态的调用我们的ioc容器(service vlocator插件)。这个代理会通过检验是否存在serviceable标注来确定一个可服务对象。然后,修改所有的构造函数来调用ioc容器的方法在对象初始化时正确地配置和初始化这个对象。 让我们假设我们有一个需要依赖于其他服务的对象(还记得injected标注吗?):@serviceablepublic class serviceableobject { public serviceableobject() { system.out.println("initializing……"); } @injected public void aservicingmethod( service s1, anotherservice s2) { // …… omissis …… }} 当它被转换代理操作以后,它的字节码会和下面这个进行正常编译的类的字节码一样:@serviceablepublic class serviceableobject { public serviceableobject() { servicelocator.service(this); system.out.println("initializing……"); } @injected public void aservicingmethod( service s1, anotherservice s2) { // …… omissis …… }} 通过这种解决方案,我们不必将对容器的依赖进行硬编码就可以配置一个可服务对象并且使他们可用。开发人员仅仅需要在可服务对象类上使用serviceable标注就可以了,变换代理的代码如下:public class ioctransformer implements classfiletransformer { public byte[] transform( classloader loader, string classname, class<?> classbeingredefined, protectiondomain protectiondomain, byte[] classfilebuffer) throws illegalclassformatexception { system.out.println("loading " + classname); classreader creader = new classreader(classfilebuffer); // parse the class file constructorvisitor cv = new constructorvisitor(); classannotationvisitor cav = new classannotationvisitor(cv); creader.accept(cav, true); if (cv.getconstructors()。size() > 0) { system.out.println("enhancing "+classname); // generate the enhanced-constructor class classwriter cw = new classwriter(false); classconstructorwriter writer = new classconstructorwriter( cv.getconstructors(), cw); creader.accept(writer, false); return cw.tobytearray(); } else return null; } public static void premain(string agentargs, instrumentation inst) { inst.addtransformer(new ioctransformer()); }} 其中constructorvisitor, classannotationvisitor, classwriter以及 classconstructorwriter这几个类使用objectweb asm类库来进行字节码操作。 asm使用访问者模式来将类数据(包括指令序列)作为事件流处理。当解码一个已经存在的类时,asm为我们产生事件流,调用我们的方法来处理事件。当生成一个新类的时候,采用相反的过程:我们产生一个事件流,asm类库将它转化成一个类。注意我们描述的这个方法并不依赖于特定的字节码类库(我们这里用了asm),其他的解决方案,例如bcel和javassist同样可以工作。 我们不想深究asm的内部机制。对于本文的目的来说,知道constructorvisitor和classannotationvisitor对象是用来确定使用了serviceable标注的类并且收集他们的构造函数就足够了。它们的代码如下: public class classannotationvisitor extends classadapter { private boolean matches = false; public classannotationvisitor(classvisitor cv) { super(cv); } @override public annotationvisitor visitannotation( string desc, boolean visible) { if (visible && desc.equals("lcom/onjava/servicelocator/annot/serviceable;")) { matches = true; } return super.visitannotation(desc, visible); } @override public methodvisitor visitmethod( int access, string name, string desc, string signature, string[] exceptions) { if (matches) return super.visitmethod( access,name,desc,signature,exceptions); else { return null; } } }public class constructorvisitor extends emptyvisitor { private set<method> constructors; public constructorvisitor() { constructors = new hashset<method>(); } public set<method> getconstructors() { return constructors; } @override public methodvisitor visitmethod( int access, string name, string desc, string signature, string[] exceptions) { type t = type.getreturntype(desc); if (name.indexof("<init>") != -1 && t.equals(type.void_type)) { constructors.add(new method(name,desc)); } return super.visitmethod( access,name,desc,signature,exceptions); }} 对于上述类收集到的每一个构造函数,使用一个classconstructorwriter类的实例来修改构造函数的字节码,注入对service locator插件的调用:com.onjava.servicelocator.servicelocator.service(this); 采用asm方式完成上述工作需要以下代码:// mv is an asm method visitor,// a class which allows method manipulationmv.visitvarinsn(aload, 0);mv.visitmethodinsn( invokestatic, "com/onjava/servicelocator/servicelocator", "service", "(ljava/lang/object;)v"); 第一个指令将第二个指令需要使用的this对象的引用放在堆栈上,第二个指令将调用servicelocator的一个静态方法。 一个示例eclipse rcp应用我们现在已经具有了所有创建应用程序的元素,我们的示例代码用来向用户显示有趣的警句和引用,就像fortune cookies一样。它包含了四个插件:+service locator插件,提供ioc框架的功能+fortuneservice插件,提供了管理fortune cookies的服务。 +fortuneinterface插件,发布访问服务需要的公共接口。 +客户端插件,作为eclipse应用在一个eclipse视图中显示格式化的警句。 我们采用的ioc设计使得服务的实现和客户端分离,服务的实现可以改变或者修改,而客户端却不受影响。 就像上面几节描述的那样,为了向用户显示警句,service locator将会将客户和服务绑定在一起。fortuneinterface仅仅定义一个公有的接口,用户可以使用它来访问cookie消息。 public interface ifortunecookie { public string getmessage();} fortune插件提供了一个简单的服务工厂来创建ifortunecookie的实现类的实例。 public class fortuneservicefactory implements iservicefactory { public object getserviceinstance() throws serviceexception { return new fortunecookieimpl(); } // …… omissis ……} 工厂作为一个eclipse扩展注册到service locator,就像它的plugin.xml中描述的一样。 <?xml version="1.0" encoding="utf-8"?><?eclipse version="3.0"?><plugin><extension point="com.onjava.servicelocator.servicefactory"> <servicefactory class="com.onjava.fortuneservice.fortuneservicefactory" id="com.onjava.fortuneservice.fortuneservicefactory" name="fortune service factory" resourceclass="com.onjava.fortuneservice.ifortunecookie"/></extension></plugin> 这里,resourceclass属性定义了这个工厂提供的服务类。描述的服务被fortuneclient插件中的eclipse视图使用。 @serviceablepublic class view extends viewpart { public static final string id = "fortuneclient.view"; private ifortunecookie cookie; @injected(optional=false) public void setdate(ifortunecookie cookie) { this.cookie = cookie; } public void createpartcontrol(composite parent){ label l = new label(parent,swt.wrap); l.settext("your fortune cookie is:/n" + cookie.getmessage()); } public void setfocus() {}} 注意要加上serviceable和injected标注来定义对其他服务的依赖,但是不需要引用提供这些服务的代码。最后的结果是createpartcontrol()可以自由得使用cookie对象而且可以保证cookie是正确初始化过的。 结论 在这篇文章中,我们讨论了如何将一种强大的设计模式(可以简化代码依赖的处理,ioc)与一种可以加速java客户端应用程序开发的技术合并在一起。虽然我没有处理更多于这个问题有关的细节,但是我也已经演示了一个示例应用如何将服务和服务客户解耦。我同时也描述了eclipse插件技术在开发客户端和服务时如何做到了关注点分离。但是,仍然有很多有趣的元素在等待我们探索,例如清除策略,用来在不需要这个服务的时候清除掉服务,或者在我们的客户插件中使用mock-up服务来进行单元测试,这些要留给读者去研究了。 resources +本文的示例代码+eclipse.org网站上的eclipse rcp教程+asm网站上的asm 2.0介绍+matrix,与java共舞+http://www.onjava.com
|