当前位置： 首页 > article >正文

数据库之连接池Druid

article 2025/1/17 7:40:24

Druid是一个由阿里巴巴开源的高性能数据库连接池组件，它在许多项目中都是首选的连接池实现。Druid不仅提供了高效的连接管理，还具备丰富的监控和统计功能，以及强大的安全特性。

一、功能介绍

1、高效连接管理

Druid采用了高效的连接管理机制，可以快速地创建和回收数据库连接，从而减少了连接的创建和销毁带来的性能开销。通过连接复用机制，Druid可以在多个请求之间复用相同的连接，进一步减少了频繁创建和关闭连接的成本。

2、详细的监控信息

Druid提供了详细的监控信息，包括连接池的状态、SQL执行的统计信息等，这有助于性能调优和问题诊断。开发人员可以通过这些监控信息了解应用程序的性能瓶颈，并据此进行优化。

3、丰富的配置选项

Druid提供了大量的配置选项，可以根据项目的实际需求进行细致的调整，以适应不同的运行环境。这些配置选项包括连接池大小、最大活跃连接数、初始化连接数等，通过灵活的配置可以满足各种复杂的应用场景。

4、安全特性

Druid连接池内置了防SQL注入功能，可以有效地防止SQL注入攻击。此外，它还支持自定义过滤器，可以扩展Druid的功能，实现特定的业务逻辑。

5、强大的扩展性

Druid支持动态加载配置文件，可以在不重启应用的情况下更改连接池的配置。它还支持插件化设计，可以根据需要选择安装不同的插件，增强其功能。

6、良好的集成性

Druid可以很方便地与Spring、MyBatis等主流框架集成，降低开发者的使用门槛。此外，它还支持与各种监控工具（如Prometheus、Grafana）集成，实现对数据库操作的实时监控。

7、广泛的社区支持

由于其优秀的特性和广泛的应用，Druid拥有庞大的用户基础和活跃的社区支持。遇到问题时，开发者很容易找到解决方案。

二、使用场景

Druid数据库连接池组件适用于多种场景，以下是一些主要的应用场景：

1. 高并发的互联网应用

  • 电子商务：在电商应用中，需要处理大量的数据库连接和查询，如用户信息、商品信息、订单信息等。Druid通过优化数据库连接的使用方式，可以显著提高应用程序的性能和响应速度。
  • 社交媒体：社交媒体平台需要处理大量的用户交互数据，如帖子、评论、点赞等。Druid的高并发处理能力能够确保这些交互的实时性和流畅性。
  • 金融系统：金融系统对数据的实时性和准确性要求极高，如股票交易、支付系统等。Druid能够提供稳定、高效的数据库连接服务，确保金融系统的稳定运行。

2. 企业级应用

  • 复杂数据库连接环境：在大型企业中，数据库连接环境通常比较复杂，包括多种数据库类型、多种连接方式等。Druid提供了灵活的数据源配置方式，能够支持多种数据库类型和连接方式，方便开发人员进行管理和优化。
  • 数据库监控和管理：Druid提供了丰富的监控功能，如连接池状态监控、SQL执行分析、慢查询记录等。这些功能可以帮助开发人员实时了解数据库连接池的运行状态，及时发现和解决问题。

三、Java代码示例

以下是一个使用Druid连接池连接数据库的Java示例代码，展示了连接池的配置、使用和优化等方面。

1. 添加Druid依赖

首先，需要在Maven项目的pom.xml文件中添加Druid依赖：

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.8</version>
</dependency>

这个依赖包用于引入Druid连接池库。

2. 配置Druid连接池

接下来，在应用程序的配置文件中配置Druid连接池。例如，在application.properties文件中添加以下配置：

# 数据源配置
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
spring.datasource.username=root
spring.datasource.password=password

# 连接池配置
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
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,slf4j

这些配置信息包括数据库连接的基本信息（如URL、用户名和密码）以及连接池的一些常用配置（如初始连接数、最小空闲连接数、最大活跃连接数等）。

3. 编写Druid工具类

为了更方便地使用Druid连接池，可以编写一个Druid工具类，封装获取连接、关闭连接等操作。以下是一个简单的Druid工具类示例：

import com.alibaba.druid.pool.DruidDataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class DruidUtils {
    private static DruidDataSource dataSource;

    static {
        dataSource = new DruidDataSource();
        dataSource.setUrl("jdbc:mysql://localhost:3306/mydatabase");
        dataSource.setUsername("root");
        dataSource.setPassword("password");
        dataSource.setInitialSize(5);
        dataSource.setMinIdle(5);
        dataSource.setMaxActive(20);
        dataSource.setMaxWait(60000);
        dataSource.setTimeBetweenEvictionRunsMillis(60000);
        dataSource.setMinEvictableIdleTimeMillis(300000);
        dataSource.setValidationQuery("SELECT 1");
        dataSource.setTestWhileIdle(true);
        dataSource.setTestOnBorrow(false);
        dataSource.setTestOnReturn(false);
        dataSource.setPoolPreparedStatements(true);
        dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
        dataSource.setFilters("stat,wall,slf4j");
    }

    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }

    public static void close(Connection conn) {
        if (conn != null) {
            try {
                conn.close(); // 归还连接给连接池
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

这个工具类创建了一个DruidDataSource对象，并设置了数据库连接和连接池的属性。通过getConnection方法可以获取数据库连接，close方法用于关闭连接（实际上是将连接归还给连接池）。

4. 使用Druid连接池

现在，可以在应用程序中使用Druid连接池来获取数据库连接并执行SQL语句。以下是一个简单的示例：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DruidDemo {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            conn = DruidUtils.getConnection();
            String sql = "SELECT * FROM mytable";
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();

            while (rs.next()) {
                // 读取数据操作
                System.out.println(rs.getString("column_name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (rs != null) {
                    rs.close();
                }
                if (pstmt != null) {
                    pstmt.close();
                }
                if (conn != null) {
                    DruidUtils.close(conn);
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例中，首先通过DruidUtils.getConnection方法获取数据库连接，然后执行SQL查询语句，并读取查询结果。最后，在finally块中关闭结果集、预处理语句和数据库连接（实际上是将连接归还给连接池）。

5. 监控和统计

Druid提供了丰富的监控和统计功能，可以帮助开发人员更好地了解应用程序的性能。可以通过在Web应用中集成Druid的监控组件来查看连接池的使用情况。

首先，需要在Spring Boot的配置类中配置Druid的监控Servlet：

import com.alibaba.druid.support.http.ResourceFilter;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DruidConfig {
    @Bean
    public ServletRegistrationBean<StatViewServlet> statViewServlet() {
        ServletRegistrationBean<StatViewServlet> srb = new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");
        srb.addInitParameter("allow", "127.0.0.1");
        srb.addInitParameter("deny", "192.168.1.100");
        srb.addInitParameter("loginUsername", "admin");
        srb.addInitParameter("loginPassword", "admin");
        return srb;
    }

    @Bean
    public ServletRegistrationBean<ResourceFilter> resourceFilter() {
        ServletRegistrationBean<ResourceFilter> srb = new ServletRegistrationBean<>(new ResourceFilter());
        srb.addUrlPatterns("/druid/*");
        return srb;
    }
}

四、总结

Druid是阿里巴巴开源的高性能数据库连接池组件，广泛应用于高并发互联网应用和企业级项目中。它提供了高效的连接管理、详细的监控信息、丰富的配置选项和安全特性。Druid支持快速创建和回收数据库连接，减少性能开销，并通过连接复用机制降低频繁连接的成本。其监控功能帮助开发者实时了解数据库状态，优化性能。Druid还内置防SQL注入功能，增强安全性。此外，它易于与Spring等框架集成，支持动态配置和插件扩展。在高并发场景如电商、社交媒体和金融系统中，Druid能显著提升应用性能和响应速度，是企业级应用的首选数据库连接池解决方案。


http://www.kler.cn/a/429408.html

相关文章：

  • MDX语言的数据库交互
  • C++ 并发编程之std::find的并发版本
  • Flink链接Kafka
  • 【Vue】分享一个快速入门的前端框架以及如何搭建
  • api开发及运用小红书笔记详情api如何获取笔记详情信息
  • istio-proxy oom问题排查步骤
  • ZZCMS2023存在跨站脚本漏洞（CNVD-2024-44822、CVE-2024-44818）
  • sock_poll内核函数
  • No module named ‘_ssl‘ No module named ‘_ctypes‘
  • 如何防范顶级应用程序安全威胁
  • 【大语言模型】LangChain ModelsIO与Models I/O Promopts详解
  • 【CKS最新模拟真题】Dockerfile修改
  • CTF-RE/WEB: python-Hook(钩子)
  • 电子信息工程自动化 基于单片机的居室安全报警系统
  • 为什么 JavaScript 中的回调函数未按顺序执行？
  • Pydantic 动态字段：使用和不使用 `@computed_field` 的对比指南
  • 如何使用 JavaScript 获取页面滚动位置？
  • Java项目实战II基于微信小程序的跑腿系统（开发文档+数据库+源码）
  • Hasura 中间件API go操作示例
  • 专为高性能汽车设计的Armv9架构的Neoverse V3AE CPU基础知识与软件编码特性解析
  • 管理系统前端框架开发案例学习
  • redis-stack redisSearch环境安装搭建
  • 记录一下，解决js内存溢出npm ERR! code ELIFECYCLEnpm ERR! errno 134 以及 errno 9009
  • 智创 AI 新视界 -- AI 引领下的未来社会变革预测（16 - 6）
  • DP协议：术语表
  • Vue 3初始化工程