`
shazhenzhong
  • 浏览: 17600 次
  • 性别: Icon_minigender_1
  • 来自: 北京
最近访客 更多访客>>
shaobo
社区版块
存档分类
最新评论

jbpm与ssh完整示例(二)

JBPMSSHApacheStrutsServlet 
阅读更多
流程的发布常用的有二种方式：直接发布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完整示例(一)
评论
4 楼 atchina 2009-06-15  
如果有完整的项目就好了
3 楼 flysunsystem 2009-02-12  
期待上传完整的项目。哈哈。
2 楼 flysunsystem 2009-02-06  
楼主：能不能给个完整的例子？谢谢了

我的邮箱是flysunmicro@gmail.com
1 楼 sskhnje 2009-01-12  
谢谢啊， 好文章， 学到很多东西。
期待更新，谢谢
！
发表评论

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

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics