Spring Boot神操作-多个数据源Service层封装

当 JVM 内存严重不足时，就会抛出 java.lang.OutOfMemoryError 错误。本文总结了常见的 OOM 原因及其解决方法，如下图所示。如有遗漏或错误，欢迎补充指正。

Spring Boot - 多个数据源Service层封装
类关系图
封装的一些配置
- application.yml
- pom.xml
封装后使用
- MySQL 动态数据访问
Mongo 动态数据访问
ElasticSearch 动态数据访问(单个index+type)
ElasticSearch 动态数据访问(多个index+type)
源代码托管

类关系图

对多个数据源连接获取数据进行统一封装
ES spring-data方式不支持多个Index和Type的查找功能，添加了DynamicESDao支持
大大简化封装之后的调用, 调用方式如下

封装的一些配置

application.yml

banner:
charset: UTF-8
location: classpath:banner.txt
server:
port:5555
contextPath:/
session:
timeout:0
spring:
application:
name:'spring-boot-datasource-demo'
output:
ansi:
enabled: DETECT
messages:
basename: i18n/messages
thymeleaf:
cache:false
profiles:
active: dev
#MySQL data source settings
datasource:
url: jdbc:mysql://localhost:3306/cdc_standalone?useSSL=false
username: root
password: bfXa4Pt2lUUScy8jakXf
#MySQL JPA settings
jpa:
generate-ddl:true
show-sql:true
properties:
hibernate:
dialect: org.hibernate.dialect.MySQLDialect
format_sql:true
#NoSQL data source settings
data:
#MongoDB2.2+ settings
mongodb:
uri: mongodb://standalone:fhY1tPt1lpUSbS7jwkTf@10.11.60.4:27017/standalone
#ElasticSearch settings
elasticsearch:
cluster-name: es-logs-01
cluster-nodes:10.11.60.5:9300

pom.xml

<projectxmlns="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>spring-boot-datasource-demo</groupId>
<artifactId>spring-boot-datasource-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>spring-boot-datasource-demo</name>
<description>spring-boot-datasource-demo</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.1.RELEASE</version>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<commons.lang.version>3.3.2</commons.lang.version>
<springfox.version>2.7.0</springfox.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<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>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>${springfox.version}</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>${springfox.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons.lang.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
<version>4.1</version>
</dependency>
<dependency>
<groupId>com.github.wenhao</groupId>
<artifactId>jpa-spec</artifactId>
<version>3.2.3</version>
</dependency>
</dependencies>
<build>
<sourceDirectory>src</sourceDirectory>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>

封装后使用

封装之后使用将非常简单，公共的Service行为将被封装处理

MySQL 动态数据访问

通过几行代码即可实现对MySQL的访问，同时支持动态的条件查询；

User

@Entity
@Table(name ="tb_user")
publicclassUserextendsBaseEntity{
privatestaticfinallong serialVersionUID =1L;
/**
* 用户id
*/
@Id
@GeneratedValue(strategy =GenerationType.AUTO)
@Column(name ="id", nullable =false)
privateInteger id;
privateString userName;
privateString nickName;
privateString password;
privateInteger sex;
privateString telephone;
privateString email;
privateString address;
privateInteger deleteStatus;
privateInteger locked =0;
privateString description;
@JSONField(format ="yyyy-MM-dd HH:mm:ss")
privateDate createTime;
@JSONField(format ="yyyy-MM-dd HH:mm:ss")
privateDate updateTime;
@ManyToMany(cascade ={CascadeType.REFRESH }, fetch =FetchType.LAZY)
@JoinTable(name ="tb_user_role", joinColumns ={@JoinColumn(name ="user_id")}, inverseJoinColumns ={
@JoinColumn(name ="role_id")})
private java.util.Set<Role> roles;
// getter & setter
}

Dao

@Repository
publicinterfaceIUserDaoextendsIBaseJpaDao<User,Integer>{
}

Service

publicinterfaceIUserServiceextendsIBaseJpaService<User,Integer>{
}
@Service
publicclassUserServiceImplextendsBaseJpaServiceImpl<User,Integer>implementsIUserService{
@Autowired
privateIUserDao userDao;
@Override
publicIBaseJpaDao<User,Integer> getBaseDao(){
returnthis.userDao;
}
@Override
publicvoiddelete(Integer id){
User user = find(id);
Assert.state(!"admin".equals(user.getUserName()),"超级管理员用户不能删除");
super.delete(id);
}
}

Controller

@RestController
@RequestMapping("/admin/user")
publicclassUserController{
/**
* user service
*/
@Autowired
privateIUserService userService;
/**
* @param searchText
- 发表于 2020-03-14 09:56
- 阅读 ( 1204 )
- 分类：Java开发

作家榜 »

轩辕小不懂 2403 文章
小柒 1956 文章
Pack 1147 文章
Nen 576 文章
王昭君 209 文章
文双 71 文章
小威 64 文章
Cara 36 文章

Spring Boot神操作-多个数据源Service层封装

类关系图

封装的一些配置

application.yml

pom.xml

封装后使用

MySQL 动态数据访问

你可能感兴趣的文章

相关问题

0 条评论

作家榜 »