SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客

沙海
沙海
沙海
1017
文章
2
评论
2021年4月27日11:57:50
评论
3 6321字阅读21分4秒
摘要

SpringBoot项目开发(五):HikariCP数据库连接池

SpringBoot项目开发(五):HikariCP数据库连接池

SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客

闪耀的瞬间
2018-07-22 20:41:37
SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客
10264

SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客

收藏

6

分类专栏:
spring boot
java
SpringBoot 项目开发

版权

SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客
1.前两篇是介绍控制器与页面的,本篇将介绍 数据库连接池 ,它很重要,SpringBoot 2.0 默认连接池就是Hikari
2.可以看一下这位朋友对几大主流数据库连接池的测试报告,结论是:hikariCP在并发较高的情况下,性能基本上没有下降。我自己也测试过,循环查询500次,13秒多

SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客

3.在项目中集成 Hikari 与Spring Data JPA,做个数据展示demo,实际项目中使用的 mybatis,后面会专文介绍

  • 请在pom.xml中添加Maven依赖:HikariCP 、mysql-connector-java 、spring-boot-starter-data-jpa
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <scope>runtime</scope>
</dependency>
<dependency>
   <groupId>com.zaxxer</groupId>
   <artifactId>HikariCP</artifactId>
<version>3.1.0</version>
</dependency>
<!-- 序列化与反序列化 -->
<dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>fastjson</artifactId>
<version>1.2.47</version>
</dependency>
1234567891011121314151617181920

在application.properties中添加数据库配置,可在正式环境中加大maximum-pool-size值

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/bigdata?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&maxReconnects=15000&allowMultiQueries=true&useSSL=false
spring.datasource.username=root
spring.datasource.password=root
# Hikari will use the above plus the following to setup connection pooling
# type就是指定使用什么数据源,可以是Hikari、Druid等
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.maximum-pool-size=25
spring.datasource.hikari.auto-commit=true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=ExpendHikariCP
spring.datasource.hikari.max-lifetime=1800000
spring.datasource.hikari.connection-timeout=30000
spring.datasource.hikari.connection-test-query=SELECT 1
123456789101112131415

接下来需要在项目中添加entity、repository 架包 在entity架包下,添加 User.java文件,与数据库表字段对应,本文使用spring-data-jpa,后面会分享mybatis

@Entity
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY) //id自动增长
    private int id;
    @Column(nullable = false)
    private String name;
    @Column(nullable = false)
    private int age;

    getter and setter ...
}
123456789101112

在repository架包下,新建UserRepository.java文件,继承 CrudRepository<User , Integer>


@Repository
@Transactional
public interface UserRepository extends CrudRepository<User , Integer> {

    /**
     * 由JPA自动根据方法名生成查询sql
     * @param id
     * @return
     */
    User findById(int id);

    User findByName(String name);

    void deleteById(int id);

    //自定义sql
    @Modifying
    @Query(value = "select * from user",nativeQuery = true)
    List<User> findAll();
}
123456789101112131415161718192021

再创建service架包,在其下添加inf、impl架包,分别在其下添加接口与实现

public interface IUserService {

    void add(User user);

    void edit(User user);

    void delete(int id);

    User findById(int id);

    User findByName(String name);

    List<User> findAll();
}
1234567891011121314
@Service
public class UserServiceImpl implements IUserService{

    @Autowired private UserRepository userRepository;

    @Override
    public void add(User user) {
        userRepository.save(user);
    }

    @Override
    public void edit(User user) {
        userRepository.save(user);
    }

    @Override
    public void delete(int id) {
        userRepository.deleteById(id);
    }

    @Override
    public User findById(int id) {
        return userRepository.findById(id);
    }

    @Override
    public User findByName(String name) {
        return userRepository.findByName(name);
    }

    @Override
    public List<User> findAll() {
        return userRepository.findAll();
    }
}
1234567891011121314151617181920212223242526272829303132333435

最后,对写的代码进行测试,新建一个测试类,内容如下,右键测试方法点击运行一一测试,下面有测试图片,其中项目结构也在图片中,把user对象打印成字符串,就需要用到fastjson进行序列化

@RunWith(SpringRunner.class)
@SpringBootTest
public class UserTest {

    @Autowired private IUserService userService;

    @Test
    public void add(){
        User user = new User();
        user.setName("zy");
        user.setAge(26);
        userService.add(user);
    }

    @Test
    public void edit(){
        User user = new User();
        user.setId(1);
        user.setName("zy1");
        user.setAge(22);
        userService.edit(user);
    }

    @Test
    public void delete(){
        userService.delete(1);
    }

    @Test
    public void findById(){
        User user = userService.findById(1);
        System.out.println("user content :" + JSON.toJSONString(user));
    }

    @Test
    public void findByName(){
        User user = userService.findByName("zy1");
        System.out.println("user content :" + JSON.toJSONString(user));
    }

    @Test
    public void findAll(){
        List<User> list = userService.findAll();
        System.out.println("user content :" + JSON.toJSONString(list));
    }
}
12345678910111213141516171819202122232425262728293031323334353637383940414243444546

SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客 执行add方法后 SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客 再来一个findById方法,其他的大家自行测试 SpringBoot项目开发(五):HikariCP数据库连接池_zhuyu19911016520-CSDN博客

下一篇集成:Mybatis框架

如果想使用阿里的Druid,可以添加依赖,在配置文件中加入自定义配置(线程池大小等)

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.1.20</version>
</dependency>
12345
spring:
  datasource:
#   数据源基本配置
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/duid
    type: com.alibaba.druid.pool.DruidDataSource
#   数据源其他配置
    initialSize: 5
    minIdle: 5
    maxActive: 20
    maxWait: 60000
    timeBetweenEvictionRunsMillis: 60000
    minEvictableIdleTimeMillis: 300000
    validationQuery: SELECT 1 FROM DUAL
    testWhileIdle: true
    testOnBorrow: false
    testOnReturn: false
    poolPreparedStatements: true
#   配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙  
    filters: stat,wall
    maxPoolPreparedStatementPerConnectionSize: 20
    useGlobalDataSourceStat: true  
    connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
12345678910111213141516171819202122232425

然后添加一个配置类,使用这些自定义配置,配置监控后台Servlet,配置filter

@Configuration
public class DruidConfig{
   
   @ConfigurationProperties(prefix = "spring.datasource")
   @Bean
   public DruidDataSource druidDataSource(){
      return new DruidDataSource();
   }
   
   //配置监控servlet
   @Bean
   public ServletRegistrationBean statViewServlet(){
      ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet() , "/druid/*");
      Map<String,String> initParameter= new HashMap<>();
      initParameter.put("loginUsername" ,"admin");
      initParameter.put("loginPassword" ,"123456");
      initParameter.put("allow" ,"");//默认允许所有访问
      // 添加IP白名单
      //servletRegistrationBean.addInitParameter("allow", "127.0.0.1");
      // 添加IP黑名单,当白名单和黑名单重复时,黑名单优先级更高
      //servletRegistrationBean.addInitParameter("deny", "127.0.0.1");
      // 是否能够重置数据
      servletRegistrationBean.addInitParameter("resetEnable", "false");
      bean.setInitParameters(initParameter);
      return bean;
   }

   //配置监控filter
   @Bean
   public FilterRegistrationBean webStatFilter(){
     FilterRegistrationBean bean = new FilterRegistrationBean(new WebStatFilter());
     // 添加过滤规则
     bean .addUrlPatterns("/*");
     // 忽略过滤格式
     bean .addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*,");
     return bean;
   }
}
1234567891011121314151617181920212223242526272829303132333435363738

配置完后我们启动SpringBoot程序访问:

http://localhost:8080/druid/ 就可以来到我们的登录页面面就是我们上面添加的控制台管理用户,我们可以在上面很好的看到运行状况和Sql执行情况

继续阅读
weinxin
资源分享QQ群
本站是一个IT技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默!
沙海
匿名

发表评论

匿名网友 填写信息

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: