spring boot2 整合（一續）Druid資料庫連接配接池和FastJson

本項目教程環境建立在 spring boot2 整合（一）Mybatis （特别完整！） 的基礎上。

1. Druid配置

1.1 修改pom.xml

<!-- alibaba的druid資料庫連接配接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.0.11</version>
        </dependency>
           

1.2. 添加yml配置屬性

# 使用druid資料源
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    platform: mysql
    # 下面為連接配接池的補充設定，應用到上面所有資料源中
    # 初始化大小，最小，最大
    initialSize: 1
    minIdle: 3
    maxActive: 20
    # 配置擷取連接配接等待逾時的時間
    maxWait: 60000
    # 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接配接，機關是毫秒
    timeBetweenEvictionRunsMillis: 60000
    # 配置一個連接配接在池中最小生存的時間，機關是毫秒
    minEvictableIdleTimeMillis: 30000
    validationQuery: select 'x'
    testWhileIdle: true
    testOnBorrow: false
    testOnReturn: false
    # 打開PSCache，并且指定每個連接配接上PSCache的大小
    poolPreparedStatements: true
    maxPoolPreparedStatementPerConnectionSize: 20
    # 配置監控統計攔截的filters，去掉後監控界面sql無法統計，'wall'用于防火牆
    filters: stat,wall,slf4j
    # 通過connectProperties屬性來打開mergeSql功能；慢SQL記錄
    connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
    # 合并多個DruidDataSource的監控資料
    #useGlobalDataSourceStat: true
           

注意這些屬性都是spring.datasource下的子屬性。

1.3. 添加druid的配置類檔案

DruidConfiguration .java

package com.fantj.config;

/**
 * druid 連接配接池配置類
 * Created by Fant.J.
 */
@Configuration
public class DruidConfiguration {
    @Value("${spring.datasource.url}")
    private String dbUrl;
    @Value("${spring.datasource.username}")
    private String username;
    @Value("${spring.datasource.password}")
    private String password;
    @Value("${spring.datasource.driver-class-name}")
    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   //聲明其為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) {
            System.err.println("druid configuration initialization filter: "+ e);
        }
        datasource.setConnectionProperties(connectionProperties);
        return datasource;
    }
    @Bean
    public ServletRegistrationBean statViewServlet(){
        //建立servlet注冊實體
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(),"/druid/*");
        //設定ip白名單
        servletRegistrationBean.addInitParameter("allow","127.0.0.1");
        //設定ip黑名單
        servletRegistrationBean.addInitParameter("deny","192.168.0.2");
        //設定控制台管理使用者
        servletRegistrationBean.addInitParameter("loginUsername","druid");
        servletRegistrationBean.addInitParameter("loginPassword","123456");
        //是否可以重置資料
        servletRegistrationBean.addInitParameter("resetEnable","false");
        return servletRegistrationBean;
    }
    @Bean
    public FilterRegistrationBean statFilter(){
        //建立過濾器
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
        //設定過濾器過濾路徑
        filterRegistrationBean.addUrlPatterns("/*");
        //忽略過濾的形式
        filterRegistrationBean.addInitParameter("exclusions","*.js,*.gif,*.png,*.css,*.ico,/druid/*");
        return filterRegistrationBean;
    }
}

           

注意該代碼段中有

//設定控制台管理使用者
        servletRegistrationBean.addInitParameter("loginUsername","druid");
        servletRegistrationBean.addInitParameter("loginPassword","123456");
           

這是druid監控端的賬号和密碼，其登入入口的官方url為：

127.0.0.1:8080/druid/login.html

2. FastJson配置

2.1 添加pom依賴

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.39</version>
        </dependency>
           

2.2 增加fastJson配置檔案

方法一：繼承extends WebMvcConfigurerAdapter

FastJsonConfiguration .java

package com.fantj.config;
/**
 * fastJson 配置類
 * Created by Fant.J.
 */
@Configuration
public class FastJsonConfiguration extends WebMvcConfigurerAdapter{
    /**
     * 修改自定義消息轉換器
     */
    @Override
    public void configureMessageConverters(List<HttpMessageConverter<?>> converters){
        super.configureMessageConverters(converters);
        //1.建立一個convert消息轉換對象
        FastJsonHttpMessageConverter fastConvert = new FastJsonHttpMessageConverter();
        //2.建立一個fastJson的配置對象,然後配置格式化資訊
        FastJsonConfig config = new FastJsonConfig();
        config.setSerializerFeatures(SerializerFeature.PrettyFormat);
        //3.在convert中添加配置資訊
        fastConvert.setFastJsonConfig(config);
        //4.将convert添加到converts裡面
        converters.add(fastConvert);
    }
}

           

方法二：覆寫方法configureMessageConverters

public HttpMessageConverters fastJsonHttpMessageConverters(){
//1.建立一個convert消息轉換對象
FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
//2.建立一個fastJson的配置對象,然後配置格式化資訊
FastJsonConfig fastJsonConfig = new FastJsonConfig();
fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);
//3.在convert中添加配置資訊
fastConverter.setFastJsonConfig(fastJsonConfig);
HttpMessageConverter<?> converters = fastConverter;
return new HttpMessageConverters(converters);
}
           

2.3 修改pojo

@Data
public class User {
    private Integer id;

    private String username;

    @JSONField(format="yyyy-MM-dd HH:mm:ss")
    private Date birthday;

    private String sex;

    private String address;
}
           

注意

@JSONField(format="yyyy-MM-dd HH:mm:ss")

，如果它能顯示出效果，證明druid配置成功。