欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

内嵌式--代码启动OSGI框架

程序员文章站 2022-07-13 16:53:57
...

前言

 

前面两篇文章中我们都是直接启动的OSGI框架(equinox),然后把所有bundle放到框架中运行。在平时开发中,由于历史原因,把整个应用都迁移到OSGI框架中 是一件很困难的事,但我们可以尝试把需要热更新的部分剥离出来 制作成bundle。然后在我们现有的web框架中嵌入一个OSGI框架,并使用这个嵌入的OSGI框架加载bundle,从而实现对程序的部分模块化。

 

本次demo是在一个典型的spring mvc框架下的web应用中,通过代码启动一个内嵌OSGI框架。

 

代码启动OSGI框架

 

由于是使用spring,可以直接定义一个spring bean来启动一个OSGI框架:

/**
 * osgi容器管理
 */
@Component
public class OsgiInit {
 
    /**
     * 初始化容器
     */
    @PostConstruct
    public void init() {
        ServiceLoader<FrameworkFactory> serviceLoader = ServiceLoader.load(FrameworkFactory.class);
        FrameworkFactory frameworkFactory = serviceLoader.iterator().next();
 
        //一些启动参数
        Map<String, String> properties = new HashMap<>();
        properties.put("osgi.console", "");
        properties.put("osgi.clean", "true");
        properties.put("org.osgi.framework.bootdelegation", "sun.*,com.sun.*,javax.*");
        properties.put("org.osgi.framework.system.capabilities","osgi.ee; osgi.ee=\"JavaSE\";version:List=\"1.0,1.1,1.2,1.3,1.4,1.5,1.6,1.7,1.8\"");
 
        Framework framework = frameworkFactory.newFramework(properties);
 
        try {
            framework.init();//初始化框架
        } catch (BundleException e) {
            e.printStackTrace();
        }
        try {
            framework.start();//启动框架
 
            Thread thread = new Thread(() -> {
                try {
                    framework.waitForStop(0);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            thread.start();
            Constents.getInstence().setThread(thread);
 
            Constents.getInstence().setFramework(framework);
        } catch (BundleException e) {
            e.printStackTrace();
        }
        System.out.println("osgi容器启动成功");
    }
 
    /**
     * 销毁容器
     */
    @PreDestroy
    public void destroy(){
        System.out.println("开始销毁容器");
        try {
            Constents.getInstence().getFramework().stop();
 
        } catch (BundleException e) {
            e.printStackTrace();
        }
        Constents.getInstence().getThread().interrupt();
    }
}
 

 

这边类是由@Component注释,spring容器会在初始化这个bean之前执行@PostConstruct注释的init方法 启动OSGI框架;spring 容器在销毁之前会执行@PreDestroy注释的destroy方法,销毁OSGI框架。

 

OSGI框架启动成功后,会通过调用Constents.getInstence().setFramework(framework);方法把这个framework对象存起来。看下Constents的实现:

public class Constents {
    private static final Constents constents = new Constents();
    private Thread thread;
    private Framework framework;//OSGI框架对象
    private Map<String,Bundle> bundleMap = new HashMap<>();//OSGI框架中加载的Bundle
 
    private Constents(){}
    public static Constents getInstence(){
        return constents;
    }
 
    public Thread getThread() {
        return thread;
    }
 
    public void setThread(Thread thread) {
        this.thread = thread;
    }
 
    public Framework getFramework() {
        return framework;
    }
 
    public void setFramework(Framework framework) {
        this.framework = framework;
    }
 
    public void setBundle(Bundle bundle){
        this.bundleMap.put(bundle.getSymbolicName(),bundle);
    }
 
    public Bundle getBundle(String name){
        return this.bundleMap.get(name);
    }
}
 

 

Constents使用了单例模式生成一个唯一的Constents对象,上述代码在OSGI容器启动成功后,会把framework对象赋值给Constents对象。在web框架中可以直接调用这个对象的相关方法动态的加载Bundle

 

这里我们在一个Spring mvc Controller中,模拟对Bundle的加载和启动:

@RequestMapping("/start")
    public String start(){
        Framework framework = Constents.getInstence().getFramework();//
        try {
            File bundleRoot = new File("D:\\test\\bundles");
            File[] files = bundleRoot.listFiles();
            for (File jar :files){
                Bundle temp = framework.getBundleContext().installBundle(jar.toURL().toExternalForm());
                Constents.getInstence().setBundle(temp);
            }
            //启动manager bundle
            Constents.getInstence().getBundle("com.sky.osgi.manager").start();
 
        } catch (Exception e) {
            System.out.println("安装bundle失败");
            e.printStackTrace();
        }
        return "start";
}

当然也可以在Controller中定义其他修改bundle、删除bundle等方法,以控制内嵌的OSGI容器的内部bundle运行。

 

 

相关标签: 代码启动OSGI框架