찾다

 >  Q&A  >  본문

java的DriverManager.getConnection为什么返回同一个connection?

我启动了十个线程去测试一个业务方法,但有时候会报出连接已经关闭,无法继续操作的异常。直接上代码了:
首先是测试代码:

public class Test {
    public static void main(String[] args){
//        ProductService productService = new ProductServiceImpl();
//        productService.updateProductPrice(1, 3000);

        for(int i=0;i<10;i++){
            ProductService productService = new ProductServiceImpl();
            MyThread myThread = new MyThread(productService);
            myThread.start();
        }
    }
}

class MyThread extends Thread{

    private ProductService productService;

    public MyThread(ProductService productService){
        this.productService = productService;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName());
        productService.updateProductPrice(1,3000);
    }
}

业务代码:

public class ProductServiceImpl implements ProductService{
    private static final String UPDATE_PRODUCT_SQL = "update product set price = ? where id = ?";
    private static final String INSERT_LOG_SQL = "insert into log (created, description) values (?, ?)";

    public void updateProductPrice(long productId, int price) {
        Connection conn = null;
        try {
            // 获取连接
            conn = DBUtil.getConnection();
            System.out.println(Thread.currentThread().getName()+"---->"+conn.toString());
            conn.setAutoCommit(false); // 关闭自动提交事务(开启事务)

            // 执行操作
            updateProduct(conn, UPDATE_PRODUCT_SQL, productId, price); // 更新产品
            insertLog(conn, INSERT_LOG_SQL, "Create product."); // 插入日志

            // 提交事务
            conn.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            DBUtil.closeConnection(conn);
        }
    }

    private void updateProduct(Connection conn, String updateProductSQL, long productId, int productPrice) throws Exception {
        PreparedStatement pstmt = conn.prepareStatement(updateProductSQL);
        pstmt.setInt(1, productPrice);
        pstmt.setLong(2, productId);
        int rows = pstmt.executeUpdate();
        if (rows != 0) {
            System.out.println("Update product success!");
        }
    }

    private void insertLog(Connection conn, String insertLogSQL, String logDescription) throws Exception {
        PreparedStatement pstmt = conn.prepareStatement(insertLogSQL);
        pstmt.setString(1, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS").format(new Date()));
        pstmt.setString(2, logDescription);
        int rows = pstmt.executeUpdate();
        if (rows != 0) {
            System.out.println("Insert log success!");
        }
    }
}

数据库操作类:

public class DBUtil {
    private static final String driver = "com.mysql.jdbc.Driver";
    private static final String url = "jdbc:mysql://localhost:3306/demo";
    private static final String username = "root";
    private static final String password = "root";

    // 定义一个数据库连接
    private static Connection conn = null;

    // 获取连接
    public static Connection getConnection() {
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }

    // 关闭连接
    public static void closeConnection(Connection conn) {
        try {
            if (conn != null) {
                conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


}

其中一次得到的运行结果:

PHP中文网PHP中文网2803일 전838

모든 응답(3)나는 대답할 것이다

  • 伊谢尔伦

    伊谢尔伦2017-04-18 10:30:56

    문제는 DBUtil의 다음 코드 줄에 있습니다.

    으아악

    conn 변수는 전역 정적 변수이며 모든 스레드에서 공유됩니다.

    극단적인 경우:
    스레드 A가 conn = DriverManager.getConnection(...)으로 실행되면 conn은 데이터베이스 연결입니다.
    스레드 B는 conn = DriverManager.getConnection(...)으로 실행됩니다. conn이 데이터베이스 b 연결로 재할당되는 경우

    이때 conn은 모든 스레드에서 공유되므로 스레드 A와 스레드 B에 대한 conn 값은 데이터베이스 b 연결입니다. 이로 인해 모든 스레드가 데이터베이스 연결을 공유하게 됩니다. 한 스레드가 연결을 닫으면 다른 스레드가 예외를 발생시킵니다.

    또한 데이터베이스 b 연결은 마지막에 공유되기 때문에 데이터베이스 a 연결을 닫을 수 없어 메모리 누수가 발생합니다.

    회신하다
    0
  • 巴扎黑

    巴扎黑2017-04-18 10:30:56

    매번 다른 연결이 반환된다는 보장은 없다고 해야 할까요
    결국 멤버변수로 썼네요

    회신하다
    0
  • 天蓬老师

    天蓬老师2017-04-18 10:30:56

    풀을 사용하려면 여러 풀을 초기화하고 각 연결에 하나씩 할당하세요.

    으아악

    회신하다
    0
  • 취소회신하다