前端大天二 2011-04-27 10:36
浏览 252
已采纳

JBPM+QUARTZ+JBOSS内存溢出

最近在做项目,目前已经到了测试的阶段了,我用quartz做了一个任务调度,每隔3秒钟(测试的时候周期比较短),会扫描数据库,如果发现满足条件的结果,就会发起一个流程。

但是当项目运行4个小时左右,jboss就会报内存泄露异常:java.lang.OutOfMemoryError: Java heap space

以下是我的代码片段,以及配置文件,请大家看看

Quartz的job配置
[code="java"]<?xml version="1.0" encoding="UTF-8"?>



deployAds
group1
cn.itstudio.ad_server.quartz.DeployAdsJob




deployAds
group1
deployAds
group1
0/3 * * ? * *



[/code]

DeployAdsJob.java
[code="java"]public class DeployAdsJob implements Job {

public void execute(JobExecutionContext arg0) throws JobExecutionException {
    // TODO Auto-generated method stub
    System.out.println("-------------广告上架");

    Session session = null;
    Transaction tx = null;

    try {
        session = HibernateSessionFactory.getSession();
        Date current = new Date();
        // 获取当前日的前一天
        Date compareDate = DateUtil.getPrevDate(current);
        String sql = "from PlayList p where p.playBegin<='"
                + DateUtil.dateFormate(current, "yyyy-MM-dd")
                + "' and p.playEnd > '"
                + DateUtil.dateFormate(compareDate, "yyyy-MM-dd")
                + "' and p.other1 ='false'";
        //System.out.println("发布广告-------"+sql);
        PlayListDao playListDao = new PlayListDao();
        List<PlayList> list = playListDao.findByCondition(session, sql,
                null);
        JbpmUtil jbpmUtil = new JbpmUtil();

        //开启事务
        tx = session.beginTransaction();
        for (PlayList playList : list) {
            // 发布广告上架流程实例
            jbpmUtil.startNewProcessInstance(playList.getTerminal()
                    .getTerminalCode(), playList.getAds().getAdsId()
                    .toString(), JbpmUtil.DEPLOY_ADS);
            System.out.println("广告:" + playList.getAds().getLabel()
                    + "  需要在终端机:"
                    + playList.getTerminal().getTerminalCode() + "   上架");
        }
        tx.commit();
    } catch (Exception e) {
        e.printStackTrace();
        if (tx != null) {
            tx.rollback();
        }
    } finally {
        HibernateSessionFactory.closeSession();
    }
}

}[/code]

JbpmUtil中的startNewProcessInstance方法
[code="java"]public boolean startNewProcessInstance(String terminalCode, String adId,
String processDefinitionKey) throws Exception {

    ProcessEngine pe = null;
    try {
        pe = Configuration.getProcessEngine();
        Session session = HibernateSessionFactory.getSession();
        pe.setHibernateSession(session);

        ExecutionService es = pe.getExecutionService();

        Map context = new HashMap();
        context.put("terminalCode", terminalCode);
        context.put("adId", adId);

        ProcessKeyMapDao processKeyMapDao = new ProcessKeyMapDao();
        // 构建流程id
        String processInstanceId = processKeyMapDao.getProcessIdBySDKey(
                session, processDefinitionKey + "." + terminalCode + "."
                        + adId);
        if (processInstanceId.equals("")) {
            processInstanceId = processDefinitionKey + "." + terminalCode
                    + "." + adId;
        }
        Query query = session
                .createQuery("from ExecutionImpl e where e.id like '%"
                        + processInstanceId + "%'");

        if (query.list().size() != 0) {
            System.out.println("该processInstance已经启动过了,无法重复启动");
            return false;
        }
        // 如果该流程为收集终端机状态的流程,如果该广告正在下架,则不允许收集状态
        if (processDefinitionKey.equals("CollectTerminalState")) {
            String deployProcessId = "CollectTerminalState" + "."
                    + terminalCode + "." + adId;
            query = session
                    .createQuery("from ExecutionImpl e where e.id like '%"
                            + deployProcessId + "%'");
            if (query.list().size() != 0) {
                System.out.println("广告:" + adId + "   正在下架,不允许收集状态");
                return false;
            }
        }

        // es.startProcessInstanceById(pd.getId(), context, terminalCode +
        // "."
        // + adId);
        es.startProcessInstanceByKey(processDefinitionKey, context,
                terminalCode + "." + adId);
        System.out.println("成功创建processInstance,流程Id为"
                + processDefinitionKey + "." + terminalCode + "." + adId);
        return true;
    } catch (Exception e) {
        e.printStackTrace();
        throw e;
    } finally {
        if (pe != null) {
            pe.close();
        }
    }
}[/code]

有一点不是很清楚,processEngine需不需要关闭,已经我的问题出在哪,谢谢大家

  • 写回答

1条回答 默认 最新

  • TonyLian 2011-04-27 20:06
    关注

    processEngine是个单例,无需关闭

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 seatunnel-web使用SQL组件时候后台报错,无法找到表格
  • ¥15 fpga自动售货机数码管(相关搜索:数字时钟)
  • ¥15 用前端向数据库插入数据,通过debug发现数据能走到后端,但是放行之后就会提示错误
  • ¥30 3天&7天&&15天&销量如何统计同一行
  • ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码
  • ¥15 飞机曲面部件如机翼,壁板等具体的孔位模型
  • ¥15 vs2019中数据导出问题
  • ¥20 云服务Linux系统TCP-MSS值修改?
  • ¥20 关于#单片机#的问题:项目:使用模拟iic与ov2640通讯环境:F407问题:读取的ID号总是0xff,自己调了调发现在读从机数据时,SDA线上并未有信号变化(语言-c语言)
  • ¥20 怎么在stm32门禁成品上增加查询记录功能