Spring配置Druid詳細說明

本文轉載自查看原文 2019-08-09 18:20 1343 Java

**簡單直接，上代碼，開封即食**

***yml文件內容配置***

 1 # 數據源配置
 2 spring:
 3     datasource:
 4         type: com.alibaba.druid.pool.DruidDataSource
 5         driverClassName: com.mysql.cj.jdbc.Driver
 6         druid:
 7             # 主庫數據源
 8             master:
 9                 url: jdbc:mysql://****
10                 username: ****
11                 password: ****
12             # 從庫數據源
13             slave:
14                 # 從數據源開關/默認關閉
15                 enabled: false
16                 url: 
17                 username: 
18                 password: 
19             # 初始連接數
20             initialSize: 5
21             # 最小連接池數量
22             minIdle: 10
23             # 最大連接池數量
24             maxActive: 20
25             # 配置獲取連接等待超時的時間
26             maxWait: 60000
27             # 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒
28             timeBetweenEvictionRunsMillis: 60000
29             # 配置一個連接在池中最小生存的時間，單位是毫秒
30             minEvictableIdleTimeMillis: 300000
31             # 配置一個連接在池中最大生存的時間，單位是毫秒
32             maxEvictableIdleTimeMillis: 900000
33             # 配置檢測連接是否有效
34             validationQuery: SELECT 1 FROM DUAL
35             testWhileIdle: true
36             testOnBorrow: false
37             testOnReturn: false
38             webStatFilter: 
39                 enabled: true
40             statViewServlet:
41                 enabled: true
42                 # 設置白名單，不填則允許所有訪問
43                 allow:
44                 url-pattern: /monitor/druid/*
45             filter:
46                 stat:
47                     enabled: true
48                     # 慢SQL記錄
49                     log-slow-sql: true
50                     slow-sql-millis: 1000
51                     merge-sql: true
52                 wall:
53                     config:
54                         multi-statement-allow: true

***DruidConfig文件***

  1 import java.io.IOException;
  2 import java.util.HashMap;
  3 import java.util.Map;
  4 import javax.servlet.Filter;
  5 import javax.servlet.FilterChain;
  6 import javax.servlet.ServletException;
  7 import javax.servlet.ServletRequest;
  8 import javax.servlet.ServletResponse;
  9 import javax.sql.DataSource;
 10 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 11 import org.springframework.boot.context.properties.ConfigurationProperties;
 12 import org.springframework.boot.web.servlet.FilterRegistrationBean;
 13 import org.springframework.context.annotation.Bean;
 14 import org.springframework.context.annotation.Configuration;
 15 import org.springframework.context.annotation.Primary;
 16 import com.alibaba.druid.pool.DruidDataSource;
 17 import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
 18 import com.alibaba.druid.spring.boot.autoconfigure.properties.DruidStatProperties;
 19 import com.alibaba.druid.util.Utils;
 20 import com.heater.common.enums.DataSourceType;
 21 import com.heater.framework.config.properties.DruidProperties;
 22 import com.heater.framework.datasource.DynamicDataSource;
 23 
 24 /**
 25  * druid 配置多數據源
 26  */
 27 @Configuration
 28 public class DruidConfig
 29 {
 30     @Bean
 31     @ConfigurationProperties("spring.datasource.druid.master")
 32     public DataSource masterDataSource(DruidProperties druidProperties)
 33     {
 34         DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
 35         return druidProperties.dataSource(dataSource);
 36     }
 37 
 38     @Bean
 39     @ConfigurationProperties("spring.datasource.druid.slave")
 40     @ConditionalOnProperty(prefix = "spring.datasource.druid.slave", name = "enabled", havingValue = "true")
 41     public DataSource slaveDataSource(DruidProperties druidProperties)
 42     {
 43         DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
 44         return druidProperties.dataSource(dataSource);
 45     }
 46 
 47     @Bean(name = "dynamicDataSource")
 48     @Primary
 49     public DynamicDataSource dataSource(DataSource masterDataSource, DataSource slaveDataSource)
 50     {
 51         Map<Object, Object> targetDataSources = new HashMap<>();
 52         targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
 53         targetDataSources.put(DataSourceType.SLAVE.name(), slaveDataSource);
 54         return new DynamicDataSource(masterDataSource, targetDataSources);
 55     }
 56 
 57     /**
 58      * 去除監控頁面底部的廣告
 59      */
 60     @SuppressWarnings({ "rawtypes", "unchecked" })
 61     @Bean
 62     @ConditionalOnProperty(name = "spring.datasource.druid.statViewServlet.enabled", havingValue = "true")
 63     public FilterRegistrationBean removeDruidFilterRegistrationBean(DruidStatProperties properties)
 64     {
 65         // 獲取web監控頁面的參數
 66         DruidStatProperties.StatViewServlet config = properties.getStatViewServlet();
 67         // 提取common.js的配置路徑
 68         String pattern = config.getUrlPattern() != null ? config.getUrlPattern() : "/druid/*";
 69         String commonJsPattern = pattern.replaceAll("\\*", "js/common.js");
 70         final String filePath = "support/http/resources/js/common.js";
 71         // 創建filter進行過濾
 72         Filter filter = new Filter()
 73         {
 74             @Override
 75             public void init(javax.servlet.FilterConfig filterConfig) throws ServletException
 76             {
 77             }
 78             @Override
 79             public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
 80                     throws IOException, ServletException
 81             {
 82                 chain.doFilter(request, response);
 83                 // 重置緩沖區，響應頭不會被重置
 84                 response.resetBuffer();
 85                 // 獲取common.js
 86                 String text = Utils.readFromResource(filePath);
 87                 // 正則替換banner, 除去底部的廣告信息
 88                 text = text.replaceAll("<a.*?banner\"></a><br/>", "");
 89                 text = text.replaceAll("powered.*?shrek.wang</a>", "");
 90                 response.getWriter().write(text);
 91             }
 92             @Override
 93             public void destroy()
 94             {
 95             }
 96         };
 97         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
 98         registrationBean.setFilter(filter);
 99         registrationBean.addUrlPatterns(commonJsPattern);
100         return registrationBean;
101     }
102 }

