springboot配置druid資料來源和監控

阿新 • • 發佈：2019-01-19

資料來源使用的是阿里的Driud。

1.配置之前先看一下xml的配置。

-------------------spring-mybatis.xml檔案--------------------------
<!-- 引入屬性檔案 -->
<context:property-placeholder location="classpath:config.properties" />
<!-- 配置資料來源 -->
<bean name="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
    init-method="init" destroy-method="close">
    <property name="url" value="${jdbc_url}" />
    <property name="username" value="${jdbc_username}" />
    <property name="password" value="${jdbc_password}" />
    <!-- 初始化連線大小 -->
    <property name="initialSize" value="0" />
    <!-- 連線池最大使用連線數量 -->
    <property name="maxActive" value="20" />
    <!-- 連線池最大空閒 -->
    <property name="maxIdle" value="20" />
    <!-- 連線池最小空閒 -->
    <property name="minIdle" value="0" />
    <!-- 獲取連線最大等待時間 -->
    <property name="maxWait" value="60000" />
    <!-- <property name="poolPreparedStatements" value="true" /> <property 
        name="maxPoolPreparedStatementPerConnectionSize" value="33" /> -->
    <property name="validationQuery" value="${validationQuery}" />
    <property name="testOnBorrow" value="false" />
    <property name="testOnReturn" value="false" />
    <property name="testWhileIdle" value="true" />
    <!-- 配置間隔多久才進行一次檢測，檢測需要關閉的空閒連線，單位是毫秒 -->
    <property name="timeBetweenEvictionRunsMillis" value="60000" />
    <!-- 配置一個連線在池中最小生存的時間，單位是毫秒 -->
    <property name="minEvictableIdleTimeMillis" value="25200000" />
    <!-- 開啟removeAbandoned功能 -->
    <property name="removeAbandoned" value="true" />
    <!-- 1800秒，也就是30分鐘 -->
    <property name="removeAbandonedTimeout" value="1800" />
    <!-- 關閉abanded連線時輸出錯誤日誌 -->
    <property name="logAbandoned" value="true" />
    <!-- 監控資料庫 -->
    <!-- <property name="filters" value="stat" /> -->
    <!-- <property name="filters" value="mergeStat" />-->
</bean>
<!-- myBatis檔案 -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <!-- 自動掃描entity目錄, 省掉Configuration.xml裡的手工配置 -->
    <property name="mapperLocations" value="classpath:/mybatis/*Mapper.xml" />
    <property name="configLocation" value="classpath:mybatis-interceptor.xml" /> 
</bean>
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.lcl.springBoot.dao" />
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
</bean>
-------------------mybatis-interceptor.xml檔案------------------------------
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"  
"http://mybatis.org/dtd/mybatis-3-config.dtd">  
<!-- 配置管理器 -->  
<configuration>  
<plugins>  
    <!-- com.github.pagehelper為PageHelper類所在包名 -->  
    <plugin interceptor="com.github.pagehelper.PageHelper">  
        <!-- 4.0.0以後版本可以不設定該引數 -->  
        <property name="dialect" value="mysql"/>  
        <!-- 該引數預設為false -->  
        <!-- 設定為true時，會將RowBounds第一個引數offset當成pageNum頁碼使用 -->  
        <!-- 和startPage中的pageNum效果一樣-->  
        <property name="offsetAsPageNum" value="true"/>  
        <!-- 該引數預設為false -->  
        <!-- 設定為true時，使用RowBounds分頁會進行count查詢 -->  
        <property name="rowBoundsWithCount" value="true"/>  
        <!-- 設定為true時，如果pageSize=0或者RowBounds.limit = 0就會查詢出全部的結果 -->  
        <!-- （相當於沒有執行分頁查詢，但是返回結果仍然是Page型別）-->  
        <property name="pageSizeZero" value="true"/>  
        <!-- 3.3.0版本可用 - 分頁引數合理化，預設false禁用 -->  
        <!-- 啟用合理化時，如果pageNum<1會查詢第一頁，如果pageNum>pages會查詢最後一頁 -->  
        <!-- 禁用合理化時，如果pageNum<1或pageNum>pages會返回空資料 -->  
        <property name="reasonable" value="true"/>  
        <!-- 3.5.0版本可用 - 為了支援startPage(Object params)方法 -->  
        <!-- 增加了一個`params`引數來配置引數對映，用於從Map或ServletRequest中取值 -->  
        <!-- 可以配置pageNum,pageSize,count,pageSizeZero,reasonable,orderBy,不配置對映的用預設值 -->  
        <!-- 不理解該含義的前提下，不要隨便複製該配置 -->  
        <property name="params" value="pageNum=start;pageSize=limit;"/>  
        <!-- 支援通過Mapper介面引數來傳遞分頁引數 -->  
        <property name="supportMethodsArguments" value="true"/>  
        <!-- always總是返回PageInfo型別,check檢查返回型別是否為PageInfo,none返回Page -->  
        <property name="returnPageInfo" value="check"/>  
    </plugin>  
</plugins>  
</configuration>

這裡面可以看到配置了DruidDataSource、SqlSessionFactoryBean、MapperScannerConfigurer三個bean，其中DruidDataSource配置了最基本的連結屬性；SqlSessionFactoryBean配置資料來源、mapper.xml路徑和PageHelper外掛填充；MapperScannerConfigurer設定的自動掃描的基本包basePackage跟sqlSessionFactory。
對應的在springBoot中，我們如果不用xml配置，則可以用@Configuration、@bean來進行註解配置。
@Configuration註解，等價與XML中配置beans；用@Bean標註方法等價於XML中配置bean。

2.看springBoot配置，首先配置DruidDataSource，建立一個DruidDBConfig類，表注@Configuration。程式碼如下：

@Configuration  
public class DruidDBConfig {  
    private Logger logger = LoggerFactory.getLogger(DruidDBConfig.class);   
    @Value("${spring.datasource.url}")  
    private String dbUrl;   
    @Value("${spring.datasource.username}")  
    private String username;  
    @Value("${spring.datasource.password}")  
    private String password;  
    @Value("${spring.datasource.driverClassName}")  
    private String driverClassName;  
    @Value("${spring.datasource.initialSize}")  
    private int initialSize;   
    @Value("${spring.datasource.minIdle}")  
    private int minIdle;  
    @Value("${spring.datasource.maxActive}")  
    private int maxActive;  
    @Value("${spring.datasource.maxWait}")  
    private int maxWait;  
    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")  
    private int timeBetweenEvictionRunsMillis;  
    @Value("${spring.datasource.minEvictableIdleTimeMillis}")  
    private int minEvictableIdleTimeMillis;  
    @Value("${spring.datasource.validationQuery}")  
    private String validationQuery;   
    @Value("${spring.datasource.testWhileIdle}")  
    private boolean testWhileIdle;  
    @Value("${spring.datasource.testOnBorrow}")  
    private boolean testOnBorrow;  
    @Value("${spring.datasource.testOnReturn}")  
    private boolean testOnReturn;  
    @Value("${spring.datasource.poolPreparedStatements}")  
    private boolean poolPreparedStatements;   
    @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")  
    private int maxPoolPreparedStatementPerConnectionSize;  
    @Value("${spring.datasource.filters}")  
    private String filters;    
    @Value("{spring.datasource.connectionProperties}")  
    private String connectionProperties;   
    @Bean(value="dataSource")     //宣告其為Bean例項  
    @Primary  //在同樣的DataSource中，首先使用被標註的DataSource  
    public DataSource dataSource(){  
        DruidDataSource datasource = new DruidDataSource();  
        datasource.setUrl(this.dbUrl);  
        datasource.setUsername(username);  
        datasource.setPassword(password);  
        datasource.setDriverClassName(driverClassName);  
        //configuration  
        datasource.setInitialSize(initialSize);  
        datasource.setMinIdle(minIdle);  
        datasource.setMaxActive(maxActive);  
        datasource.setMaxWait(maxWait);  
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);  
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);  
        datasource.setValidationQuery(validationQuery);  
        datasource.setTestWhileIdle(testWhileIdle);  
        datasource.setTestOnBorrow(testOnBorrow);  
        datasource.setTestOnReturn(testOnReturn);  
        datasource.setPoolPreparedStatements(poolPreparedStatements);  
        datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);  
        try {  
            datasource.setFilters(filters);  
        } catch (SQLException e) {  
            logger.error("druid configuration initialization filter", e);  
        }  
        datasource.setConnectionProperties(connectionProperties);  
        return datasource;  
    }  
}

至此，DruidDataSource資料來源在系統執行的時候，會自動建立一個bean。

3.若想使用Druid的監控，則需要額外配置StatViewServlet 和 filterRegistrationBean，這裡單獨拎出來便於理解，此處配置也可以放置在DruidDBConfig類中。

@Configuration
public class DruidConfiguration { 
   /**
    * 註冊一個StatViewServlet
    * @return
    */
   @Bean
   public ServletRegistrationBean DruidStatViewServle2(){
          //org.springframework.boot.context.embedded.ServletRegistrationBean提供類的進行註冊.
          ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(),"/druid/*");
          //新增初始化引數：initParams
          //白名單：
          servletRegistrationBean.addInitParameter("allow","127.0.0.1");
          //IP黑名單 (存在共同時，deny優先於allow) : 如果滿足deny的話提示:Sorry, you are not permitted to view this page.
          servletRegistrationBean.addInitParameter("deny","192.168.1.73");
          //登入檢視資訊的賬號密碼.
          servletRegistrationBean.addInitParameter("loginUsername","admin2");
          servletRegistrationBean.addInitParameter("loginPassword","123456");
          //是否能夠重置資料.
          servletRegistrationBean.addInitParameter("resetEnable","false");
          return servletRegistrationBean;
   }   
   /**
    * 註冊一個：filterRegistrationBean
    * @return
    */
   @Bean
   public FilterRegistrationBean druidStatFilter2(){       
          FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
          //新增過濾規則.
          filterRegistrationBean.addUrlPatterns("/*");
          //新增不需要忽略的格式資訊.
          filterRegistrationBean.addInitParameter("exclusions","*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid2/*");
          return filterRegistrationBean;
   } 
 }

這裡的配置類同等於xml配置檔案：

<filter>
<filter-name>DruidWebStatFilter</filter-name>
<filter-class>com.alibaba.druid.support.http.WebStatFilter</filter-class>
<init-param>
    <param-name>exclusions</param-name>
    <param-value>*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*</param-value>
</init-param>
</filter>
<filter-mapping>
    <filter-name>DruidWebStatFilter</filter-name>
    <url-pattern>/*</url-pattern>
</filter-mapping>
<servlet>
    <servlet-name>DruidStatView</servlet-name>
    <servlet-class>com.alibaba.druid.support.http.StatViewServlet</servlet-class>
</servlet>
<servlet-mapping>
    <servlet-name>DruidStatView</servlet-name>
    <url-pattern>/druid/*</url-pattern>
</servlet-mapping>

同樣的還有另外一種方式：

1)建立DruidStatFilter。

@WebFilter(filterName="druidWebStatFilter",urlPatterns="/*",  
initParams={  
    @WebInitParam(name="exclusions",value="*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*")//忽略資源  
}  
)  
public class DruidStatFilter extends WebStatFilter {
}

2)建立DruidStatViewServlet。

@WebServlet(urlPatterns="/druid/*",  
initParams={  
     @WebInitParam(name="allow",value="127.0.0.1,192.168.163.1"),// IP白名單(沒有配置或者為空，則允許所有訪問)  
     @WebInitParam(name="deny",value="192.168.1.73"),// IP黑名單 (存在共同時，deny優先於allow)  
     @WebInitParam(name="loginUsername",value="admin"),// 使用者名稱  
     @WebInitParam(name="loginPassword",value="123456"),// 密碼  
     @WebInitParam(name="resetEnable",value="false")// 禁用HTML頁面上的“Reset All”功能  
})  
public class DruidStatViewServlet extends StatViewServlet {  
    private static final long serialVersionUID = -2688872071445249539L; 
}

4.配置sqlSessionFactory，此bean是SqlSessionFactoryBean型別。

@Configuration
public class MyBatisConfig implements TransactionManagementConfigurer{
    private Logger logger = LoggerFactory.getLogger(MyBatisConfig.class);
    //@Autowired 
    //private DruidDataSource dataSource;
    @Value("${spring.datasource.type}")  
    private Class<? extends DataSource> dataSourceType;  
    @Bean(name="dataSource", destroyMethod = "close", initMethod="init")  
    @ConfigurationProperties(prefix = "spring.datasource")  
    public DataSource dataSource() {
        return DataSourceBuilder.create().type(dataSourceType).build();  
    }  
    @Bean(name = "sqlSessionFactory")//3
    public SqlSessionFactory sqlSessionFactoryBean() {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource());
        //bean.setTypeAliasesPackage("com.hjf.boot.demo.boot_mybatis.domain");
        //分頁外掛 //4
        PageHelper pageHelper = new PageHelper();
        Properties properties = new Properties();
        properties.setProperty("reasonable", "true");
        properties.setProperty("supportMethodsArguments", "true");
        properties.setProperty("returnPageInfo", "check");
        properties.setProperty("params", "count=countSql");
        pageHelper.setProperties(properties);
        //新增外掛
        bean.setPlugins(new Interceptor[]{pageHelper});
        //新增XML目錄
        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            bean.setMapperLocations(resolver.getResources("classpath:/mybatis/*Mapper.xml"));
            return bean.getObject();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    @Bean
    public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
    @Bean
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return new DataSourceTransactionManager(dataSource());
    }
}

5.配置MapperScannerConfigurer，設定自動掃描。

@Configuration
@AutoConfigureAfter(MyBatisConfig.class)//見文思意，在MyBatisConfig配置之後載入
public class MyBatisMapperScannerConfig {
    @Bean
    public MapperScannerConfigurer mapperScannerConfigurer() {
        MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer();
        //對應<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
        mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");
        //對應<property name="basePackage" value="com.lcl.springBoot.dao" />
        mapperScannerConfigurer.setBasePackage("com.lcl.springBoot.dao");
        return mapperScannerConfigurer;
    }
}

至此配置完畢，對於資原始檔在resources目錄下：

 resources
   --application.properties//存放資原始檔
   --mybatis//資料夾存放mapper檔案
       --DemoMapper.xml //本人用的測試mapper

application.properties檔案內容(千篇一律，滿大街都是= =！)：

##DATASOURCE（DataSourceAutoConfiguration＆DataSourceProperties）
# 驅動配置資訊   
spring.datasource.url = jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
spring.datasource.username= root
spring.datasource.password=
spring.datasource.driverClassName=com.mysql.jdbc.Driver 
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource 
##連線池屬性配置
spring.datasource.initialSize=5  
spring.datasource.minIdle=5  
spring.datasource.maxActive=20  
spring.datasource.maxWait=60000  
spring.datasource.timeBetweenEvictionRunsMillis=60000  
spring.datasource.minEvictableIdleTimeMillis=300000  
spring.datasource.validationQuery=SELECT 1 FROM DUAL  
spring.datasource.testWhileIdle=true  
spring.datasource.testOnBorrow=false  
spring.datasource.testOnReturn=false  
spring.datasource.poolPreparedStatements=true  
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20  
spring.datasource.filters=stat,wall,log4j  
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

結尾：在MyBatisConfig中關於DruidDataSource，一開始使用的形式是：

    @Autowired 
    private DruidDataSource dataSource;

此時發現不能自動例項化bean，而後改為一下形式解決，沒有看原始碼不知何故，以後有時間在看原始碼進行分析：

    @Value("${spring.datasource.type}")  
    private Class<? extends DataSource> dataSourceType;  
    @Bean(name="dataSource", destroyMethod = "close", initMethod="init")  
    @ConfigurationProperties(prefix = "spring.datasource")  
    public DataSource dataSource() {
        return DataSourceBuilder.create().type(dataSourceType).build();  
    }

springboot配置druid資料來源和監控

springboot配置druid資料來源和監控

spring boot配置druid資料來源和監控配置

搭建微服務歷程-3 修改服務提供者Provider 使用jpa配置druid資料來源和監控

從零學springboot—— 配置druid資料來源，並開啟監控

springboot配置Druid資料來源

SpringBoot配置Druid資料來源，持久層分別 mybatis，jdbc

springboot配置druid監控

SpringBoot配置多資料來源(druid)

springboot配置雙資料來源 MySQL和SqlServer

springboot配置多資料來源並整合Druid

SpringBoot整合druid資料來源及新增Druid監控頁面

SpringBoot配置多資料來源（結合Druid）

springboot 引入 druid 資料來源監控

SpringBoot配置Druid

SpringBoot配置Druid數據源

springboot配置多資料來源之Spring Date JPA

springboot配置多資料來源(MongoDB主從)

springboot配置多資料來源(不同DB)

SpringBoot使用Druid資料來源

spring boot整合mybatis -配置 druid 資料來源

springboot配置druid資料來源和監控

相關推薦