SpringBoot數(shù)據(jù)訪問自定義使用Druid數(shù)據(jù)源的方法

更新時間：2021年08月07日 14:24:17 作者：xbhog

本文記錄Druid數(shù)據(jù)源的使用,自定義實現(xiàn)Drud的功能、監(jiān)控頁、登錄、統(tǒng)計等。對SpringBoot數(shù)據(jù)訪問使用Druid數(shù)據(jù)源的相關(guān)知識感興趣額朋友一起看看吧

數(shù)據(jù)訪問之Druid數(shù)據(jù)源的使用

說明：該數(shù)據(jù)源Druid,使用自定義方式實現(xiàn)，后面文章使用start啟動器實現(xiàn)，學(xué)習(xí)思路為主。

為什么要使用數(shù)據(jù)源：

當(dāng)程序需要進行數(shù)據(jù)庫訪問時，無須重新獲得數(shù)據(jù)庫連接，而是從連接池中取出一個空閑的數(shù)據(jù)庫連接。

當(dāng)程序使用數(shù)據(jù)庫連接訪問數(shù)據(jù)庫結(jié)束后，無須關(guān)閉數(shù)據(jù)庫連接，而是將數(shù)據(jù)庫連接歸還給連接池即可。

通過這種方式，就可避免頻繁地獲取數(shù)據(jù)庫連接、關(guān)閉數(shù)據(jù)庫連接所導(dǎo)致的性能下降

為什么要使用數(shù)據(jù)源

數(shù)據(jù)源是提高數(shù)據(jù)庫連接性能的常規(guī)手段，數(shù)據(jù)源會負(fù)責(zé)維持一個數(shù)據(jù)連接池，當(dāng)程序創(chuàng)建數(shù)據(jù)源實例時，系統(tǒng)會一次性地創(chuàng)建多個數(shù)據(jù)庫連接，并把這些數(shù)據(jù)庫連接保存在連接池中。當(dāng)程序需要進行數(shù)據(jù)庫訪問時，無須重新獲得數(shù)據(jù)庫連接，而是從連接池中取出一個空閑的數(shù)據(jù)庫連接。當(dāng)程序使用數(shù)據(jù)庫連接訪問數(shù)據(jù)庫結(jié)束后，無須關(guān)閉數(shù)據(jù)庫連接，而是將數(shù)據(jù)庫連接歸還給連接池即可。通過這種方式，就可避免頻繁地獲取數(shù)據(jù)庫連接、關(guān)閉數(shù)據(jù)庫連接所導(dǎo)致的性能下降。

Druid官方github地址

Druid中文文檔

Druid的介紹以及優(yōu)點：

Druid是阿里巴巴開源平臺上一個數(shù)據(jù)庫連接池實現(xiàn)，它不但結(jié)合了C3P0、DBCP、PROXOOL等數(shù)據(jù)庫連接池的優(yōu)點，同時還加入了日志監(jiān)控，可以分別監(jiān)控DB池連接和SQL的執(zhí)行情況，是一款針對監(jiān)控而生的數(shù)據(jù)庫連接池

整合第三方技術(shù)的兩種方式

自定義
找starter

自定義實現(xiàn)Druid數(shù)據(jù)源

引入數(shù)據(jù)源

博主版本：1.2.6

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>版本號</version>
</dependency>

配置數(shù)據(jù)源

因為在引入數(shù)據(jù)源，SpringBoot默配置的數(shù)據(jù)源是HikariDataSource,所以我們?nèi)绻褂肈ruid的話，需要自己創(chuàng)建一個數(shù)據(jù)源，并放到容器中使用，myDataSourceConfig文件代碼如下：

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;   //注意不要導(dǎo)錯包

@Configuration
//配置數(shù)據(jù)源
public class MyDtaSourceConfig {
    @Bean
    public DataSource dataSource() {

        return new DruidDataSource();   //創(chuàng)建Druid數(shù)據(jù)源
    }
}

為什么我們創(chuàng)建的數(shù)據(jù)源可以使用呢？

在DataSourceAutoConfiguration中的以下部分可以發(fā)現(xiàn)：

