Spring、OSGi整合Hibernate 二

接上文，为了测试已经搭好的架子，创建了一个注册实体的Bundle（wanged_security_entity），这个里面包含了两个实体类（Role、User）和它们的Hibernate映射文件（Role.hbm.xml、User.hbm.xml），以及一个实现了EntityRegister接口的类（SecurityEntityRegisterImpl）以提供注册实体的服务。这里仅将SecurityEntityRegisterImpl的代码列出如下：

java 代码

package wanged.security.entity;

import java.util.ArrayList;

import wanged.core.persistent.entity.EntityRegister;


@SuppressWarnings("unchecked")
public class SecurityEntityRegisterImpl implements EntityRegister{

    public Class[] register() {
        ArrayList<class> cList = new ArrayList<class>();  </class></class>

        cList.add(Role.class);
        cList.add(User.class);

        return cList.toArray(new Class[cList.size()]);
    }

}

下面来声明该服务：

xml 代码

<osgi:service interface="wanged.core.persistent.entity.EntityRegister">
  <bean class="wanged.security.entity.SecurityEntityRegisterImpl" />
</osgi:service>

 这个服务就是上篇中，"wanged_core_persistent" Bundle中引用的服务，完成了实体类的注册。
       现在有了实体类，就需要有对实体类进行CURD操作的Bundle（wanged_security_service），这个Bundle中采用了常见的Service-DAO模式，以对Role的操作为例，包括RoleService：

java 代码

package wanged.security.service;

import java.util.List;

import wanged.security.dao.RoleDao;
import wanged.security.entity.Role;

public interface RoleService {

    void setRoleDao(RoleDao rdao);

    void saveRole(Role r);

    List<role> findAll();  </role>
}

和其实现RoleServiceImpl：

java 代码

package wanged.security.service.impl;

import java.util.List;

import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import wanged.security.dao.RoleDao;
import wanged.security.entity.Role;
import wanged.security.service.RoleService;

@Transactional(readOnly = true)
public class RoleServiceImpl implements RoleService {

    private RoleDao rdao;

    public void setRoleDao(RoleDao rdao) {
        this.rdao = rdao;
    }

    @Transactional(readOnly = false, propagation = Propagation.REQUIRED)
    public void saveRole(Role r) {
        this.rdao.save(r);
    }

    @Transactional()
    public List<role> findAll() {  </role>
        List<role> l =  this.rdao.find();  </role>
        return l;
    }

}

以及DAO的接口RoleDao：

java 代码

package wanged.security.dao;

import java.util.List;

import org.hibernate.SessionFactory;

import wanged.security.entity.Role;

public interface RoleDao {

    void setSessionFactory(SessionFactory sessionFactory);

    void save(Role r);

    List<role> find();  </role>
}

及其实现RoleDaoImpl：

java 代码

package wanged.security.dao.impl;

import java.util.List;

import org.hibernate.SessionFactory;

import wanged.security.dao.RoleDao;
import wanged.security.entity.Role;

public class RoleDaoImpl implements RoleDao {
    private SessionFactory sessionFactory;

    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    public void save(Role r) {
        sessionFactory.getCurrentSession().save(r);
    }

    @SuppressWarnings("unchecked")
    public List<role> find(){  </role>
        return sessionFactory.getCurrentSession().createQuery("from " + Role.class.getName()).list();
    }
}

这些都是最常见的没什么可注意的，下面主要说说配置。
配置文件还是Bean初始化使用bean.xml：

xml 代码

<!-- 数据持久化 -->
<bean id="roleDao" class="wanged.security.dao.impl.RoleDaoImpl">
  <property name="sessionFactory" ref="sessionFactory" />
</bean>

<bean id="roleService" class="wanged.security.service.impl.RoleServiceImpl">
  <property name="roleDao" ref="roleDao" />
</bean>

<!-- 事务处理 -->
<tx:annotation-driven transaction-manager="txManager" />

<!--  Test  -->
<bean id="test" class="wanged.RoleServiceTest" init-method="init">
  <property name="roleService" ref="roleService" />
</bean>

这里引用了上文中在"wanged_core_persistent" Bundle中声明的服务sessionFactory和txManager，这个txManager是一个默认的事务管理方案，如果不合适可以在这个xml文件中自定义，这就为新扩展的数据库操作提供了方便。另外这里有一个测试类RoleServiceTest，是用来测试这个Bundle是否能正常工作的，可以自己编写其中的代码。
服务的声明和引用定义在osgi-service.xml文件中：

xml 代码

<osgi:reference id="sessionFactory" interface="org.hibernate.SessionFactory" />

<osgi:reference interface="org.springframework.transaction.PlatformTransactionManager" id="txManager" />

<osgi:service interface="wanged.security.service.RoleService" ref="roleService" />

这里声明了一个RoleService的服务供其它的Bundle使用。
       到目前为止，OSGi、Spring、Hibernate已经成功整合在一起。经运行测试，一切正常。但还没有对SessionFactory的重新初始化进行处理，不过这已经不是重点了。
       后续博客会将对Jetty和Wicket的整合陆续写出来，最终形成OSGi、Spring、Hibernate、Jetty和Wicket搭建起来的面向服务的基于组件的体系。
       这个周末所有的时间都放在Wicket和Jetty上面终于将其调试通过，写出来希望能给广大道友一点帮助，不至于像我刚开始那样盲目与不知所措。

评论

15 楼 KKBB123 2012-08-22  

能不能 给我发份源码 我一直调试不 成功 ，你要在 发一份 先谢了

14 楼 liuqiao_0702 2012-06-15  

写的很好，有个问题请教一下：自己写的数据库bundle用到的org.hibernate.SessionFactory是怎么引进到本bundle的？以及它依赖的jar，都得引到数据库bundle中吗？相当于基础bundle和数据库bundle引用了相同的jar在自己的bundle，有没有更好的处理方式？

