jbpm与ssh完整示例(二)

shazhenzhong

浏览: 17644 次
性别:
来自: 北京

最近访客更多访客>>

shaobo

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

2009-01 ( 2)
更多存档...

JBPM SSH Apache Struts Servlet

流程的发布常用的有二种方式：直接发布processdefinition.xml定义的xml文件，在以前的文章描述中使用的方式。建议使用第二种方式，gpd.xml、processdefinition.xml、processimage.jpg压缩成zip文件上传。注rar不可以，java当中不支持这种商业化的压缩文件。

代码如下：

1 deployjbpm.jsp下选择zip压缩文件上传

<%@ page contentType="text/html;charset=UTF-8"%>

<%@ include file="/commons/taglibs.jsp"%>

<html>

<head>

</head>

<body>

<form action="${ctx}/jbpmdeploy.do?method=deploy" enctype="multipart/form-data" method="post" />

      选择zip类型流程上传 : <input type="file" name="file" />

      <br/>

      <input type="submit">

    </form>

</body>

</html>

2 struts中的action文件

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.struts.action.ActionForm;

import org.apache.struts.action.ActionForward;

import org.apache.struts.action.ActionMapping;

import com.shane.commons.core.web.StrutsAction;

import com.shane.security.service.UploadProcessManager;

public class JbpmAction extends StrutsAction {

         private static Log log = LogFactory.getLog(JbpmAction.class);

         private UploadProcessManager uploadProcessManager;



         public void setUploadProcessManager(UploadProcessManager uploadProcessManager) {

                   this.uploadProcessManager = uploadProcessManager;

         }



    /**

     * 上传流程文件

     * @param mapping

     * @param form

     * @param request

     * @param response

     * @return

     */

    public ActionForward deploy(ActionMapping mapping, ActionForm form,

                            HttpServletRequest request, HttpServletResponse response)throws Exception {

             log.info("执行流程部署！");

             log.info(uploadProcessManager.handleRequest(request));

                   return mapping.findForward("delpoyindex");

         }



}

3 Service类，使用时要修改自已的hibernate的封装。代码中使用spring的设置式注入方式。相关文件可以自行编写。本方式是根据jbpm自带的示例改写。

3.1接口定义

import java.io.IOException;

import javax.servlet.http.HttpServletRequest;

public interface UploadProcessManager {

         public void printInput(HttpServletRequest request) throws IOException;



         public String handleRequest(HttpServletRequest request);

}

3.2实现类

import java.io.IOException;

import java.io.InputStream;

import java.util.Iterator;

import java.util.List;

import java.util.zip.ZipInputStream;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.fileupload.DiskFileUpload;

import org.apache.commons.fileupload.FileItem;

import org.apache.commons.fileupload.FileUpload;

import org.apache.commons.fileupload.FileUploadException;

import org.jbpm.JbpmConfiguration;

import org.jbpm.JbpmContext;

import org.jbpm.graph.def.ProcessDefinition;

import com.shane.commons.core.dao.HibernateEntityDao;

public class UploadProcessManagerImpl extends HibernateEntityDao implements UploadProcessManager{



         private JbpmConfiguration jbpmConfiguration;



         public void printInput(HttpServletRequest request) throws IOException {

                   InputStream inputStream = request.getInputStream();

                   StringBuffer buffer = new StringBuffer();

                   int read;

                   while ((read = inputStream.read()) != -1) {

                            buffer.append((char)read);

                   }

         }



         public String handleRequest(HttpServletRequest request) {

             if (!FileUpload.isMultipartContent(request)) {

                      return "Not a multipart request";

             }

                   try {

                       DiskFileUpload fileUpload = new DiskFileUpload();

                       List list = fileUpload.parseRequest(request);

                       Iterator iterator = list.iterator();

                       if (!iterator.hasNext()) {

                                return "No process file in the request";

                       }

                       FileItem fileItem = (FileItem)iterator.next();

                       if (fileItem.getContentType().indexOf("application/x-zip-compressed") == -1) {

                                return "Not a process archive";

                       }

                       return doDeployment(fileItem);

                   } catch (FileUploadException e) {

                            e.printStackTrace();

                            return "FileUploadException";

                   }

         }



         public String doDeployment(FileItem fileItem) {

                   try {

                      ZipInputStream zipInputStream = new ZipInputStream(fileItem.getInputStream());

                      JbpmContext jbpmContext = JbpmContext.getCurrentJbpmContext();

            if(jbpmContext == null) {

                               jbpmContext = this.getJbpmContext();

                      }

                      ProcessDefinition processDefinition = ProcessDefinition.parseParZipInputStream(zipInputStream);

                      jbpmContext.deployProcessDefinition(processDefinition);

                      zipInputStream.close();

                      return "Deployed archive " + processDefinition.getName() + " successfully";

                   } catch (IOException e) {

                            return "IOException";

                   }

         }



         private JbpmContext getJbpmContext(){

                   JbpmContext context = jbpmConfiguration.getInstance().createJbpmContext();

                   context.setSession(this.getSession());

                   return context;

         }



         public void setJbpmConfiguration(JbpmConfiguration jbpmConfiguration) {

                   this.jbpmConfiguration = jbpmConfiguration;

         }



}

分享到：

jbpm与ssh完整示例(一)

2009-01-10 08:12
浏览 1896
评论(4)
论坛回复 / 浏览 (3 / 3979)
查看更多

4 楼 atchina 2009-06-15

如果有完整的项目就好了

3 楼 flysunsystem 2009-02-12

期待上传完整的项目。哈哈。

2 楼 flysunsystem 2009-02-06

楼主：能不能给个完整的例子？谢谢了

我的邮箱是flysunmicro@gmail.com

1 楼 sskhnje 2009-01-12

谢谢啊，好文章，学到很多东西。
期待更新，谢谢
！

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论