@Configuration(proxyBeanMethods = false)
	@Conditional(PooledDataSourceCondition.class)
	@ConditionalOnMissingBean({ DataSource.class, XADataSource.class })
	@Import({ DataSourceConfiguration.Hikari.class, DataSourceConfiguration.Tomcat.class,
			DataSourceConfiguration.Dbcp2.class, DataSourceConfiguration.OracleUcp.class,
			DataSourceConfiguration.Generic.class, DataSourceJmxConfiguration.class })
	protected static class PooledDataSourceConfiguration {

	}

有引入DataSourceConfiguration.Hikari.class這個默認(rèn)類，點擊進入，

@Configuration(proxyBeanMethods = false)
	@ConditionalOnClass(HikariDataSource.class)
	@ConditionalOnMissingBean(DataSource.class)
	@ConditionalOnProperty(name = "spring.datasource.type", havingValue = "com.zaxxer.hikari.HikariDataSource",
			matchIfMissing = true)
	static class Hikari {

		@Bean
		@ConfigurationProperties(prefix = "spring.datasource.hikari")  
		HikariDataSource dataSource(DataSourceProperties properties) {
			HikariDataSource dataSource = createDataSource(properties, HikariDataSource.class);
			if (StringUtils.hasText(properties.getName())) {
				dataSource.setPoolName(properties.getName());
			}
			return dataSource;
		}

	}

由上述代碼可以發(fā)現(xiàn)，默認(rèn)的配置源是HikariDataSource，但是有一個要求：

@ConditionalOnMissingBean(DataSource.class)

就是如果在容器中沒有數(shù)據(jù)源，下面代碼生效，也就是使用HikariDataSource，但是若容器中已經(jīng)有開發(fā)者創(chuàng)建的數(shù)據(jù)源，那么開發(fā)者創(chuàng)建的優(yōu)先。

在使用數(shù)據(jù)源的時候，不可避免地需要配置基本的屬性，如：url、用戶名、密碼、端口號等。所以我們可以將這些信息抽取出來，放到配置文件中，

這里我們采用yaml寫法application.yaml：

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/vuesite
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver

使用ConfigurationProperties注解來進行屬性的綁定：

package com.xbhog.Config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration
//配置數(shù)據(jù)源
public class MyDtaSourceConfig {
    @ConfigurationProperties("spring.datasource")  //屬性綁定 要加對位置
    @Bean
    public DataSource dataSource() {
        DruidDataSource druidDataSource = new DruidDataSource();

        return druidDataSource;
    }
}

進行單元測試：

package com.xbhog;

import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.jdbc.core.JdbcTemplate;

import javax.sql.DataSource;

@SpringBootTest
@Slf4j
class FirstAdminApplicationTests {
    @Autowired
    DataSource dataSource;
    
    @Test
    void contextLoads() {
        log.info("數(shù)據(jù)類型：{}",dataSource.getClass());
    }
}

結(jié)果==> 數(shù)據(jù)類型：class com.alibaba.druid.pool.DruidDataSource

具體的配置綁定：個人博客

Druid中的其他功能

配置監(jiān)控頁：

貼心文檔鏈接：網(wǎng)頁地址

我們需要配置一個servlet配置，然后放到容器中，輸入賬號密碼，進入鏈接地址即可訪問；

在配置數(shù)據(jù)源代碼下：

/**
* 配置監(jiān)控頁
*/
@Bean
public ServletRegistrationBean staViewServlet(){
    //實例化StatViewServlet
    StatViewServlet statViewServlet = new StatViewServlet();
	 //將實例化的實例化StatViewServlet 傳入ServletRegistrationBean，并設(shè)置訪問路徑
    ServletRegistrationBean<StatViewServlet> registrationBean = new ServletRegistrationBean<>(statViewServlet, "/druid/*");

    return registrationBean;
}

結(jié)果：

開啟登錄功能：

因為登錄設(shè)置還是在servlet中設(shè)置的，所以相關(guān)信息暫略，貼一個文檔截圖：

代碼添加：

