设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

一个简单的osgi实现框架，可以动态装载运行，jar包

2017-2-7 13:38| 发布者: zhangjf| 查看: 473| 评论: 0

摘要: hyberbin-osgi 一个简单的osgi实现框架，可以动态装载运行，jar包。 运行方式public static void main(String args) throws Exception { //模块名称 final String module=comparedb; // ...
hyberbin-osgi

一个简单的osgi实现框架，可以动态装载运行，jar包。

运行方式
  1. public static void main(String[] args) throws Exception {
  2. //模块名称
  3. final String module="comparedb";
  4. //获取OSGI容器实例
  5. final OSGiContainer container = OSGiContainer.getInstance();
  6. //启动框架
  7. container.start();
  8. //设置模块安装成功后的处理
  9. container.setModuleInstalledHandler(new ModuleInstalledHandler() {
  10. @Override
  11. public void moduleInstalled(ModuleLoader loader) {
  12. //模块安装成功后运行该模块
  13. Thread.currentThread().setContextClassLoader((ClassLoader)container.getLoader(module));
  14. container.run(module);
  15. }
  16. });
  17. //创建模块模型
  18. ModulesBean modulesBean = new ModulesBean(module, "1.0", new JarFile[]{new JarFile("/codes/myproject/CompareDB/target/CompareDB.jar")},new MainClassRunner("com.hyberbin.main.Main"));
  19. //从本地maven仓库中自动解决依赖
  20. modulesBean.setModuleLoader(new MavenModuleLoaderImpl("/Users/hyberbin/.m2/repository/"));
  21. //安装
  22. container.install(modulesBean);
  23. }
复制代码

动态安装一个SpringMVC模块

spring-dynamic文件夹下是动态安装一个SpringMVC模块的实现

applicationContext-dao.xml配置如下:
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:context="http://www.springframework.org/schema/context"
  4. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
  5. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd"
  6. default-lazy-init="true">
  8. <bean class="org.springframework.orm.hibernate4.HibernateExceptionTranslator"/>
  9. <!--<bean class="org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor"/>-->
  10. <!--自己实现了一个PersistenceExceptionTranslationPostProcessor,原来的获取ClassLoader的方式有问题-->
  11. <bean class="com.XXX.spring.dynamic.aop.UserPersistenceExceptionTranslationPostProcessor"/>
  12. <!--让这个sessionFactory来动态路由多个sessionFactory-->
  13. <bean id="sessionFactory" class="com.XXX.spring.dynamic.factory.DynamicSessionFactory"/>
  14. <!--这个是将所有的sessionFactory放入Map中-->
  15. <bean id="sessionFactoryMap" class="java.util.HashMap">
  16. <constructor-arg>
  17. <map>
  18. <entry key="defaultSessionFactory">
  19. <ref bean="defaultSessionFactory"/>
  20. </entry>
  21. </map>
  22. </constructor-arg>
  23. </bean>
  24. <!-- Hibernate SessionFactory -->
  25. <bean id="defaultSessionFactory" lazy-init="true" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean" destroy-method="destroy">
  26. <property name="dataSource" ref="dataSource"/>
  27. <property name="configLocation" value="/WEB-INF/hibernate.cfg.xml"/>
  28. <property name="packagesToScan">
  29. <list>
  30. <value>com.XXX.digitalcampus.**.model</value>
  31. </list>
  32. </property>
  33. <property name="hibernateProperties">
  34. <props>
  35. <prop key="hibernate.dialect">${hibernate.dialect}</prop>
  36. <prop key="hibernate.show_sql">false</prop>
  37. <prop key="hibernate.format_sql">false</prop>
  38. <prop key="hibernate.query.substitutions">true 'Y', false 'N'</prop>
  39. <prop key="hibernate.cache.use_second_level_cache">true</prop>
  40. <prop key="hibernate.cache.provider_class">org.hibernate.cache.ehcache.EhCacheRegionFactory</prop>
  41. <prop key="javax.persistence.validation.mode">none</prop>
  42. <!--<prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop>-->
  43. <!--<prop key="hibernate.transaction.auto_close_session">true</prop>-->
  44. <!-- Hibernate Search index directory -->
  45. <!--<prop key="hibernate.search.default.indexBase">${app.search.index.basedir}</prop>-->
  46. </props>
  47. <!-- Turn batching off for better error messages under PostgreSQL -->
  48. <!-- hibernate.jdbc.batch_size=0 -->
  49. </property>
  50. </bean>
  52. <!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA) -->
  53. <!--<bean id="txManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">-->
  54. <!--<property name="sessionFactory" ref="sessionFactory"/>-->
  55. <!--</bean>-->
  56. <!--动态事务管理器-->
  57. <bean id="txManager" class="com.XXX.spring.dynamic.factory.DynamicTransactionManager">
  58. <property name="sessionFactory" ref="sessionFactory"/>
  59. </bean>
  60. <!-- Activates scanning of @Repository -->
  61. <context:component-scan base-package="com.XXX.framework.**.data.hibernate"/>
  62. <context:component-scan base-package="com.XXX.digitalcampus.**.dao.hibernate"/>
  64. </beans>
复制代码

