讲享元设计模式,顺便~学会了数据库连接池,

设计模式-详细说明享元模式设计,保准一听就会,不会你来打我

1.前言

今天呢,我们来说下享元模式,享元模式是结构型模式,我的感觉,结构型模式都是相对比较简单的设计模式,这个也是,之前手写Mybatis时有学习了解数据库连接池的设计,非常精彩,其中就运用了咱们这节说的设计模式,享元模式。

2.什么是享元模式

享元模式: 对一些共享对象进行复用的思想,这样减少内存使用提高资源性能,像我们使用redis进行缓存处理的,线程池,数据源连接池都是享元模式,享元模式其实是一个思想,一般会和工厂模式或其他经常使用的设计模式搭配使用。

那根据这种设计理念我们自己实现个数据库连接池,当然是伪代码哈,毕竟数据库连接池的业务比较庞大和复杂,我们这个就是简单实现,但也能够让你理解到数据库连接池的代码设计和思路。

之所以选择数据库连接池的原因是,数据库连接池使用是连接,连接的创建会有很大消耗,所以就出现个池子作共享操作,谁用谁从池子里取连接,不用了就送回池子里,所以这是个典型的享元模式设计思想。

3.代码设计

因为我们知道数据库连接池,最主要有连接,还有数据源,以及数据源工厂,那么用户可以通过数据源工厂连接数据源,根据数据源获取连接。

3.1 Connection

首先我们定义连接接口,Connection,定义连接的提交、回滚、关闭方法。

import java.sql.SQLException;/*** @Author df* @Description:* @Date 2024/3/2 16:05*/
public interface Connection {void commit();void rollback();void close();
}

然后就是连接的实现,DefaultConnection实现Connection接口,回滚和提交就不写代码了,因为说的是数据库连接池,连接池的处理会有创建连接和回收连接,那么什么时候回收连接呢,就是连接关闭的时候,所以在关闭连接的方法里我们调用了回收连接pooledDatasource.pushConnection(this);

由于连接池需要在池数据源里操作,所以我们需要通过构造方法把PooledDatasource传入进来,这样回收连接时可以调用PooledDatasource的回收方法。代码如下

/*** @Author df* @Description:* @Date 2024/3/2 16:31*/
public class DefaultConnection implements Connection {private PooledDatasource pooledDatasource;public DefaultConnection(PooledDatasource pooledDatasource) {this.pooledDatasource = pooledDatasource;}@Overridepublic void commit() {// 模拟提交}@Overridepublic void rollback() {// 模拟回滚}@Overridepublic void close() {pooledDatasource.pushConnection(this);}
}

3.2 DataSource

接着我们在定义数据源接口,DataSource,定义获取连接方法。

/*** @Author df* @Description: 数据源接口* @Date 2024/3/2 16:19*/
public interface DataSource {Connection getConnection();
}

然后重点来了,定义有池化的数据源,然后实现DataSource接口,

1.这里首先我们定义了两个全局变量activeConnectionPool(活跃连接池列表)和idleConnectionPool(空闲连接池列表)字如其意,一个放活跃连接状态的连接,一个放空闲状态的连接,在用户获取连接时就是活跃的,不使用关闭连接就是空闲的。

2.在获取连接时,先获取空闲连接池里有连接没,如果有直接取出来,返回,并删除列表这个连接即可,如果没有空闲连接则创建连接,创建连接以后放入活跃连接池中。

3.pushConnection(回收连接方法),当关闭连接调用到这里时,把当前连接从活跃连接池移除,然后放入空闲连接池里。当然真实的肯定是要更复杂的,如果大家感兴趣呢,可以去我的博客Mybatis专栏或者B站去看啦。

手写Mybatis五-全网最详细的讲解数据源连接池,内容有点长,关注不迷路,不会你打我!_哔哩哔哩_bilibili

/*** @Author df* @Description: 有池化资源* @Date 2024/3/2 16:22*/
public class PooledDatasource implements DataSource {protected final List<Connection> activeConnectionPool = new ArrayList<>();protected final List<Connection> idleConnectionPool = new ArrayList<>();@Overridepublic Connection getConnection() {if (!idleConnectionPool.isEmpty()) {return idleConnectionPool.remove(0);}// 模拟获取连接Connection connection = new DefaultConnection(this);activeConnectionPool.add(connection);return connection;}protected void pushConnection(Connection connection) {// 移除活跃池activeConnectionPool.remove(connection);// 放入空闲池idleConnectionPool.add(connection);}
}

3.3 DatasourceFactory

连接接口有啦,数据源接口有啦,那现在就差个入口啦,我们定义数据源工厂接口DatasourceFactory,定义的获取数据源方法就OK啦。


/*** @Author df* @Description: 数据源工厂接口* @Date 2024/3/2 17:08*/
public interface DatasourceFactory {DataSource getDataSource();
}

 然后池化数据源工厂PooledDatasourceFactory,实现DatasourceFactory接口,再获取数据源的时候实例化有池化数据源。

/*** @Author df* @Description: 池化数据源工厂* @Date 2024/3/2 17:07*/
public class PooledDatasourceFactory implements DatasourceFactory {@Overridepublic DataSource getDataSource() {return new PooledDatasource();}
}

单元测试:

怎么样,其实还是蛮简单的,大家可以打断点调试下就都明白啦。

/*** @Author df* @Description: 测试享元模式* @Date 2024/3/2 17:12*/
public class TestApi {@Testpublic void test_flyweight() {// 实例化数据源工厂DatasourceFactory datasourceFactory = new PooledDatasourceFactory();// 通过工厂获取数据源DataSource datasource = datasourceFactory.getDataSource();// 通过数据源获取连接Connection connection = datasource.getConnection();// 连接关闭connection.close();// 再次获取连接Connection connection1 = datasource.getConnection();//connection.close();}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/725055.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

数据伪列

目录 数据伪列 rownum 查询 emp 表中的记录并且取得第一行数据 取得 emp 表的前 5 行记录 rowid 面试题&#xff1a;表中有许多完全重复的数据&#xff0c;要求将重复的数据删除掉&#xff08;只剩最早的一个&#xff09; Oracle从入门到总裁:https://blog.csdn.net/weixin…

Guava处理异常

guava由Google开发&#xff0c;它提供了大量的核心Java库&#xff0c;例如&#xff1a;集合、缓存、原生类型支持、并发库、通用注解、字符串处理和I/O操作等。 异常处理 传统的Java异常处理通常包括try-catch-finally块和throws关键字。 遇到FileNotFoundException或IOExce…

【算法可视化】图论专题

运行平台 Algorithm Visualizer 图的深度优先遍历 // import visualization libraries { const { Tracer, Array1DTracer, GraphTracer, LogTracer, Randomize, Layout, VerticalLayout } require(algorithm-visualizer); // }// define tracer variables { const graphTra…

嵌入式蓝桥杯做题总结

第十二届省赛 按键代码 ——自认为比较巧妙&#xff0c;定时器3被设置为10ms进入一次中断&#xff0c;代替了HAL_Delay(10)的方法消抖&#xff1b; 运用状态机机思想实现检测多个按键检测——且分为两个状态&#xff0c;其中一个状态PB&#xff11;和PB&#xff12;的按键不…

stable-diffusion-webui-forge 介绍,安装,运行

一 stable-diffusion-webui-forge 介绍 stable-diffusion-webui-forge 的作用和stable-diffusion-webui一样&#xff0c;但性能上作了优化&#xff0c;说得上是是stable-diffusion-webui优化版&#xff0c;本人在使用stable-diffusion-webui时偶尔会有内存不够报错。本人的环境…

手写分布式配置中心(四)增加实时刷新功能(长轮询)

上一篇文章中实现了短轮询&#xff0c;不过短轮询的弊端也很明显&#xff0c;如果请求的频率较高&#xff0c;那么就会导致服务端压力大&#xff08;并发高&#xff09;&#xff1b;如果请求的频率放低&#xff0c;那么客户端感知变更的及时性就会降低。所以我们来看另一种轮询…

Mysql面试总结

基础 1. 数据库的三范式是什么&#xff1f; 第一范式&#xff1a;强调的是列的原子性&#xff0c;即数据库表的每一列都是不可分割的原子数据项。第二范式&#xff1a;要求实体的属性完全依赖于主关键字。所谓完全 依赖是指不能存在仅依赖主关键字一部分的属性。第三范式&…

牛客 子序列的权值最小值(贪心)

链接&#xff1a;https://ac.nowcoder.com/acm/contest/76803/A 来源&#xff1a;牛客网 题目描述 给定一个长度为 n n n 的数组 a a a&#xff0c;求数组所有非空子序列权值的最小值。 定义子序列 a i , a j , … , a k a_i,a_j,…,a_k ai​,aj​,…,ak​ 的权值为 a i a…

什么是reids缓存雪崩、缓存击穿、缓存穿透?

缓存雪崩、缓存击穿和缓存穿透是与redis缓存系统相关的三种常见问题&#xff0c;它们都可能导致缓存系统性能下降或失效。下面分别解释这三种情况并提供例子&#xff1a; 缓存雪崩&#xff08;Cache Avalanche&#xff09;&#xff1a; 定义&#xff1a; 缓存雪崩是指在某个时…

UDP通信发送和接收 || UDP实现全双工通信

recvfrom ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen); 功能: 从套接字中接收数据 参数: sockfd:套接字文件描述符 buf:存放数据空间首地址 …

基于springboot实现的幼儿园管理系统

一、系统架构 前端&#xff1a;html | layui | jquery | css 后端&#xff1a;springboot | mybatis 环境&#xff1a;jdk1.8 | mysql | maven 二、代码及数据库 三、功能介绍 01. 登录页 02. 系统管理-用户管理 03. 系统管理-页面管理 04. 系统管理-角色管…

Day 50[补档] |● 123.买卖股票的最佳时机III ● 188.买卖股票的最佳时机IV

123.买卖股票的最佳时机III class Solution { public:int maxProfit(vector<int>& prices) {if(prices.size() 0) return 0;vector<vector<int>> dp(prices.size(), vector<int>(5,0));//dp[i][j] 表示根据j的方法数下&#xff0c;第i天时候最大…

win11配置Mask DINO小白踩坑记录

win11配置Mask DINO踩坑记录 1 准备工作2 创建python环境和安装detectron22.1 安装前提2.2 安装流程2.2.1 cl.exe的错误2.2.2 SetuptoolsDeprecationWarning的错误 3 MaskDINO运行3.1 运行demo 前情提要&#xff1a;需要复现Mask DINO&#xff0c;但是实验室没有Linux的电脑&am…

keycloak18.0.0==本地源码启动

github下载源码&#xff0c; 版本18.0.0 java和maven的版本如下 E:\keycloak-18.0.0>java -version java version "21.0.1" 2023-10-17 LTS Java(TM) SE Runtime Environment (build 21.0.112-LTS-29) Java HotSpot(TM) 64-Bit Server VM (build 21.0.112-LTS-…

Wince NK.BIN文件格式

nk.bin文件格式 开始7个字节为 42 30 30 30 46 46 0A 即“B000FF\x0A”&#xff0c;以次来判别文件类型。 接下来4字节&#xff08;DWORD&#xff09;表示ImageStart, 4字节表示ImageLength 如7字节后的8字节分别为&#xff1a;00 00 00 60 9C FA 33 01 则表示ImageStart0x600…

【SpringBoot3.x教程05】SpringBoot与关系型数据库的整合

前言&#xff1a;常用的ORM框架有哪些 JdbcTemplate JdbcTemplate 是Spring框架提供的一个JDBC抽象库&#xff0c;旨在简化传统的JDBC操作&#xff0c;避免了繁琐的JDBC代码和数据库资源的手动处理。通过JdbcTemplate&#xff0c;开发者可以更加专注于业务逻辑而不是数据库的连…

【网站项目】308学生档案管理系统

&#x1f64a;作者简介&#xff1a;拥有多年开发工作经验&#xff0c;分享技术代码帮助学生学习&#xff0c;独立完成自己的项目或者毕业设计。 代码可以私聊博主获取。&#x1f339;赠送计算机毕业设计600个选题excel文件&#xff0c;帮助大学选题。赠送开题报告模板&#xff…

如何用Python3自撰一个简单的后端框架

不使用任何现有的后端框架来创建一个Python 3的后端框架是一个相当复杂的任务,因为它涉及到许多Web开发的基础知识,比如HTTP协议处理、路由、中间件、请求和响应处理等。然而,我们可以从最基本的概念开始,逐步构建一个简单的后端框架。 以下是一个非常基础的指南,用于创建…

Spring Webflux 详解

目录 0、组件对比 1、WebFlux 1、引入 2、Reactor Core 1、HttpHandler、HttpServer 3、DispatcherHandler 1、请求处理流程 4、注解开发 1、目标方法传参 2.返回值写法 5、文件上传 6、错误处理 7、RequestContext 8、自定义Flux配置 9、Filter WebFlux&am…

2024武汉国际氢能源与燃料电池展将在8月盛大开幕!

2024武汉国际氢能源及燃料电池产业博览会 同期举办&#xff1a;2024世界汽车制造技术暨智能装备博览会 时间&#xff1a;2024.8.14-16 地点&#xff1a;武汉国际博览中心 邀请函 主办单位&#xff1a; 湖北省汽车行业协会 湖北省机械行业联合会 湖北省汽车产业技术创新联…