欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

用ThreadLocal完成事务:一个事务一次连接

程序员文章站 2022-03-01 23:20:45
...

ThreadLocal 线程变量,和Synchonized都用于处理多线程并发问题.

一句话理解ThreadLocal,向ThreadLocal里面存东西就是向它里面的Map存东西的,然后ThreadLocal把这个Map挂到当前的线程底下,这样Map就只属于这个线程了。

区别在于:ThreadLocal用数据隔离

                Synchonized用数据共享

思路:用set()方法将连接对象放入ThreadLocal中,使用时就通过get()方法拿出来.


//将连接存入ThreadLocal中

public static Connection getConnection(){
        Connection connection = threadLocal.get();
        if (connection!=null){
            return connection;
        }
        try{
            connection=JdbcUtils.getConnection();
            threadLocal.set(connection);
        }catch (Exception e){
            e.printStackTrace();
        }

        return threadLocal.get();
    }

//在service层调用



public void transfer(Integer sourceId, Integer targetId, Double money) {
        Connection connection = getConnection();


        try {
            connection.setAutoCommit(false);

            Account sourceAccount =  accountDao.findAccountById(sourceId,connection);
            Account targetAccount =  accountDao.findAccountById(targetId,connection);

            sourceAccount.setMoney(sourceAccount.getMoney()-money);
            accountDao.updateAccount(sourceAccount,connection);

            targetAccount.setMoney(targetAccount.getMoney()-money);
            accountDao.updateAccount(targetAccount,connection);


            connection.commit();
        }catch (Exception e){
            e.printStackTrace();

            try {
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }


    }