applicationContext-service.xml配置如下:
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xmlns:aop="http://www.springframework.org/schema/aop"
  4. xmlns:context="http://www.springframework.org/schema/context"
  5. xmlns:tx="http://www.springframework.org/schema/tx"
  6. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
  7. http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd
  8. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
  9. http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd"
  10. default-lazy-init="true">
  12. <!-- =================================================================== -->
  13. <!-- AOP: Configuration and Aspects -->
  14. <!-- =================================================================== -->
  16. <tx:advice id="txAdvice" transaction-manager="txManager">
  17. <tx:attributes>
  18. <tx:method name="save*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  19. <tx:method name="add*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  20. <tx:method name="create*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  21. <tx:method name="insert*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  22. <tx:method name="update*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  23. <tx:method name="merge*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  24. <tx:method name="del*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  25. <tx:method name="remove*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  26. <tx:method name="put*" rollback-for="com.XXX.framework.core.exception.BusinessException"/>
  27. <tx:method name="execute*" rollback-for="com.XXX.framework.core.exception.BusinessException"
  28. no-rollback-for="java.lang.RuntimeException"/>
  29. <tx:method name="clear*" rollback-for="com.XXX.framework.core.exception.BusinessException"
  30. no-rollback-for="java.lang.RuntimeException"/>
  31. <tx:method name="disable*" rollback-for="com.XXX.framework.core.exception.BusinessException"
  32. no-rollback-for="java.lang.RuntimeException"/>
  33. <tx:method name="use*" rollback-for="com.XXX.framework.core.exception.BusinessException"
  34. no-rollback-for="java.lang.RuntimeException"/>
  36. <!--hibernate4必须配置为开启事务 否则 getCurrentSession()获取不到-->
  37. <tx:method name="get*" read-only="true"/>
  38. <tx:method name="count*" read-only="true"/>
  39. <tx:method name="find*" read-only="true"/>
  40. <tx:method name="list*" read-only="true"/>
  41. <tx:method name="*" read-only="false"/>
  42. </tx:attributes>
  43. </tx:advice>
  44. <!--这个modulesAdvice主要是为了在ThreadLocal中放入一个模块名,后面好获取对应模块的sessionFactory-->
  45. <bean id="modulesAdvice" class="com.XXX.spring.dynamic.aop.ServiceMethodBeforeAdvice"/>
  48. <!--&lt;!&ndash; 配置pointcut，将事务通过aop方式插入到joinpoint &ndash;&gt;-->
  49. <!--<aop:config>-->
  50. <!--<aop:pointcut expression="execution(* com.XXX..service.impl.*.*(..))" id="serviceMethod"/>-->
  51. <!--&lt;!&ndash;这个modulesAdvice主要是为了在ThreadLocal中放入一个模块名,后面好获取对应模块的sessionFactory&ndash;&gt;-->
  52. <!--<aop:advisor advice-ref="modulesAdvice" pointcut-ref="serviceMethod"/>-->
  53. <!--<aop:advisor advice-ref="txAdvice" pointcut-ref="serviceMethod"/>-->
  54. <!--</aop:config>-->
  55. <!--<aop:aspectj-autoproxy proxy-target-class="true"/>-->
  56. <!--这里没用<aop:>这种高级的配置因为AutoProxyCreator是我自己实现的,之前的AutoProxyCreator不能获取当前的ClassLoader-->
  57. <bean id="autoProxyCreator" class="com.XXX.spring.dynamic.aop.AutoProxyCreator"></bean>
  58. <!--第一个注入modulesAdvice-->
  59. <bean id="aspectjAspect" class="org.springframework.aop.aspectj.AspectJExpressionPointcutAdvisor">
  60. <property name="advice" ref="modulesAdvice"/>
  61. <property name="expression" value="execution(* com.XXX..service.impl.*.*(..))"/>
  62. </bean>
  63. <!--第二个注入modulesAdvice,注入事务代理,要从第一个切入点中获取当前模块的SessionFactory-->
  64. <bean id="aspectjAspect2" class="org.springframework.aop.aspectj.AspectJExpressionPointcutAdvisor">
  65. <property name="advice" ref="txAdvice"/>
  66. <property name="expression" value="execution(* com.XXX..service.impl.*.*(..))"/>
  67. </bean>
  68. <!--osgi模块的卸载器-->
  69. <bean id="moduleUnInstaller" class="com.XXX.spring.dynamic.uninstaller.SpringModuleUninstall"/>
  70. <!--启动OSGI容器-->
  71. <bean id="osgi-container" class="org.jplus.osgi.core.OSGiContainer" factory-method="getInstance" lazy-init="false" init-method="start">
  72. <property name="moduleUnInstaller" ref="moduleUnInstaller"/>
  73. </bean>
  75. <!-- Activates scanning of @Service -->
  76. <context:component-scan base-package="com.XXX.framework.**.service"/>
  77. <context:component-scan base-package="com.XXX.digitalcampus.**.service"/>
  79. <!-- Configure Velocity for sending e-mail -->
  80. <bean id="velocityEngine" class="org.springframework.ui.velocity.VelocityEngineFactoryBean">
  81. <property name="velocityProperties">
  82. <props>
  83. <prop key="resource.loader">class</prop>
  84. <prop key="class.resource.loader.class">
  85. org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader
  86. </prop>
  87. <prop key="velocimacro.library"></prop>
  88. </props>
  89. </property>
  90. </bean>
  92. </beans>
复制代码

说明

作者已经实现了用这个框架动态加载自己项目中的模块.

动态装载Controller类,并注册BeanFactory缓存服务. 动态装载Service类,并注册Aop服务和BeanFactory缓存服务,开启Hibernate事务. 动态装载Hibernate类,并动态生成和加载新的SessionFactory,和BeanFactory缓存服务. 自动将jar包中的jsp文件解压到web容器下. 问题申明 这种osgi平台下的模块中如果有单独的线程或者不能正常中断的程序将导致模块只能加载不能卸载! 程序中不能有System.exit()方法的调用.

项目主页：http://www.open-open.com/lib/view/home/1448203102069

收藏 邀请
上一篇：Java十分钟速懂知识点 - System类下一篇：Java中 VO、 PO、DO、DTO、 BO、 QO、DAO、POJO的概念

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-9 01:57

Copyright 2015-2025 djqfx

返回顶部