SpringBoot整合Druid

迩来不停在折腾springboot，也根据需要整合了一些好用的库，mybatis作为连续层数据操作，也想用一下大名鼎鼎的Druid来做毗连池和数据库监控服务。于是探索了一下战书，整理出这篇小文，盼望能帮助到同道，也给本身做个记载反思。

• 1.关于Druid

Druid是阿里团队开源的高性能数据库毗连池，国内利用广泛，特别是在监控sql和数据库性能方面非常强大。

毗连池能有效节流数据库毗连消耗，且对高写入、实时性要求高的业务非常符合。

• 2.引入依赖到pom.xml中。

1. <code><dependency>
2. <groupId>com.alibaba</groupId>
3. <artifactId>druid-spring-boot-starter</artifactId>
4. <version>1.1.10</version>
5. </dependency>
6. </code>

复制代码

• 3.然后在application.yml中设置相干设置

1. <code>spring:
2. datasource:
3. url: jdbc:mysql://127.0.0.1:3306/test_go?characterEncoding=UTF-8&useSSL=false
4. username: xxx
5. password: xxxxxx
6. driver-class-name: com.mysql.jdbc.Driver
7. type: com.alibaba.druid.pool.DruidDataSource
8. druid:
9. initial-size: 5
10. min-idle: 5
11. max-active: 20
12. test-while-idle: true
13. test-on-borrow: false
14. test-on-return: false
15. pool-prepared-statements: true
16. max-pool-prepared-statement-per-connection-size: 20
17. max-wait: 60000
18. time-between-eviction-runs-millis: 60000
19. min-evictable-idle-time-millis: 30000
20. filters: stat
21. async-init: true</code>

复制代码

此中最重要的是

type: com.alibaba.druid.pool.DruidDataSource

如许就不会利用Springboot默认的毗连池Hikari。

由于SpringBoot没法见效写在yml文件中的设置，需要单独编写Bean文件来加载。

• 4.定义Druid设置类。

1. <code>package com.tony.testspringboot.config;
4. import com.alibaba.druid.pool.DruidDataSource;
5. import org.slf4j.Logger;
6. import org.slf4j.LoggerFactory;
7. import org.springframework.beans.factory.annotation.Value;
8. import org.springframework.context.annotation.Bean;
9. import org.springframework.context.annotation.Configuration;
10. import org.springframework.context.annotation.Primary;
12. import javax.sql.DataSource;
13. import java.sql.SQLException;
15. @Configuration
16. public class DruidConfig {
17. private Logger logger = LoggerFactory.getLogger(DruidConfig.class);
19. @Value("${spring.datasource.url}")
20. private String dbUrl;
22. @Value("${spring.datasource.username}")
23. private String username;
25. @Value("${spring.datasource.password}")
26. private String password;
27. @Value("${spring.datasource.test-druid.driver-class-name}")
28. private String driverClassName;
30. @Value("${spring.datasource.druid.initial-size}")
31. private int initialSize;
33. @Value("${spring.datasource.druid.min-idle}")
34. private int minIdle;
36. @Value("${spring.datasource.druid.max-active}")
37. private int maxActive;
39. @Value("${spring.datasource.druid.max-wait}")
40. private int maxWait;
42. @Value("${spring.datasource.druid.time-between-eviction-runs-millis}")
43. private int timeBetweenEvictionRunsMillis;
45. @Value("${spring.datasource.druid.min-evictable-idle-time-millis}")
46. private int minEvictableIdleTimeMillis;
48. @Value("${spring.datasource.druid.test-while-idle}")
49. private boolean testWhileIdle;
51. @Value("${spring.datasource.druid.test-on-borrow}")
52. private boolean testOnBorrow;
54. @Value("${spring.datasource.druid.test-on-return}")
55. private boolean testOnReturn;
57. @Value("${spring.datasource.druid.pool-prepared-statements}")
58. private boolean poolPreparedStatements;
60. @Value("${spring.datasource.druid.max-pool-prepared-statement-per-connection-size}")
61. private int maxPoolPreparedStatementPerConnectionSize;
63. @Value("${spring.datasource.druid.filters}")
64. private String filters;
66. @Bean
67. @Primary
68. public DataSource dataSource() {
69. DruidDataSource datasource = new DruidDataSource();
71. datasource.setUrl(this.dbUrl);
72. datasource.setUsername(this.username);
73. datasource.setPassword(this.password);
74. datasource.setDriverClassName(this.driverClassName);
76. // configuration
77. datasource.setInitialSize(this.initialSize);
78. datasource.setMinIdle(this.minIdle);
79. datasource.setMaxActive(this.maxActive);
80. datasource.setMaxWait(this.maxWait);
81. datasource.setTimeBetweenEvictionRunsMillis(this.timeBetweenEvictionRunsMillis);
82. datasource.setMinEvictableIdleTimeMillis(this.minEvictableIdleTimeMillis);
83. datasource.setTestWhileIdle(this.testWhileIdle);
84. datasource.setTestOnBorrow(this.testOnBorrow);
85. datasource.setTestOnReturn(this.testOnReturn);
86. datasource.setPoolPreparedStatements(this.poolPreparedStatements);
87. datasource.setMaxPoolPreparedStatementPerConnectionSize(this.maxPoolPreparedStatementPerConnectionSize);
89. try {
90. datasource.setFilters(this.filters);
91. } catch (SQLException e) {
92. logger.error("druid configuration init fail!");
93. }
95. return datasource;
96. }
97. }
98. </code>

