手动开启hibernate的事务的问题

作者: jarWorker | 来源:发表于2019-05-24 16:40 被阅读0次

手动开启hibernate的事务的问题
MySQL数据库的事务transaction
事务、MySQL与Python交互、Python 中操作 MyS
Dao层的四种对比
JAVAEE——MySQL事务
如何解决秒杀场景下的超卖问题
springboot 监听事务，执行另外的任务
hibernate的五大接口
spring手动提交事务与hibernate的坑
springboot 事物管理

问题代码（监听redis过期的key）

package com.aaa.bbb.listen;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import javax.transaction.Transactional;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.orm.hibernate4.HibernateTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import com.aaa.bbb.common.Exceptions;
import com.aaa.bbb.common.SpringContextHolder;
import com.aaa.bbb.dao.util.Daoutil;

public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
    private static final Logger logger = LoggerFactory.getLogger(RedisKeyExpirationListener.class);
    @Autowired
    private Daoutil daoutil;

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    /**
     *
     * 监听redis过期失效的key
     */
    @Override
    public void onMessage(Message message, byte[] pattern){
        //手动开启hibernate的事务
        HibernateTransactionManager transactionManager = SpringContextHolder.getBean("txManager");
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔离级别，开启新事务，这样会比较安全些。
        TransactionStatus status = transactionManager.getTransaction(def); // 获得事务状态
        String redisKey = message.toString();
        logger.info("即将要失效的Key:" + redisKey);
        //System.out.println("即将要失效的Key:" + redisKey);
        if (StringUtils.isNotBlank(redisKey)) {
            String countSql = "select count(*) from slogintbl where tradeno =? ";
            List<String> countParams = new ArrayList<>();
            countParams.add(redisKey);
            try {
                int count = daoutil.queryCountSql(countSql, countParams);
                if (0 == count) {
                    return;//这里return了，导致问题。
                } else {
                    List<String> params = new ArrayList<>();
                    SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd HH:mm:ss");
                    
                    params.add(sf.format(new Date()));
                    params.add(redisKey);
                    String sql = "update slogintbl set logoutdate=? where tradeno=?";
                    daoutil.updateOrSaveSql(sql, params);
                    transactionManager.commit(status);

                }
            } catch (Exception e) {
                // TODO Auto-generated catch block
                logger.debug(Exceptions.getStackTraceAsString(e));
                transactionManager.rollback(status);
            }

        }
    }
}

结果

没有关闭资源导致连接池耗尽

解决方式

方式一

package com.aaa.bbb.listen;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import javax.transaction.Transactional;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.orm.hibernate4.HibernateTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import com.aaa.bbb.common.Exceptions;
import com.aaa.bbb.common.SpringContextHolder;
import com.aaa.bbb.dao.util.Daoutil;

public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
    private static final Logger logger = LoggerFactory.getLogger(RedisKeyExpirationListener.class);
    @Autowired
    private Daoutil daoutil;

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    /**
     *
     * 监听redis过期失效的key
     */
    @Override
    public void onMessage(Message message, byte[] pattern){
        //手动开启hibernate的事务
        HibernateTransactionManager transactionManager = SpringContextHolder.getBean("txManager");
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔离级别，开启新事务，这样会比较安全些。
        TransactionStatus status = transactionManager.getTransaction(def); // 获得事务状态
        String redisKey = message.toString();
        logger.info("即将要失效的Key:" + redisKey);
        //System.out.println("即将要失效的Key:" + redisKey);
        if (StringUtils.isNotBlank(redisKey)) {
            String countSql = "select count(*) from slogintbl where tradeno =? ";
            List<String> countParams = new ArrayList<>();
            countParams.add(redisKey);
            try {
                int count = daoutil.queryCountSql(countSql, countParams);
                if (0 ！= count) {
                    List<String> params = new ArrayList<>();
                    SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd HH:mm:ss");
                    
                    params.add(sf.format(new Date()));
                    params.add(redisKey);
                    String sql = "update slogintbl set logoutdate=? where tradeno=?";
                    daoutil.updateOrSaveSql(sql, params);
                    transactionManager.commit(status);
            } catch (Exception e) {
                // TODO Auto-generated catch block
                logger.debug(Exceptions.getStackTraceAsString(e));
                transactionManager.rollback(status);
            }
        }
    }
}

方式二

package com.aaa.bbb.listen;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import javax.transaction.Transactional;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.orm.hibernate4.HibernateTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import com.aaa.bbb.common.Exceptions;
import com.aaa.bbb.common.SpringContextHolder;
import com.aaa.bbb.dao.util.Daoutil;


public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
    private static final Logger logger = LoggerFactory.getLogger(RedisKeyExpirationListener.class);
    @Autowired
    private Daoutil daoutil;

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    /**
     *
     * 监听redis过期失效的key
     */
    @Override
    public void onMessage(Message message, byte[] pattern){
        //手动开启hibernate的事务
        HibernateTransactionManager transactionManager = SpringContextHolder.getBean("txManager");
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); // 事物隔离级别，开启新事务，这样会比较安全些。
        TransactionStatus status = transactionManager.getTransaction(def); // 获得事务状态
        String redisKey = message.toString();
        logger.info("即将要失效的Key:" + redisKey);
        //System.out.println("即将要失效的Key:" + redisKey);
        if (StringUtils.isNotBlank(redisKey)) {
            String countSql = "select count(*) from slogintbl where tradeno =? ";
            List<String> countParams = new ArrayList<>();
            countParams.add(redisKey);
            try {
                int count = daoutil.queryCountSql(countSql, countParams);
                if (0 == count) {
                    return;//使用return
                } else {
                    List<String> params = new ArrayList<>();
                    SimpleDateFormat sf=new SimpleDateFormat("yyyyMMdd HH:mm:ss");
                    
                    params.add(sf.format(new Date()));
                    params.add(redisKey);
                    String sql = "update slogintbl set logoutdate=? where tradeno=?";
                    daoutil.updateOrSaveSql(sql, params);
                    transactionManager.commit(status);
                }
            } catch (Exception e) {
                // TODO Auto-generated catch block
                logger.debug(Exceptions.getStackTraceAsString(e));
                transactionManager.rollback(status);
            }finally {
                try {
                transactionManager.getSessionFactory().getCurrentSession().close();
                }catch(Exception e){
                    logger.debug("关闭资源异常");
                }
            }

        }
    }
}

手动开启hibernate的事务的问题
问题代码（监听redis过期的key）结果没有关闭资源导致连接池耗尽解决方式方式一方式二
MySQL数据库的事务transaction
事务操作分两种：自动事务（默认）、手动事务手动事务的操作流程开启事务：start transaction; 进...
事务、MySQL与Python交互、Python 中操作 MyS
1、事务事务操作分两种：自动事务（默认）、手动事务手动事务的操作流程开启事务：start transacti...
Dao层的四种对比
Dao四种比较 JDBCtemplate+JDBC+Mybatis+ Hibernate 1.JDBC。手动事务管...
JAVAEE——MySQL事务
事物概述 MySQL事务默认的事务一条sql语句就是一个事务，默认开启事务并提交事务手动事务：1.显式的开启...
如何解决秒杀场景下的超卖问题
1、利用排他锁解决超卖问题 MySQL InnoDB存储引擎支持事务和行锁。如果不手动开启事务的话，InnoDB会...
springboot 监听事务，执行另外的任务
最近做项目碰到一个问题，就是要在某些事务提交以后然后再去执行某些操作，有一种方法是手动开启事务，然后手动提交，提交...
hibernate的五大接口
session transaction1、事务是由session来产生的2、事务默认是关闭的，必须手动开启
spring手动提交事务与hibernate的坑
最近做项目的时候遇到一个问题 , 简要说一下项目的的坑如何出现 .中石油的这个项目 ,需要银行的查询系统 , 以...
springboot 事物管理
Spring Boot 默认集成事务，所以无须手动开启使用 @EnableTransactionManagemen...