***DruidProperties文件***

 1 import org.springframework.beans.factory.annotation.Value;
 2 import org.springframework.context.annotation.Configuration;
 3 import com.alibaba.druid.pool.DruidDataSource;
 4 
 5 /**
 6  * druid 配置屬性
 7  */
 8 @Configuration
 9 public class DruidProperties
10 {
11     @Value("${spring.datasource.druid.initialSize}")
12     private int initialSize;
13 
14     @Value("${spring.datasource.druid.minIdle}")
15     private int minIdle;
16 
17     @Value("${spring.datasource.druid.maxActive}")
18     private int maxActive;
19 
20     @Value("${spring.datasource.druid.maxWait}")
21     private int maxWait;
22 
23     @Value("${spring.datasource.druid.timeBetweenEvictionRunsMillis}")
24     private int timeBetweenEvictionRunsMillis;
25 
26     @Value("${spring.datasource.druid.minEvictableIdleTimeMillis}")
27     private int minEvictableIdleTimeMillis;
28 
29     @Value("${spring.datasource.druid.maxEvictableIdleTimeMillis}")
30     private int maxEvictableIdleTimeMillis;
31 
32     @Value("${spring.datasource.druid.validationQuery}")
33     private String validationQuery;
34 
35     @Value("${spring.datasource.druid.testWhileIdle}")
36     private boolean testWhileIdle;
37 
38     @Value("${spring.datasource.druid.testOnBorrow}")
39     private boolean testOnBorrow;
40 
41     @Value("${spring.datasource.druid.testOnReturn}")
42     private boolean testOnReturn;
43 
44     public DruidDataSource dataSource(DruidDataSource datasource)
45     {
46         /** 配置初始化大小、最小、最大 */
47         datasource.setInitialSize(initialSize);
48         datasource.setMaxActive(maxActive);
49         datasource.setMinIdle(minIdle);
50 
51         /** 配置獲取連接等待超時的時間 */
52         datasource.setMaxWait(maxWait);
53 
54         /** 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒 */
55         datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
56 
57         /** 配置一個連接在池中最小、最大生存的時間，單位是毫秒 */
58         datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
59         datasource.setMaxEvictableIdleTimeMillis(maxEvictableIdleTimeMillis);
60 
61         /**
62          * 用來檢測連接是否有效的sql，要求是一個查詢語句，常用select 'x'。如果validationQuery為null，testOnBorrow、testOnReturn、testWhileIdle都不會起作用。
63          */
64         datasource.setValidationQuery(validationQuery);
65         /** 建議配置為true，不影響性能，並且保證安全性。申請連接的時候檢測，如果空閑時間大於timeBetweenEvictionRunsMillis，執行validationQuery檢測連接是否有效。 */
66         datasource.setTestWhileIdle(testWhileIdle);
67         /** 申請連接時執行validationQuery檢測連接是否有效，做了這個配置會降低性能。 */
68         datasource.setTestOnBorrow(testOnBorrow);
69         /** 歸還連接時執行validationQuery檢測連接是否有效，做了這個配置會降低性能。 */
70         datasource.setTestOnReturn(testOnReturn);
71         return datasource;
72     }
73 }

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Spring Cloud Eureka配置文件例子與較為詳細說明 ES配置詳細說明 web.config配置詳細說明 web.config配置詳細說明 tomcat下的日志配置詳細說明 Apache日志配置參數詳細說明 vsftpd 配置文件詳細說明 web.config配置詳細說明 Nginx配置參數中文詳細說明 Webpack配置示例和詳細說明