复制代码

云云即可让设置的参数见效并作为首选的DataSource进利用用。

5.在Controller中测试。

可以利用JdbcTemplate来进行查询。
测试代码如下所示：

1. <code>@RequestMapping(value = "/hey", method = RequestMethod.GET)
2. public ResultResponse testDruid() {
4. String sql = "SELECT mobile FROM user WHERE id = ?";
6. String mobile = jdbcTemplate.queryForObject(sql, new Object[]{1}, String.class);
8. return new ResultResponse(201, "hey" + mobile);
9. }
10. </code>

复制代码

PS: ResultResponse是我项目中封装的通用response对象。

关于多数据源参数的设置。

只需要在yml(application.yml)中设置即可，格式如下：

1. <code>datasource:
2. one-source:
3. url: jdbc:mysql://127.0.0.1:3306/test_go?characterEncoding=UTF-8&useSSL=false
4. username: xxxx1
5. password: xxxx
6. driver-class-name: com.mysql.jdbc.Driver
7. type: com.alibaba.druid.pool.DruidDataSource
8. two-source:
9. url: jdbc:mysql://127.0.0.1:3306/demo2?characterEncoding=UTF-8&useSSL=false
10. username: xxxx
11. password: 1xxxxxx
12. driver-class-name: com.mysql.jdbc.Driver
13. type: com.alibaba.druid.pool.DruidDataSource
14. ...</code>

复制代码

利用的时候也遵照这个结构，如要获取第一个数据源的url设置则在DruidConfig.java文件中的相应项的@Value中如许写：

1. <code>@Value("${spring.datasource.one-source.url}")
2. private String dbUrl;</code>

复制代码

• 6.设置数据库监控。

a) 先在application.yml中增加如下设置：

1. <code>druid:
2. .....
3. # 通过connectProperties属性来打开mergeSql功能；慢SQL记载
4. connection-properties: druid.stat.mergeSql=true;druid.stat.SlowSqlMills=5000
5. # 监控后台的设置，如登录账号和暗码等
6. monitor:
7. allow: 127.0.0.1
8. loginUsername: admin
9. loginPassword: admin</code>

复制代码

b)单独编写DruidMonitorConfiguration类。

1. <code>public class DruidMonitorConfiguration {
3. @Value("${spring.datasource.druid.monitor.allow}")
4. private String allow;
5. // @Value("${spring.datasource.druid.monitor.deny}")
6. // private String deny;
7. @Value("${spring.datasource.druid.monitor.loginUsername}")
8. private String loginUsername;
9. @Value("${spring.datasource.druid.monitor.loginPassword}")
10. private String loginPassword;
11. @Value("${spring.datasource.druid.monitor.resetEnable")
12. private String resetEnable;
13. @Bean
14. public ServletRegistrationBean druidStatViewServlet() {
15. ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
16. servletRegistrationBean.addInitParameter("allow", this.allow);
17. // servletRegistrationBean.addInitParameter("deny", this.deny);
18. servletRegistrationBean.addInitParameter("loginUsername", this.loginUsername);
19. servletRegistrationBean.addInitParameter("loginPassword", this.loginPassword);
20. servletRegistrationBean.addInitParameter("resetEnable", this.resetEnable);
21. return servletRegistrationBean;
22. }
24. @Bean
25. public FilterRegistrationBean druidStatFilter() {
26. FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
27. filterRegistrationBean.addUrlPatterns("/*");
28. filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
29. return filterRegistrationBean;
30. }
32. }
33. </code>

复制代码

访问方法就是:http://project-name.com/druid/login.html

验证登录即可。整个监控功能非常强大，有sql监控、URI监控、Session监控，Web应用等等。

来源：https://www.cnblogs.com/freephp/p/11688387.html