@Bean
public ServletRegistrationBean staViewServlet(){
    StatViewServlet statViewServlet = new StatViewServlet();

    ServletRegistrationBean<StatViewServlet> registrationBean = new ServletRegistrationBean<>(statViewServlet, "/druid/*");
    //配置登錄信息
    registrationBean.addInitParameter("loginUsername","admin");
    registrationBean.addInitParameter("loginPassword","123456");
    return registrationBean;
}

結(jié)果：

打開監(jiān)控統(tǒng)計功能：

測試Sql監(jiān)控功能。

網(wǎng)頁地址：

創(chuàng)建一個DruidDataSource組件，并配置其中的屬性filters的value為stat，這樣才能打開監(jiān)控功能。

所以我們在創(chuàng)建數(shù)據(jù)源的地方需要配置filters屬性：

public class MyDtaSourceConfig {
    @ConfigurationProperties("spring.datasource")
    @Bean
    public DataSource dataSource() throws SQLException {
        DruidDataSource druidDataSource = new DruidDataSource();
        //加入監(jiān)控功能
        druidDataSource.setFilters("stat");
        return druidDataSource;
    }
}

也可以進行屬性的配置來實現(xiàn)上述的效果：（第二種方法）

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/vuesite
    username: root
    password: 123456
    driver-class-name: com.mysql.jdbc.Driver

    filters: stat
    tomcat:
      max-active: 12

然后設(shè)置一個請求，來測試監(jiān)控功能；

創(chuàng)建一個controller:

@Controller
public class tablecontro {

  	  @Autowired
    JdbcTemplate jdbcTemplate;

    @ResponseBody   //不經(jīng)過視圖解析器
    @GetMapping("/sql")
    public String druidquery(){
        Long aLong = jdbcTemplate.queryForObject("select count(*) from user",Long.class);
        return aLong.toString();
    }
}

先訪問localhost:8080/sql,然后進入http://localhost:8080/druid/index.html頁面中的SQL監(jiān)控，即可查看執(zhí)行次數(shù)次數(shù)。

在最大并發(fā)的后面的有各種分布，可以參考官方文檔：Druid連接池介紹

開啟Web應(yīng)用功能：

基本上還是跟上面一樣的；

WebStatFilter用于采集web-jdbc關(guān)聯(lián)監(jiān)控的數(shù)據(jù)。

網(wǎng)頁地址

配置一個WebStatFilter，然后需要初始化exclusions，來排除一些不必要的url.得先進行sql的請求

/**
     * WebStatFilter用于采集web-jdbc關(guān)聯(lián)監(jiān)控的數(shù)據(jù)。
     */
@Bean
public FilterRegistrationBean webRegistrationBean(){
    WebStatFilter webStatFilter = new WebStatFilter();
    FilterRegistrationBean<WebStatFilter> registrationBean = new FilterRegistrationBean<>(webStatFilter);
    registrationBean.setUrlPatterns(Arrays.asList("/*"));
    //添加一些不必要的ulr,在初始化的時候就執(zhí)行
    registrationBean.addInitParameter("exclusions","*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
    return  registrationBean;
}

結(jié)果：

Web應(yīng)用：

URL監(jiān)控

配置防火墻：

wallfilter

所以我們可以結(jié)合Filter一起使用，代碼如下：得先進行sql的請求。

public class MyDtaSourceConfig {
    @ConfigurationProperties("spring.datasource")
    @Bean
    public DataSource dataSource() throws SQLException {
        DruidDataSource druidDataSource = new DruidDataSource();
        //加入監(jiān)控功能
        druidDataSource.setFilters("stat,wall");
        return druidDataSource;
    }
}

結(jié)果：

參考文獻

Druid官方github地址

Druid中文文檔

引用

SpringBoot2零基礎(chǔ)入門springboot全套完整版

結(jié)束：

如果你看到這里或者正好對你有所幫助，希望能點個關(guān)注或者推薦，感謝；

有錯誤的地方，歡迎在評論指出，作者看到會進行修改。

到此這篇關(guān)于SpringBoot數(shù)據(jù)訪問自定義使用Druid數(shù)據(jù)源的方法的文章就介紹到這了,更多相關(guān)SpringBoot數(shù)據(jù)訪問使用Druid數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: