当前位置: 首页 > 工具软件 > osmp > 使用案例 >

[置顶] osgi实战项目(osmp)一步一步玩转osgi之服务发布和引用(4)

陈斌
2023-12-01

 

今天主要讲一下在osgi环境下的服务注册、和服务引用。

 

其实osgi只是一个java动态化、模块化的一系列规范,根据不同厂商制定了不同的规范,如Felix和Equinox则分别是Apache和Eclipse开源社区给出的标准规范的实现!而osgi的魅力也在于动态化和模块化,我个人认为要实现动态化最简单的就是通过classload动态加载。我个人理解而已,osgi只是在传统开发的基础上抽象了一个bundle组件的概念,每一个bundle组件都有自己的生命周期,bundle实现动态化是基于bundle classloader实现的。理论性的东西我不想讲太多,大家可以去看一下osgi基础方面的东西,如bundle生命周期,bundle classloader等内容。而服务的注册,服务的引用等内容恰恰是bundle生命周期最好的诠释!

 

先说一下osgi环境下的服务注册,其实这部分内容在第二讲的时候已经大概说过一点儿,这次我们讲解一下传统的osgi服务注册和使用框架的方式来注册等。

 

 一个bundle被部署到osgi容器里有几个最要的阶段也可以称之为bundle的生命周期,主要包括 INSTALLED(调用BundleContext.installBundle()后,会创建一个INSTALLED状态的bundle)、RESOLVED(如果其所依赖的所有bundle都存在,即解析成功,转到RESOLVED状态)、STARTING(当开始执行BundleActivator.start(),则处于STARTING状态)、ACTIVE(当执行BundleActivator.start()成功,则转到ACTIVE状态)、STOPPING(当开始执行BundleActivator.stop(),则处于STOPPING状态)、UNINSTALLED(INSTALLED状态的bundle可以被卸载,转到UNINSTALLED状态)。

可以看到一个bundle的整个生命周期都离不开BundleActivatorBundleContext 这两个类。

 

BundleContext:Bundle上下文,主要功能是与OSGI容器交互,包括服务的注册,监听器的注册,获取osgi下所有发布的服务,服务的引用等功能。建议大家好好的看一下这个类。

BundleActivator:BundleActivator是osgi提供的一个获取BundleContext的接口,同时提供bundle启动和停止的处理方法。

 

知道这两个类我们就可以实现BundleActivator 在bundle启动的时候通过BundleContext注册服务到osgi容器里以供其它bundle调用了


实现一个自定义的BundleActivator :

 

 public class HelloServiceActivator implements BundleActivator {
	ServiceRegistration serviceRegistration;
	@Override
	public void start(BundleContext context) throws Exception {
		HelloService helloService = new HelloServiceImpl();
		serviceRegistration = context.registerService(HelloService.class.getName(), helloService, null);
	}

	@Override
	public void stop(BundleContext context) throws Exception {
		serviceRegistration.unregister();
	}

}

 

在这个bundle启动的时候我们通过实现BundleActivator里的start方法 实例化一个服务类并通过BundleContext的registerService注册到osgi容器里,分别传入服务名称,服务实例,服务别名(可以理解为这个的tag标签),通过stop方法注销到这个服务。

 

完成这一步后我们还在MANIFEST.MF(Bundle元数据描述文件,定义此Bundle依赖的jar包,导入和导出的包等基础元数据)定义Bundle-Activator为我们自己的Activator

Bundle-Activator:com.osmp.demo.HelloServiceActivator

 

 这样我们在将此bundle部署到osgi容器的时候在bundle启动的时候就会将HelloService注册到osgi容器里供别的bundle服务调用。再简单的说一下bundle服务的引用。与发布基本相同,在启动的时候通过start方法获取到bundle上下文,通过BundleContext获取ServiceReference 服务引用,再通过此类获取我们需要的服务引用,代码如下:

 

