spring cloud使用spring data jpa配置druid做数据源和监控

淩亂°似流年 2022-06-02 06:35 271阅读 0赞

druid数据源是非常好用的一款产品，有强大的监控和扩展功能，接下来就做一个在spring cloud中应用spring data jpa使用druid作为数据源和监控的服务提供者[demo][]。

*  spring cloud版本为Brixton.SR5，spring boot版本为1.4.0.RELEASE
 *  pom.xml
    
        <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.mysoft</groupId>
        <artifactId>cloud-provide-user-druid</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        
        
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.4.0.RELEASE</version>
        </parent>
        
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <java.version>1.8</java.version>
        </properties>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Brixton.SR5</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
        
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-jpa</artifactId>
            </dependency>
        
            <dependency>
                <groupId>com.h2database</groupId>
                <artifactId>h2</artifactId>
            </dependency>
        
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.0.11</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
        </dependencies>
        
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
 *  cloud-provide-user-druid/src/main/resources/application.yml
    
        server:
          port: 8000
        spring:
          application:
            name: cloud-provider-user-druid    # 项目名称尽量用小写
          jpa:
            generate-ddl: false
            show-sql: true
            hibernate:
              ddl-auto: none
          datasource:                           # 指定数据源
            driver-class-name: com.mysql.jdbc.Driver
            url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=true
            username: root
            password: root
            initialSize: 5
            minIdle: 5
            maxActive: 20   
            maxWait: 60000  
            filters: stat
            minEvictableIdleTimeMillis: 300000      # 配置一个连接在池中最小生存的时间，单位是毫秒
            poolPreparedStatements: true
        
        logging:
          level:
            root: INFO
            org.hibernate: INFO
            org.hibernate.type.descriptor.sql.BasicBinder: TRACE
            org.hibernate.type.descriptor.sql.BasicExtractor: TRACE
            com.itmuch.youran.persistence: ERROR
        eureka:
          client:
            serviceUrl:
              defaultZone: http://discovery:8761/eureka/    # 指定注册中心的地址
          instance:
            preferIpAddress: true
    
    注意：项目中没有给出服务发现者，启动时会报一些错，但不影响测试。而且在连接高版本的MySQL时需要声明useSSL=true，否则会出错。
 *  添加Druid配置，在spring boot 1.4版本中，datasource的配置不支持type，所以需要手动添加DataSource配置。使用type配置不详细记录。
    
    cloud-provide-user-druid/src/main/java/com/mysoft/druid/datasource/DruidConfiguration.java：
    
        package com.mysoft.druid.datasource;
        
        import java.sql.SQLException;
        
        import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
        import org.springframework.boot.context.properties.ConfigurationProperties;
        import org.springframework.boot.context.properties.EnableConfigurationProperties;
        import org.springframework.boot.jdbc.DatabaseDriver;
        import org.springframework.context.annotation.Bean;
        import org.springframework.context.annotation.Configuration;
        
        import com.alibaba.druid.pool.DruidDataSource;
        
        @Configuration
        @EnableConfigurationProperties(DataSourceProperties.class)
        public class DruidConfiguration{
        
            @Bean(destroyMethod = "close", initMethod = "init") 
            @ConfigurationProperties("spring.datasource.*")
            public DruidDataSource dataSource(DataSourceProperties properties) {
                DruidDataSource dataSource = new DruidDataSource();
                dataSource.setDriverClassName(properties.determineDriverClassName());
                dataSource.setUrl(properties.determineUrl());
                dataSource.setUsername(properties.determineUsername());
                dataSource.setPassword(properties.determinePassword());
                DatabaseDriver databaseDriver = DatabaseDriver
                        .fromJdbcUrl(properties.determineUrl());
                String validationQuery = databaseDriver.getValidationQuery();
                if (validationQuery != null) {
                    dataSource.setTestOnBorrow(true);
                    dataSource.setValidationQuery(validationQuery);
                }
                try {
                    //开启Druid的监控统计功能，mergeStat代替stat表示sql合并,wall表示防御SQL注入攻击
                    dataSource.setFilters("mergeStat,wall,log4j");
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return dataSource;
            }
        }
 *  添加数据源监控
    
    cloud-provide-user-druid/src/main/java/com/mysoft/druid/datasource/DruidStatViewServlet.java：
    
        package com.mysoft.druid.datasource;
        
        import javax.servlet.annotation.WebInitParam;
        import javax.servlet.annotation.WebServlet;
        
        import com.alibaba.druid.support.http.StatViewServlet;
        
        /**
         * druid数据源状态监控.
         * @author Administrator
         *
         */
        
        @WebServlet(urlPatterns="/druid/*",
                   initParams={
                           @WebInitParam(name="allow",value="172.20.13.133,127.0.0.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{
        
        }
 *  此时程序已经具备druid数据源和监控功能，创建启动类,注意添加注解@ServletComponentScan扫描druid的监控配置：
    
    cloud-provide-user-druid/src/main/java/com/mysoft/druid/UserApplication.java：
    
        package com.mysoft.druid;
        import org.springframework.boot.SpringApplication;
        import org.springframework.boot.autoconfigure.SpringBootApplication;
        import org.springframework.boot.web.servlet.ServletComponentScan;
        import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
        
        @SpringBootApplication
        @EnableDiscoveryClient
        @ServletComponentScan
        public class UserApplication {
          public static void main(String[] args) {
            SpringApplication.run(UserApplication.class, args);
          }
        }
 *  主要配置基本OK了，使用spring data jpa测试详细点击[github][demo]

[demo]: https://github.com/Xchunguang/cloud-provide-user-druid