安徽阜阳网站建设公司,wordpress网页自适应屏幕大小,锦州制作网站公司,可信网站 收费之前写过一篇博客《SpringMybatisMysql搭建分布式数据库访问框架》描述如何通过SpringMybatis配置动态数据源访问多个数据库。但是之前的方案有一些限制(原博客中也描述了)#xff1a;只适用于数据库数量不多且固定的情况。针对数据库动态增加的情况无能为力。下面讲的方案能支…之前写过一篇博客《SpringMybatisMysql搭建分布式数据库访问框架》描述如何通过SpringMybatis配置动态数据源访问多个数据库。但是之前的方案有一些限制(原博客中也描述了)只适用于数据库数量不多且固定的情况。针对数据库动态增加的情况无能为力。下面讲的方案能支持数据库动态增删数量不限。数据库环境准备下面一Mysql为例先在本地建3个数据库用于测试。需要说明的是本方案不限数据库数量支持不同的数据库部署在不同的服务器上。如图所示db_project_001、db_project_002、db_project_003。搭建Java后台微服务项目创建一个Spring Boot的maven项目config数据源配置管理类。datasource自己实现的数据源管理逻辑。dbmgr管理了项目编码与数据库IP、名称的映射关系(实际项目中这部分数据保存在redis缓存中可动态增删)。mapper数据库访问接口。model映射模型。rest微服务对外发布的restful接口这里用来测试。application.yml配置了数据库的JDBC参数。详细的代码实现1. 添加数据源配置package com.elon.dds.config;import javax.sql.DataSource;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionFactoryBean;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import com.elon.dds.datasource.DynamicDataSource;/*** 数据源配置管理。** author elon* version 2018年2月26日*/ConfigurationMapperScan(basePackagescom.elon.dds.mapper, valuesqlSessionFactory)public class DataSourceConfig {/*** 根据配置参数创建数据源。使用派生的子类。** return 数据源*/Bean(namedataSource)ConfigurationProperties(prefixspring.datasource)public DataSource getDataSource() {DataSourceBuilder builder DataSourceBuilder.create();builder.type(DynamicDataSource.class);return builder.build();}/*** 创建会话工厂。** param dataSource 数据源* return 会话工厂*/Bean(namesqlSessionFactory)public SqlSessionFactory getSqlSessionFactory(Qualifier(dataSource) DataSource dataSource) {SqlSessionFactoryBean bean new SqlSessionFactoryBean();bean.setDataSource(dataSource);try {return bean.getObject();} catch (Exception e) {e.printStackTrace();return null;}}}2.定义动态数据源1) 首先增加一个数据库标识类用于区分不同的数据库访问。由于我们为不同的project创建了单独的数据库所以使用项目编码作为数据库的索引。而微服务支持多线程并发的采用线程变量。package com.elon.dds.datasource;/*** 数据库标识管理类。用于区分数据源连接的不同数据库。** author elon* version 2018-02-25*/public class DBIdentifier {/*** 用不同的工程编码来区分数据库*/private static ThreadLocal projectCode new ThreadLocal();public static String getProjectCode() {return projectCode.get();}public static void setProjectCode(String code) {projectCode.set(code);}}2) 从DataSource派生了一个DynamicDataSource在其中实现数据库连接的动态切换import java.lang.reflect.Field;import java.sql.Connection;import java.sql.SQLException;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.apache.tomcat.jdbc.pool.DataSource;import org.apache.tomcat.jdbc.pool.PoolProperties;import com.elon.dds.dbmgr.ProjectDBMgr;/*** 定义动态数据源派生类。从基础的DataSource派生动态性自己实现。** author elon* version 2018-02-25*/public class DynamicDataSource extends DataSource {private static Logger log LogManager.getLogger(DynamicDataSource.class);/*** 改写本方法是为了在请求不同工程的数据时去连接不同的数据库。*/Overridepublic Connection getConnection(){String projectCode DBIdentifier.getProjectCode();//1、获取数据源DataSource dds DDSHolder.instance().getDDS(projectCode);//2、如果数据源不存在则创建if (dds null) {try {DataSource newDDS initDDS(projectCode);DDSHolder.instance().addDDS(projectCode, newDDS);} catch (IllegalArgumentException | IllegalAccessException e) {log.error(Init data source fail. projectCode: projectCode);return null;}}dds DDSHolder.instance().getDDS(projectCode);try {return dds.getConnection();} catch (SQLException e) {e.printStackTrace();return null;}}/*** 以当前数据对象作为模板复制一份。** return dds* throws IllegalAccessException* throws IllegalArgumentException*/private DataSource initDDS(String projectCode) throws IllegalArgumentException, IllegalAccessException {DataSource dds new DataSource();// 2、复制PoolConfiguration的属性PoolProperties property new PoolProperties();Field[] pfields PoolProperties.class.getDeclaredFields();for (Field f : pfields) {f.setAccessible(true);Object value f.get(this.getPoolProperties());try{f.set(property, value);}catch (Exception e){log.info(Set value fail. attr name: f.getName());continue;}}dds.setPoolProperties(property);// 3、设置数据库名称和IP(一般来说端口和用户名、密码都是统一固定的)String urlFormat this.getUrl();String url String.format(urlFormat, ProjectDBMgr.instance().getDBIP(projectCode),ProjectDBMgr.instance().getDBName(projectCode));dds.setUrl(url);return dds;}}3) 通过DDSTimer控制数据连接释放(超过指定时间未使用的数据源释放)package com.elon.dds.datasource;import org.apache.tomcat.jdbc.pool.DataSource;/*** 动态数据源定时器管理。长时间无访问的数据库连接关闭。** author elon* version 2018年2月25日*/public class DDSTimer {/*** 空闲时间周期。超过这个时长没有访问的数据库连接将被释放。默认为10分钟。*/private static long idlePeriodTime 10 * 60 * 1000;/*** 动态数据源*/private DataSource dds;/*** 上一次访问的时间*/private long lastUseTime;public DDSTimer(DataSource dds) {this.dds dds;this.lastUseTime System.currentTimeMillis();}/*** 更新最近访问时间*/public void refreshTime() {lastUseTime System.currentTimeMillis();}/*** 检测数据连接是否超时关闭。** return true-已超时关闭; false-未超时*/public boolean checkAndClose() {if (System.currentTimeMillis() - lastUseTime idlePeriodTime){dds.close();return true;}return false;}public DataSource getDds() {return dds;}}4) 增加DDSHolder来管理不同的数据源提供数据源的添加、查询功能package com.elon.dds.datasource;import java.util.HashMap;import java.util.Iterator;import java.util.Map;import java.util.Map.Entry;import java.util.Timer;import org.apache.tomcat.jdbc.pool.DataSource;/*** 动态数据源管理器。** author elon* version 2018年2月25日*/public class DDSHolder {/*** 管理动态数据源列表。*/private Map ddsMap new HashMap();/*** 通过定时任务周期性清除不使用的数据源*/private static Timer clearIdleTask new Timer();static {clearIdleTask.schedule(new ClearIdleTimerTask(), 5000, 60 * 1000);};private DDSHolder() {}/** 获取单例对象*/public static DDSHolder instance() {return DDSHolderBuilder.instance;}/*** 添加动态数据源。** param projectCode 项目编码* param dds dds*/public synchronized void addDDS(String projectCode, DataSource dds) {DDSTimer ddst new DDSTimer(dds);ddsMap.put(projectCode, ddst);}/*** 查询动态数据源** param projectCode 项目编码* return dds*/public synchronized DataSource getDDS(String projectCode) {if (ddsMap.containsKey(projectCode)) {DDSTimer ddst ddsMap.get(projectCode);ddst.refreshTime();return ddst.getDds();}return null;}/*** 清除超时无人使用的数据源。*/public synchronized void clearIdleDDS() {Iterator iter ddsMap.entrySet().iterator();for (; iter.hasNext(); ) {Entry entry iter.next();if (entry.getValue().checkAndClose()){iter.remove();}}}/*** 单例构件类* author elon* version 2018年2月26日*/private static class DDSHolderBuilder {private static DDSHolder instance new DDSHolder();}}5) 定时器任务ClearIdleTimerTask用于定时清除空闲的数据源package com.elon.dds.datasource;import java.util.TimerTask;/*** 清除空闲连接任务。** author elon* version 2018年2月26日*/public class ClearIdleTimerTask extends TimerTask {Overridepublic void run() {DDSHolder.instance().clearIdleDDS();}}3. 管理项目编码与数据库IP和名称的映射关系package com.elon.dds.dbmgr;import java.util.HashMap;import java.util.Map;/*** 项目数据库管理。提供根据项目编码查询数据库名称和IP的接口。* author elon* version 2018年2月25日*/public class ProjectDBMgr {/*** 保存项目编码与数据名称的映射关系。这里是硬编码实际开发中这个关系数据可以保存到redis缓存中* 新增一个项目或者删除一个项目只需要更新缓存。到时这个类的接口只需要修改为从缓存拿数据。*/private Map dbNameMap new HashMap();/*** 保存项目编码与数据库IP的映射关系。*/private Map dbIPMap new HashMap();private ProjectDBMgr() {dbNameMap.put(project_001, db_project_001);dbNameMap.put(project_002, db_project_002);dbNameMap.put(project_003, db_project_003);dbIPMap.put(project_001, 127.0.0.1);dbIPMap.put(project_002, 127.0.0.1);dbIPMap.put(project_003, 127.0.0.1);}public static ProjectDBMgr instance() {return ProjectDBMgrBuilder.instance;}// 实际开发中改为从缓存获取public String getDBName(String projectCode) {if (dbNameMap.containsKey(projectCode)) {return dbNameMap.get(projectCode);}return ;}//实际开发中改为从缓存中获取public String getDBIP(String projectCode) {if (dbIPMap.containsKey(projectCode)) {return dbIPMap.get(projectCode);}return ;}private static class ProjectDBMgrBuilder {private static ProjectDBMgr instance new ProjectDBMgr();}}4. 定义数据库访问的mapperpackage com.elon.dds.mapper;import java.util.List;import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Result;import org.apache.ibatis.annotations.Results;import org.apache.ibatis.annotations.Select;import com.elon.dds.model.User;/*** Mybatis映射接口定义。** author elon* version 2018年2月26日*/Mapperpublic interface UserMapper{/*** 查询所有用户数据* return 用户数据列表*/Results(value {Result(propertyuserId, columnid),Result(propertyname, columnname),Result(propertyage, columnage)})Select(select id, name, age from tbl_user)List getUsers();}5. 定义查询对象模型package com.elon.dds.model;public class User{private int userId -1;private String name ;private int age -1;Overridepublic String toString(){return name: name |age: age;}public int getUserId(){return userId;}public void setUserId(int userId){this.userId userId;}public String getName(){return name;}public void setName(String name){this.name name;}public int getAge(){return age;}public void setAge(int age){this.age age;}}6. 定义查询用户数据的restful接口package com.elon.dds.rest;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.RestController;import com.elon.dds.datasource.DBIdentifier;import com.elon.dds.mapper.UserMapper;import com.elon.dds.model.User;/*** 用户数据访问接口。** author elon* version 2018年2月26日*/RestControllerRequestMapping(value/user)public class WSUser {Autowiredprivate UserMapper userMapper;/*** 查询项目中所有用户信息** param projectCode 项目编码* return 用户列表*/RequestMapping(value/v1/users, methodRequestMethod.GET)public List queryUser(RequestParam(valueprojectCode, requiredtrue) String projectCode){DBIdentifier.setProjectCode(projectCode);return userMapper.getUsers();}}要求每次查询都要带上projectCode参数。7. 编写Spring Boot App的启动代码package com.elon.dds;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;/*** Hello world!**/SpringBootApplicationpublic class App{public static void main( String[] args ){System.out.println( Hello World! );SpringApplication.run(App.class, args);}}8. 在application.yml中配置数据源其中的数据库IP和数据库名称使用%s。在查询用户数据中动态切换。spring:datasource:url: jdbc:mysql://%s:3306/%s?useUnicodetruecharacterEncodingutf-8username: rootpassword:driver-class-name: com.mysql.jdbc.Driverlogging:config: classpath:log4j2.xml测试方案1. 查询project_001的数据正常返回2. 查询project_002的数据正常返回总结以上所述是小编给大家介绍的通过Spring Boot配置动态数据源访问多个数据库的实现代码希望对大家有所帮助如果大家有任何疑问请给我留言小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持