public class Activator implements BundleActivator {
ServiceReference helloServiceReference;
	public void start(BundleContext context) throws Exception {
		System.out.println("Hello World!!");
		helloServiceReference=context.getServiceReference(HelloService.class.getName());
		HelloService helloService=(HelloService)context.getService(helloServiceReference);
		System.out.println(helloService.sayHello());
	}
	public void stop(BundleContext context) throws Exception {
		System.out.println("Goodbye World!!");
		context.ungetService(helloServiceReference);
	}
}

 

 以上部分写到一大半的时候,想找两个例子,结果发现 http://longdick.iteye.com/blog/457310 这篇文章讲的很好,大家可以看一下,我也就不再专门讲解了。

 

我就说一下在osmp里是怎么实现服务的注册和服务的发现和服务路由的。

 

osmp里服务的发布我们是通过spring-dm来发布的,代码很简单,

 spring配置文件里引入spring-osgi的schema,通过 <osgi:service>标签来将服务发布到osgi容器里,配置文件如下:

 

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:osgi="http://www.springframework.org/schema/osgi"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
		http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi-1.2.xsd">

	<context:component-scan base-package="com.osmp.demo.service">
	</context:component-scan>
	
	
	<bean id="jdbcDao" class="com.osmp.jdbc.support.JdbcDao"></bean>
	
	<bean id="osmp.demo.service" class="com.osmp.demo.service.TestServiceImpl" />
	<osgi:service interface="com.osmp.intf.define.service.BaseDataService"
		ref="osmp.demo.service">
		<osgi:service-properties>
			<entry key="name" value="osmp-demo" />
			<entry key="mark" value="测试DEMO" />
		</osgi:service-properties>
	</osgi:service>

</beans>

 

pom.xml 里依赖

 

<dependency>
            <groupId>org.springframework.osgi</groupId>
            <artifactId>spring-osgi-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.osgi</groupId>
            <artifactId>org.osgi.core</artifactId>
 </dependency>

 

pom.xml将工程打包为bundle,需要使用到 maven-bundle-plugin 这个插件:

 

<build>
		<plugins>
			<plugin>
				<groupId>org.apache.felix</groupId>
				<artifactId>maven-bundle-plugin</artifactId>
				<extensions>true</extensions>
				<configuration>
					<instructions>
						<Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
						<Export-Package></Export-Package>
						<Import-Package>
							org.springframework.aop,
							org.springframework.aop.framework,
							org.springframework.cglib,
							org.springframework.cglib.proxy,
							org.springframework.cglib.core,
							org.springframework.cglib.reflect,
							org.aopalliance.aop,
							org.aopalliance.intercept,
							*;resolution:=optional
						</Import-Package>
					</instructions>
				</configuration>
			</plugin>
		</plugins>
	</build>

 

 

 PS:

1、配置文件引入spring-osgi  xmlns:osgi="http://www.springframework.org/schema/osgi" http://www.springframework.org/schema/osgi http://www.springframework.org/schema/osgi/spring-osgi-1.2.xsd

2、osgi:service-properties 标签对应 上面讲到的context.registerService()方法的第三个参数。我的理解是给这个服务打上tag标签,以k/v键值对的形式。

3、maven-bundle-plugin打bundle时,我这里使用的servicemix作为osgi容器,已经集成了spring,此时需要将spring的包显示的引入进来。这里比较坑的是我原本以为通过*;resolution:=optional能自动的将需要依赖的包给import进来,但是试过多次发现,只有在代码里显示的import的包才会被自动的引进去,如配置文件里依赖的包是不会自动的import进来的,而且只能一级一级的import进来。

4、spring-dm 服务引用通过<osgi:reference>这里不作详讲。

 

上面的例子可以查看osmp-demo源码!!!!

相对来说通过spring-dm的方式来发布服务比上面通过BundleContext的方式前进了一大步,此外还可以通过blueprint的方式来发布服务,感兴趣的自己百度。
 

 

 

 类似资料: