spring dm

OSGi Service Registery你知多少

http://www.cnblogs.com/ygyinx/archive/2012/10/27/2742347.html

1.    发布服务可以关联一些属性。

<service ref="beanToBeExported" interface="com.xyz.MyServiceInterface"> 
    <service-properties> 
        <beans:entry key="myOtherKey" value="aStringValue"/> 
        <beans:entry key="aThirdKey" value-ref="beanToExposeAsProperty"/> 
    </service-properties> 
</service>

2.    每个以Spring Bean发布成服务都会有一个属性名为org.springframework.osgi.bean.name,对应的值为目标Bean的name。

<service ref="beanToPublish" interface="com.xyz.MessageService"/>

这个服务就会有一个属性org.springframework.osgi.bean.name,值为beanToPublish。 

3.    Spring DM引入一种Bean的作用域,叫bundle scope。当导出服务的Bean加了这个作用域后,导入这个服务的Bundle会创建一个新的服务Bean实例。

<service ref="beanToBeExported" interface="com.xyz.MessageService"/>
<bean id="beanToBeExported" scope="bundle" class="com.xyz.MessageServiceImpl"/>

4.    Controlling The Set Of Advertised Service Interfaces For An Exported Service.

当有一个Bean服务存在多个接口时,需要将接口都导出:

<service ref="beanToBeExported"> 
  <interfaces> 
    <value>com.xyz.MessageService</value> 
    <value>com.xyz.MarkerInterface</value> 
  </interfaces> 
</osgi:service>


or

<service ref="beanToBeExported" auto-export="interfaces"/>

auto-export有四种值:

disabled :如果 auto-export 属性未被指定,则该选项为默认值。接口列表必须使用interface 属性或 interfaces 子元素指定。 
interfaces :使用由服务类或其任何超类实现的所有公共接口注册服务。 
class-hierarchy :使用服务类或其任何公共超类注册服务。 
all-classes :结合 interfaces 和 class-hierarchy 选项。

注册服务的一些属性:

depends-on :

<service ref="beanToBeExported" interface="com.xyz.MyServiceInterface" depends-on="myOtherComponent"/>

配置beanToBeExported服务所依赖的组件myOtherComponent初始化。

context-class-loader :

用于配置使用第三方的classloader来加载服务。

ranking :

默放为0,如果存在多个可用的服务接口,那么返回具有最大的ranking值的服务。如果ranking值相同,刚返回service id小的那个。

<service ref="beanToBeExported" interface="com.xyz.MyServiceInterface"  ranking="9"/>

5.    多接口服务引用

<reference id="importedOsgiService"> 
  <interfaces> 
    <value>com.xyz.MessageService</value> 
    <value>com.xyz.MarkerInterface</value> 
  </interfaces> 
</reference>

这个reference的Bean是实现了MessageService,MarkerInterface接口的。

引用服务的一些属性 

filter属性

<reference id="asyncMessageService" interface="com.xyz.MessageService" filter="(asynchronous-delivery=true)"/>

过滤服务属性asynchronous-delivery为true的服务。

bean-name属性

<osgi:reference id="messageService" interface="com.xyz.MessageService" bean-name="messageServiceBean"/>

返回服务Bean的Id为messageServiceBean的服务。

cardinality属性

<osgi:reference id="messageService" interface="com.xyz.MessageService" cardinality="1..1"/>

默认值为1..1,说明总是有一个这样的服务存在。0..1说明不需要一直存在这样一个服务。

depends-on:

当depends-on属性Bean实例化后,这个服务才能查找该服务。

context-class-loader:

与上对应。如果两边都有,最后启作用的是exporter那端的。

timeout:

等待服务多少秒,默认300秒。 

List,set引用服务支持属性

interface filter bean-name cardinality context-class-loader

cardinality取值为0..N,1..N,前面说明可以不存在,后面说明至少存在一个。 

注意: 当一个Bundle暴露SubInterface接口服务,而另一个Bundle引入SuperInterface接口是不匹配的。

当注册的服务中有接口,类等,能通过greedy-proxying创建代理访问导入服务中的的所有包含在该Bundle中类。

<list id="services" interface="com.xyz.SomeService" greedy-proxying="true"/>
for (Iterator iterator = services.iterator(); iterator.hasNext();) { 
  SomeService service = (SomeService) iterator.next(); 
  service.executeOperation(); 
  // if the service implements an additional type 
  // do something extra 
  if (service instanceof MessageDispatcher) { 
    ((MessageDispatcher)service).sendAckMessage(); 
  } 
}

6.    服务监听Service Listener:

<service ref="beanToBeExported" interface="SomeInterface"> 
    <registration-listener ref="myListener" registration-method="serviceRegistered" unregistration-method="serviceUnregistered"/>
  <registration-listener registration-method="register">
    <bean class="SomeListenerClass"/>
  </registration-listener> 
</service>

public void anyMethodName(ServiceType serviceInstance, Map serviceProperties); 
public void anyMethodName(ServiceType serviceInstance, Dictionary serviceProperties);

ServiceType为服务接口interface,serviceProperties保存着这个服务的所有属性,兼容性考虑的话,可以选Dictionary。 
有另一种方法,不鼓励这样用,那就是实现Spring DM特定接口OsgiServiceRegistrationListener,这样做的好处是省去了声明registration-method,unregistration-method,坏处是你的类与Spring有引用关系,与JAVA简单POJO类编程。

Dealing With The Dynamics Of OSGi Imported Services 
An example of declaring a listener that implements OsgiServiceLifecycleListener:

<reference id="someService" interface="com.xyz.MessageService">
    <listener ref="aListenerBean"/>
</reference>

An example of declaring an inline listener bean with custom bind and unbind methods: 

<reference id="someService" interface="com.xyz.MessageService">
    <listener bind-method="onBind" unbind-method="onUnbind">
        <beans:bean class="MyCustomListener"/>
    </listener>
</reference>

Listener Attributes:

ref bind-method unbind-mehtod

Listener And Service Proxies:

Spring管理这个服务,但是调用这个服务的时候实质是一个代理。这样做的原因是防止Listener持有一个服务的强引用。Lisenter感兴趣的是监听服务而不是依赖对等实例,更加关注服务接口,而不是他的身份,服务属性和服务跟踪。

7.    服务引用可以排序

<set id="myServices" interface="com.xyz.MyService" comparator-ref="someComparator"/> 
    <list id="myOtherServices" interface="com.xyz.OtherService"> 
    <comparator> 
        <beans:bean class="MyOtherServiceComparator"/> 
    </comparator> 
</list>

Comparator-ref是一个实现了java.util.Comparator接口的Bean。

<list id="myServices" interface="com.xyz.MyService"> 
  <comparator><natural basis="services"/></comparator> 
</list> 
<set id="myOtherServices"interface="com.xyz.OtherService"> 
  <comparator><natural basis="service-references"/></comparator> 
</set>

默认提供的一些排序,详细可以去了解下。

服务最佳实践

1.    在listener中不要执行太长的活动,因为这个方法是同步的,太长将会影响这个listener监听其他事件。 
2.    创建自己的listener,不要引用Spring DM 的API。 
3.    如果listener重复声明bind/unbind方法,可以考虑写一个通用的可重用的Bean。 
4.    服务属性优先java.util.Map而不是java.util.Dictionary。 
5.    重载方法要小心,因为当服务类型匹配方法服务类型的时候,该方法就会执行

public class MyListener { 
       void register(Object service, Map properties); 
       void register(Collection dataService, Map properties); 
       void register(SortedSet orderedDataService , Map properties); 
  }

Object type - will match all services for which the listener is triggered. This method will be always called. 
Collection type - if this method is called, the Object method is also called. 
SortedSet type - if this method is called, then both the Object and Collection methods are called. 

Service Importer Global Defaults

default-timeout
<beans xmlns="http://www.springframework.org/schema/beans" 
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
         xmlns:osgi="http://www.springframework.org/schema/osgi"                                                
         osgi:default-timeout="5000">                                                                      
     <reference id="someService" interface="com.xyz.AService"/>
     <reference id="someOtherService" interface="com.xyz.BService" timeout="1000"/>
</beans:beans>

default-cardinality
<beans:beans 
         xmlns="http://www.springframework.org/schema/osgi"                                                     
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
         xmlns:beans="http://www.springframework.org/schema/beans"                                              
         xmlns:osgi="http://www.springframework.org/schema/osgi"                                                
         osgi:default-cardinality="0..X"                                                                    
         default-lazy-init="false">                                                                         

  <reference id="someService" interface="com.xyz.AService"/>
  <set id="someSetOfService" interface="com.xyz.BService"/>
  <list id="anotherListOfServices" interface="com.xyz.CService" cardinality="1..N"/>                        
</beans:beans>

相关推荐