圈子首页 → JBPM @net → 论坛
发表回复

JBPM与SPRING事务框架完全整合

betafox 2007-11-27

经过一段事件的摸索终于将jpbm与spring完全整合，主要是事务处理的整合，工作流代码与业务代码在一个事务上下文进行；

使用了springmodules的封装，对jbpm稍有修改，稍后附上解决办法及代码；

========================================================

 

spring modules中包含了spring集成JBPM的机制，在使用的发现其并没有彻底解决两者的事务处理统一的问题，经过一段事件的摸索终于将jpbm与spring完全整合，主要是事务处理的整合，工作流代码与业务代码在一个事务上下文进行；

使用了springmodules的封装，对jbpm稍有修改，稍后附上解决办法及代码；

-------------------------------------------------姗姗来吃---------------o(∩_∩)o...哈哈，害得帖子被隐藏了

第一步：首先引入spring-modules-jbpm31.jar，同时将jbpm包含的所有hibernate映射文件解压出来，集成到spring配置文件中，可以使用类路径下的目录形式简化，如下：

 

xml 代码
  1. <property name="mappingDirectoryLocations">
  2. <list>
  3. <value>classpath:/conf/mapping/jbpm/value>
  4. list>
  5. property>

 

 

经测试在这种方式在weblogic上不能正常加载，从jar包加载也有问题必须解压到目录；

第二步：配置JPBM的大字段处理类型，这一步估计大家都知道，没什么说的；

xml 代码
  2. <bean id="jbpmTypes" class="org.springframework.orm.hibernate3.TypeDefinitionBean">
  3. <property name="typeName" value="string_max" />
  4. <property name="typeClass" value="org.jbpm.db.hibernate.StringMax" />
  5. bean>

 

xml 代码
  1. <bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
  2. <property name="lobHandler" ref="oracleLobHandle" />
  3. <property name="dataSource" ref="dataSource" />
  4. <property name="typeDefinitions"> 注意这里
  5. <ref bean="jbpmTypes" />
  6. property>
  7. 。。。。。。

 

第三步：配置spring modules，通过 springmodules 初始化jbpmConfiguration；

xml 代码

    <!-- jBPM configuration-->
    <bean id="jbpmConfiguration"
          class="org.springmodules.workflow.jbpm31.LocalJbpmConfigurationFactoryBean">
        <property name="sessionFactory" ref="sessionFactory" />

        <property name="configuration" value="classpath:/conf/jbpm.cfg.xml" />

        <!--<property name="configuration" value="classpath:/org/jbpm/default.jbpm.cfg.xml" />-->
        <!--<property name="processDefinitions">-->
        <!--<list>-->
        <!--<ref local="demoWorkflow" />-->
        <!--</list>-->
        <!--</property>-->

        <!--<property name="createSchema" value="true"/>-->
    </bean>

 

 

xml 代码（/conf/jbpm.cfg.xml）
<jbpm-configuration>

    <jbpm-context>
        <!--<service name="persistence" factory="org.jbpm.persistence.db.DbPersistenceServiceFactory" />-->
        <service name="persistence">
            <factory>
                <bean class="org.jbpm.persistence.db.DbPersistenceServiceFactory">
                    <field name="isTransactionEnabled">
                        <false />
                    </field>
                    <field name="isCurrentSessionEnabled">
                        <true />
                    </field>
                </bean>
            </factory>
        </service>

        <service name="message" factory="org.jbpm.msg.db.DbMessageServiceFactory" />
        <service name="scheduler" factory="org.jbpm.scheduler.db.DbSchedulerServiceFactory" />
        <service name="logging" factory="org.jbpm.logging.db.DbLoggingServiceFactory" />
        <service name="authentication" factory="org.jbpm.security.authentication.DefaultAuthenticationServiceFactory" />
    </jbpm-context>

    <!--<string name="resource.hibernate.cfg.xml" value="hibernate.cfg.xml" />-->

    <string name="resource.business.calendar" value="org/jbpm/calendar/jbpm.business.calendar.properties" />
    <string name="resource.default.modules" value="org/jbpm/graph/def/jbpm.default.modules.properties" />
    <string name="resource.converter" value="org/jbpm/db/hibernate/jbpm.converter.properties" />
    <string name="resource.action.types" value="org/jbpm/graph/action/action.types.xml" />
    <string name="resource.node.types" value="org/jbpm/graph/node/node.types.xml" />
    <string name="resource.parsers" value="org/jbpm/jpdl/par/jbpm.parsers.xml" />
    <string name="resource.varmapping" value="org/jbpm/context/exe/jbpm.varmapping.xml" />

    <long name="jbpm.msg.wait.timout" value="5000" singleton="true" />
    <int name="jbpm.byte.block.size" value="1024" singleton="true" />
    <string name="mail.smtp.host" value="localhost" />
    <bean name="jbpm.task.instance.factory" class="org.jbpm.taskmgmt.impl.DefaultTaskInstanceFactoryImpl"
          singleton="true" />
    <bean name="jbpm.variable.resolver" class="org.jbpm.jpdl.el.impl.JbpmVariableResolver" singleton="true" />
    <bean name="jbpm.mail.address.resolver" class="org.jbpm.identity.mail.IdentityAddressResolver" singleton="true" />

