JDBC p5 資料庫連接池

来源:https://www.cnblogs.com/zh-Note/archive/2023/07/31/17583084.html
-Advertisement-
Play Games

# 資料庫連接池 ## **傳統獲取Connection問題分析** 1. 傳統的JDBC資料庫使用 DriverManager 來獲取， **每次向資料庫建立連接的時候都要將 Connection 載入到記憶體中，再驗證IP地址，用戶名和密碼（0.05 ~ 1 s 時間）**。需要資料庫連接的時候， ...


資料庫連接池

傳統獲取Connection問題分析

  1. 傳統的JDBC資料庫使用 DriverManager 來獲取， 每次向資料庫建立連接的時候都要將 Connection 載入到記憶體中，再驗證IP地址，用戶名和密碼（0.05 ~ 1 s 時間）。需要資料庫連接的時候，就向資料庫要求一個，頻繁的進行資料庫連接操作將占用很多的系統資源，容易造成伺服器崩潰。
  2. 每一次資料庫連接使用後都得斷開，如果程式出現異常而未能關閉，將導致資料庫記憶體泄漏，最終將導致重啟資料庫。
  3. 傳統獲取連接的方式，不能控制創建的連接數量，如果連接過多，也可能導致記憶體泄露，MySQL崩潰。
  4. 解決傳統開發中的資料庫連接問題，可以採用資料庫連接池技術。

案例：

package com.hspedu.jdbc.datasource;

import com.hspedu.jdbc.utils.JDBCUtils;
import org.junit.jupiter.api.Test;

import java.sql.Connection;

public class ConQuestion {

    //代碼 連接mysql 5000次
    @Test
    public void testCon(){
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++){
            //使用傳統jdbc連接方式
            Connection connection = JDBCUtils.getConnection();

            //可能會拋出too many connections的異常

            //再看看，如果得到連接就立即關閉，總共會耗時多久
            JDBCUtils.close(null, null, connection);
        }
        long end = System.currentTimeMillis();
        System.out.println("耗時 = " + (end - start));//耗時 = 6598
    }
}

資料庫連接池原理

  • 基本介紹

    1. 預先在緩衝池中放入一定數量的連接，當需要建立資料庫連接時，只需要從“緩衝池”中取出一個，使用完畢之後再放回去（放回連接，其實就是指程式不再引用這個連接）。
    2. 資料庫連接池負責分配、管理和釋放資料庫連接，它允許應用程式重覆使用一個現有的資料庫連接，而不是重新建立一個。
    3. 當應用程式向連接池請求的連接數超過最大連接數量時，這些請求將被加入到等待隊列中。

    原理示意圖：

常用的資料庫連接池

​ JDBC 的資料庫連接池使用 javax.sql.DateSource 來表示，DataSource 只是一個介面，該介面通常由第三方提供實現。

資料庫連接池種類：**

  1. C3P0 資料庫連接池：速度相對較慢，穩定性不錯 （hibernate，spring）；
  2. DBCP 資料庫連接池：速度相對C3P0較快，但不穩定；
  3. Proxool 資料庫連接池：有監控連接池狀態的功能，穩定性較C3P0差一點；
  4. BoneCP 資料庫連接池：速度快；
  5. Druid（德魯伊） 資料庫連接池：是阿裡提供的資料庫連接池，集DBCP、C3P0、Proxool優點於一身的資料庫連接池；

C3P0的使用

需要自行導入相關的jar包。

  1. 方式1：相關參數，在程式中指定user，url， password。
  2. 方式2： 使用配置文件的模板來完成。

代碼演示：

package com.hspedu.jdbc.datasource;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.junit.jupiter.api.Test;

import java.beans.PropertyVetoException;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

public class C3P0_ {

    //方式1：相關參數，在程式中指定user, url, password
    @Test
    public void testC3P0_01() throws IOException, PropertyVetoException, SQLException {

        //1. 創建一個數據源對象
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();

        //2. 通過配置文件獲取相關連接信息
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\mysql.properties"));
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String url = properties.getProperty("url");
        String driver = properties.getProperty("driver");

        //給數據源（數據源負責連接，連接池） comboPooledDataSource 設置參數
        comboPooledDataSource.setDriverClass(driver);
        comboPooledDataSource.setJdbcUrl(url);
        comboPooledDataSource.setUser(user);
        comboPooledDataSource.setPassword(password);

        //設置初始化連接數
        comboPooledDataSource.setInitialPoolSize(10);

        //最大連接數
        comboPooledDataSource.setMaxPoolSize(50);

        //獲取連接
        //測試連接池的效率，連接5000次
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            Connection connection = comboPooledDataSource.getConnection();//這個方法就是從DateSource介面實現的
//            System.out.println("連接OK");

            //關閉
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("c3p0 5000次連接mysql 耗時 = " + (end - start));//c3p0 5000次連接mysql 耗時 = 280，之前傳統的耗時 = 6598
    }