13 楼 fr_lsl 2012-04-28  

注册实体的Bundle（wanged_security_entity），这个怎么做到动态注册实体？

12 楼 jori 2012-03-22  

有源码吗

11 楼 BlueDavy 2007-11-03  

基础的学习请先参考《OSGi实战》Opendoc，是入门级的，可以从blog.bluedavy.cn上下载。

10 楼 fangzhouxing 2007-10-31  

引用

目前OSGi还是不够成熟，支持的第三方软件也不是太多，文档也不齐全，所以学习曲线有点陡。

是啊，blueDavy的文档起到很好的作用。但是，一开始学习好像又太高深了。能否提供一些基础性的东西，先让读者入门和搭好开发调试环境，再进入具体的项目开发。

9 楼 earls 2007-10-23  

我觉得fragment主要用来解决本地化问题和一些不涉及对外提供服务的扩展问题。目前OSGi还是不够成熟，支持的第三方软件也不是太多，文档也不齐全，所以学习曲线有点陡。

8 楼 youngliuus 2007-10-20  

非常感谢你的答复！
我后来在blueDavy写的osgi进阶中也看到了。
之前我也知道有dynamicImport，但没想到还可以写*，嘿嘿 看来不看osgi spec就是不行。

我倒是觉得import*挺自然的，如果用fragment会有些限制，比如bundle不能有自己的Activator，还和fragment host用一个classloader，这个bundle就只能提供实体了，要提供其它的服务就不太方便了。我感觉这样bundle的粒度是不是太小了。

7 楼 earls 2007-10-20  

OSGi的配置中有一个DynamicImport-Pagecke标签，可以动态引入自己需要的类，对Class.forName()尤其有效，可以设置成DynamicImport-Pagecke： *表示动态导入所有需要的。当然目前这种实现是我在最初尝试的时候采用的方法，很不完善。我现在使用的方法是采用fragment,用一个Bundle来注册所有已知的实体类，扩展的实体类通过fragment方式引入

6 楼 youngliuus 2007-10-18  

hi
  我也在做类似的事情,但是碰到了class loading的问题,后面附上了Configuration.buildSessionFactory时的exception.
  从异常的信息看来,hibernate在buildSessionFactory时会用hibernate的ReflectHelper做一下Class.forName.
虽然我没想明白我已经把实体的class已经给了configuration他还要再load一次,但这样就有一个问题,以你的例子来说,在wanged_core_persistent_entity_register这个bundle中要做Class.forName,那么这个bundle的classloader就要加载在其它bundle中的实体类的.
但我又没看到你有提到要在wanged_core_persistent_entity_register这个bundle中import实体类的package之类的动作,所以不太明白在你的例子是怎么工作的,能否从原理上解释一下,多谢.

org.hibernate.MappingException: entity class not found: bo.impl.ProjectImpl
at org.hibernate.mapping.PersistentClass.getMappedClass(PersistentClass.java:99)
at org.hibernate.tuple.PropertyFactory.getGetter(PropertyFactory.java:168)
at org.hibernate.tuple.PropertyFactory.buildIdentifierProperty(PropertyFactory.java:44)
at org.hibernate.tuple.entity.EntityMetamodel.<init>(EntityMetamodel.java:123)
at org.hibernate.persister.entity.AbstractEntityPersister.<init>(AbstractEntityPersister.java:434)
at org.hibernate.persister.entity.SingleTableEntityPersister.<init>(SingleTableEntityPersister.java:109)
at org.hibernate.persister.PersisterFactory.createClassPersister(PersisterFactory.java:55)
at org.hibernate.impl.SessionFactoryImpl.<init>(SessionFactoryImpl.java:226)
at org.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1294)
at org.hibernate.cfg.AnnotationConfiguration.buildSessionFactory(AnnotationConfiguration.java:915)
Caused by: java.lang.ClassNotFoundException: bo.impl.ProjectImpl
at org.knopflerfish.framework.BundleClassLoader.findClass(BundleClassLoader.java:231)
at org.knopflerfish.framework.BundleClassLoader.loadClass(BundleClassLoader.java:299)
at java.lang.ClassLoader.loadClass(ClassLoader.java:251)
at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:319)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:164)
at org.hibernate.util.ReflectHelper.classForName(ReflectHelper.java:100)
at org.hibernate.mapping.PersistentClass.getMappedClass(PersistentClass.java:96)
... 31 more

5 楼 shaucle 2007-08-15  

jsr277,299,316,osgi ...

4 楼 xsl 2007-08-14  

    感觉Eclipse-RegisterBuddy很可能被引入下一版的osgi标准。据说会变成Bundle-RegisterBuddy。到时改一下名称就行了。
    当然你改写SessionFactory也不错。不过能有一种不需要对现有第三方类库进行修改的实现方式应该更好，而且省力。
    在osgi专家组中也讨论过关于classloader相关的问题，有很多人呼吁在接下来的标准中应该提出官方解决方案，来解决类似Class.forName（）调用的问题。但是到目前为止，除了Buddy方式还没有其它好的通用解决方式。所以，感觉Eclipse-RegisterBuddy很有可能会被采纳，进入下一版标准。

3 楼 earls 2007-08-14  

复杂的背后带来的是良好的扩展性和动态拔插的方便性，那么这点复杂是可以接受的。
何况对于大的项目来说，这恰恰可以降低系统复杂度和耦合度。

2 楼 shaucle 2007-08-13  

事情往往就是这么变复杂的...

1 楼 tilan 2007-08-13  

不错哦



==========================
http://www.sqlsoft.com.cn
http://bbs.sqlsoft.com.cn