</jbpm-configuration>

 

第四步：修改JBPM自带的过滤器（web.xml），初始化当前请求线程的JBPM Context时从spring获取我们上面配置的jbpmConfiguration；其自带过滤器是通过JbpmConfiguration.getInstance获取的，不能公用spring事务上下文的hibernate session；

 

xml 代码
  1. <filter>
  2. <filter-name>JbpmContextFilterfilter-name>
  3. <filter-class>com.**.**.workflow.web.JbpmContextHolderfilter-class>
  4. filter>

 

 

java 代码（JbpmContextHolderfilter.java）
  1. import com.**.**.core.container.ApplicationContext;
  2. import org.jbpm.JbpmConfiguration;
  3. import org.jbpm.JbpmContext;
  4. import javax.servlet.*;
  5. import javax.servlet.http.HttpServletRequest;
  6. import java.io.IOException;
  7. import java.io.Serializable;
  8. import java.security.Principal;
  9. public class JbpmContextHolder implements Filter, Serializable {
  10. private static final long serialVersionUID = 1L;
  11. String jbpmConfigurationResource = null;
  12. String jbpmContextName = null;
  13. boolean isAuthenticationEnabled = true;
  14. public void init(FilterConfig filterConfig) throws ServletException {
  15. // get the jbpm configuration resource
  16. this.jbpmConfigurationResource = filterConfig.getInitParameter("jbpm.configuration.resource");
  17. // get the jbpm context to be used from the jbpm configuration
  18. this.jbpmContextName = filterConfig.getInitParameter("jbpm.context.name");
  19. if (jbpmContextName == null) {
  20. jbpmContextName = JbpmContext.DEFAULT_JBPM_CONTEXT_NAME;
  21. }
  22. // see if authentication is turned off
  23. String isAuthenticationEnabledText = filterConfig.getInitParameter("authentication");
  24. if ((isAuthenticationEnabledText != null)
  25. && ("disabled".equalsIgnoreCase(isAuthenticationEnabledText))
  26. ) {
  27. isAuthenticationEnabled = false;
  28. }
  29. }
  30. public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
  31. String actorId = null;
  32. // see if we can get the authenticated swimlaneActorId
  33. if (servletRequest instanceof HttpServletRequest) {
  34. HttpServletRequest httpServletRequest = (HttpServletRequest) servletRequest;
  35. Principal userPrincipal = httpServletRequest.getUserPrincipal();
  36. if (userPrincipal != null) {
  37. actorId = userPrincipal.getName();
  38. }
  39. }
  40. JbpmContext jbpmContext = getJbpmConfiguration().createJbpmContext(jbpmContextName);
  41. try {
  42. if (isAuthenticationEnabled) {
  43. jbpmContext.setActorId(actorId);
  44. }
  45. filterChain.doFilter(servletRequest, servletResponse);
  46. } finally {
  47. jbpmContext.close();
  48. }
  49. }

  51. 注意：下面是修改后的方法，从spring获取JbpmConfiguration；
  52. ApplicationContext是我们对spring的封装，可以改成自己的bean加载方式；

  54. protected JbpmConfiguration getJbpmConfiguration() {
  55. return (JbpmConfiguration) ApplicationContext.getInstance().getBizComponent("jbpmConfiguration");
  56. }
  57. public void destroy() {
  58. }
  59. }


大功告成：

经过上边的修改后，从spring事务过程中调用JBPM方法、或者spring modules的方法时都会直接纳入当前事务，实现一致的提交和回滚；

 
yeshucheng 2007-11-27
期待中
sijianzuo 2007-11-28
look forword to ....
d_watson 2007-11-30
??????????
vikingjw 2008-01-24
非常期待啊~~~~
kayzhan 2008-02-26
8) 这么久咋还不贴出来看下呢，非常期待啊！
looxiaohu 2008-02-26
这么久咋还不贴出来看下呢，非常期待啊！
kencool 2008-02-26
betafox 写道
经过一段事件的摸索终于将jpbm与spring完全整合，主要是事务处理的整合，工作流代码与业务代码在一个事务上下文进行；

使用了springmodules的封装，对jbpm稍有修改，稍后附上解决办法及代码；

08年啦，快来吧，已经春暖花开了
mill_lmq 2008-02-27
就是，说过的话要兑现哦，期待Ing
差沙 2008-03-06
跑计划任务的单独线程中 如何取得context
发表回复