    //第二種方式， 使用配置文件的模板來完成
    //1. 將c3p0 提供的 c3p0.config.xml 拷貝到src目錄
    //2. 該文件指定了連接資料庫和連接池的相關參數
    @Test
    public void testC3P0_02() throws SQLException {
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource("hsp_edu");//填入數據源名稱

        long start = System.currentTimeMillis();
        for (int i = 0; i < 500000; i++) {
            Connection connection = comboPooledDataSource.getConnection();//這個方法就是從DateSource介面實現的
//            System.out.println("連接OK");

            //關閉
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("c3p0 第二種方式500000次連接mysql 耗時 = " + (end - start));//c3p0 第二種方式500000次連接mysql 耗時 = 1452

    }
}

配置文件 c3p0-config.xml：

<c3p0-config>
        <named-config name="hsp_edu">
            <!--  連接參數 -->
            <property name="driverClass">com.mysql.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc_learning</property>
            <property name="user">root</property>
            <property name="password">root</property>

            <!-- 連接池參數 -->
            <!-- 每次增長的連接數 -->
            <property name="acquireIncrement">5</property>
            <!-- 初始的連接數 -->
            <property name="initialPoolSize">5</property>
            <!-- 最大連接數 -->
            <property name="maxPoolSize">10</property>
            <!-- 最小連接數 -->
            <property name="minPoolSize">5</property>
            <!-- 每個連接對象可連接的最多的命令對象數 -->
            <property name="maxStatementPerConnection">2</property>
        </named-config>
</c3p0-config>

Druid（德魯伊）的使用

需要自行導入相關的jar包。

代碼演示：

package com.hspedu.jdbc.datasource;

import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.junit.jupiter.api.Test;

import javax.sql.DataSource;
import java.io.FileInputStream;
import java.sql.Connection;
import java.util.Properties;

public class Druid_ {

    @Test
    public void testDruid() throws Exception {
        //1. 加入 Druid jar包
        //2. 加入 配置文件 druid.properties，將該文件拷貝到項目的src目錄
        //3. 創建 Properties 對象
        Properties properties = new Properties();
        properties.load(new FileInputStream("src\\druid.properties"));

        //4. 創建一個指定參數的資料庫連接池
        DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);

        long start = System.currentTimeMillis();
        for (int i = 0; i < 500000; i++) {
            Connection connection = dataSource.getConnection();
//            System.out.println("連接成功");
            connection.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("druid連接池， 連接500000次 耗時 = " + (end - start));//druid連接池， 連接500000次 耗時 = 549

    }
}

配置文件 druid.properties：

#key=value
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbc_learning?rewriteBatchedStatements=true
username=root
password=root
#initial connection size
initialSize=10
#min idle connection size
minIdle=5
#max active connection size
maxActive=50
#max wait time (5000 mil seconds)
maxWait=5000

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【技術實戰】Vue功能樣式實戰【五】
    博客推行版本更新，成果積累制度，已經寫過的博客還會再次更新，不斷地琢磨，高質量高數量都是要追求的，工匠精神是學習必不可少的精神。因此，大家有何建議歡迎在評論區踴躍發言，你們的支持是我最大的動力，你們敢投，我就敢肝 ...
  • 【技術實戰】Vue功能樣式實戰【四】
    博客推行版本更新，成果積累制度，已經寫過的博客還會再次更新，不斷地琢磨，高質量高數量都是要追求的，工匠精神是學習必不可少的精神。因此，大家有何建議歡迎在評論區踴躍發言，你們的支持是我最大的動力，你們敢投，我就敢肝 ...
  • 中台，真的窮途末路了？
    在阿裡新的“6+N”業務子公司內部，依然會存在滿足子公司商業業務模式的中台體系。中台，不會消失，仍將發揮重要作用。 ...
  • 設計模式原則之：單一職責模式
    DDD領域建模被各個大小廠商提起並應用，而每個人都有自己的理解，本文就是針對小白，系統地講解DDD到底是什麼，解決了什麼問題，及一些建議和實踐。本文主要是思想的一種碰撞和分享，希望能對朋友們有所啟發或幫助。 ...
  • python3使用ESL和sipp自動多輪壓測FreeSWITCH
    環境：CentOS 7.6_x64 FreeSWITCH版本 ：1.10.9 sipp版本：3.6.1 python版本：3.9.12 日常工作中，有時會遇到批量自動壓測FreeSWITCH的需求，sipp是一個非常好的VoIP壓測工具，python是個很好用的腳本語言，今天記錄下CentOS 7環 ...
  • RocketMq消費原理及源碼解析
    ## Spring安全框架 Spring Security是一個用於保護基於Java的應用程式的框架。它是一個功能強大且高度可定製的身份驗證和訪問控制框架，可以輕鬆地集成到各種應用程式中，包括Web應用程式和RESTful Web服務。Spring Security提供了全面的安全解決方案，用於身份 ...
  • 註意！JAVA中的值傳遞
    前言：今天在解決一個問題時，程式總是不能輸出正確值，分析邏輯思路沒問題後，發現原來是由於函數傳遞導致了這個情況。 LeetCode 113 問題：給你二叉樹的根節點root和一個整數目標和targetSum，找出所有 從根節點到葉子節點 路徑總和等於給定目標和的路徑。 示例 輸入：root = [5 ...
  • 高效Python-1提高數據處理效率的迫切需要
    ## python規範 - 函數必須寫註釋：文檔註釋格式`'''註釋內容'''` - 參數中的等號兩邊不要用空格 - 相鄰函數用兩個空行隔開 - 小寫 \+ 下劃線 1. 函數名 2. 模塊名 3. 實例名 - 駝峰法 1. 類名 ## tips ```python # 一行代碼太長，使用\折行 i ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類