在SpringBoot微服務(wù)中設(shè)置和管理多個(gè)數(shù)據(jù)庫(kù)的代碼示例
更新時(shí)間：2024年12月26日 09:12:30 作者：小蝸牛慢慢爬行
在現(xiàn)代微服務(wù)架構(gòu)中,通常需要與多個(gè)數(shù)據(jù)庫(kù)交互的服務(wù),這可能是由于各種原因,例如遺留系統(tǒng)集成、不同類型的數(shù)據(jù)存儲(chǔ)需求,或者僅僅是為了優(yōu)化性能,在本綜合指南中,我們將探討如何在 Spring Boot 微服務(wù)中設(shè)置和管理多個(gè)數(shù)據(jù)庫(kù)連接,需要的朋友可以參考下
引言
在現(xiàn)代微服務(wù)架構(gòu)中，通常需要與多個(gè)數(shù)據(jù)庫(kù)交互的服務(wù)。這可能是由于各種原因，例如遺留系統(tǒng)集成、不同類型的數(shù)據(jù)存儲(chǔ)需求，或者僅僅是為了優(yōu)化性能。Spring Boot 具有靈活的配置和強(qiáng)大的數(shù)據(jù)訪問(wèn)庫(kù)，可以輕松配置多個(gè)數(shù)據(jù)庫(kù)。在本綜合指南中，我們將探討如何在 Spring Boot 微服務(wù)中設(shè)置和管理多個(gè)數(shù)據(jù)庫(kù)連接。
1. 簡(jiǎn)介
微服務(wù)通常需要與各種數(shù)據(jù)庫(kù)交互。每個(gè)微服務(wù)可能需要不同類型的數(shù)據(jù)庫(kù)，例如用于事務(wù)數(shù)據(jù)的 SQL 數(shù)據(jù)庫(kù)和用于非結(jié)構(gòu)化數(shù)據(jù)的 NoSQL 數(shù)據(jù)庫(kù)。Spring Boot 為配置和管理多個(gè)數(shù)據(jù)源提供了出色的支持，使其成為現(xiàn)代微服務(wù)架構(gòu)的理想選擇。
2.為什么要使用多個(gè)數(shù)據(jù)庫(kù)？
您可能需要在微服務(wù)中使用多個(gè)數(shù)據(jù)庫(kù)的原因如下：
- 遺留系統(tǒng)集成：與遺留系統(tǒng)的現(xiàn)有數(shù)據(jù)庫(kù)集成。
- 優(yōu)化性能：使用針對(duì)特定類型的數(shù)據(jù)（例如關(guān)系型與非關(guān)系型）優(yōu)化的不同數(shù)據(jù)庫(kù)。
- 數(shù)據(jù)隔離：出于安全、合規(guī)或組織原因分離數(shù)據(jù)。
- 可擴(kuò)展性：在不同的數(shù)據(jù)庫(kù)之間分配數(shù)據(jù)負(fù)載以提高性能。
3.設(shè)置 Spring Boot 項(xiàng)目
首先，創(chuàng)建一個(gè)新的 Spring Boot 項(xiàng)目。您可以使用 Spring Initializr 或您喜歡的 IDE 來(lái)設(shè)置項(xiàng)目。
Maven 依賴項(xiàng)
在您的 中pom.xml包含 Spring Data JPA 和您將使用的數(shù)據(jù)庫(kù)的依賴項(xiàng)（例如，內(nèi)存中的 H2、PostgreSQL、MySQL 等）。
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<scope>runtime</scope>
</dependency>
</dependencies>4.配置多個(gè)數(shù)據(jù)源
在application.yml或application.properties文件中，配置每個(gè)數(shù)據(jù)庫(kù)的連接屬性。
application.yml
spring:
datasource:
primary:
url: jdbc:h2:mem:primarydb
driver-class-name: org.h2.Driver
username: sa
password: password
secondary:
url: jdbc:postgresql://localhost:5432/secondarydb
driver-class-name: org.postgresql.Driver
username: postgres
password: password
jpa:
primary:
database-platform: org.hibernate.dialect.H2Dialect
hibernate:
ddl-auto: update
secondary:
database-platform: org.hibernate.dialect.PostgreSQLDialect
hibernate:
ddl-auto: update5.創(chuàng)建數(shù)據(jù)源配置類
接下來(lái)，為每個(gè)數(shù)據(jù)源創(chuàng)建單獨(dú)的配置類。
主數(shù)據(jù)源配置
package com.example.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;
@Configuration
@EnableJpaRepositories(
basePackages = "com.example.primary.repository",
entityManagerFactoryRef = "primaryEntityManagerFactory",
transactionManagerRef = "primaryTransactionManager"
)
public class PrimaryDataSourceConfig {
@Bean(name = "primaryDataSource")
@ConfigurationProperties(prefix = "spring.datasource.primary")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "primaryEntityManagerFactory")
public LocalContainerEntityManagerFactoryBean primaryEntityManagerFactory(
@Qualifier("primaryDataSource") DataSource dataSource) {
LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
em.setDataSource(dataSource);
em.setPackagesToScan(new String[] { "com.example.primary.entity" });
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
em.setJpaVendorAdapter(vendorAdapter);
return em;
}
@Bean(name = "primaryTransactionManager")
public PlatformTransactionManager primaryTransactionManager(
@Qualifier("primaryEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
return new JpaTransactionManager(entityManagerFactory);
}
}輔助數(shù)據(jù)源配置
package com.example.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;
@Configuration
@EnableJpaRepositories(
basePackages = "com.example.secondary.repository",
entityManagerFactoryRef = "secondaryEntityManagerFactory",
transactionManagerRef = "secondaryTransactionManager"
)
public class SecondaryDataSourceConfig {
@Bean(name = "secondaryDataSource")
@ConfigurationProperties(prefix = "spring.datasource.secondary")
public DataSource secondaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "secondaryEntityManagerFactory")
public LocalContainerEntityManagerFactoryBean secondaryEntityManagerFactory(
@Qualifier("secondaryDataSource") DataSource dataSource) {
LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
em.setDataSource(dataSource);
em.setPackagesToScan(new String[] { "com.example.secondary.entity" });
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
em.setJpaVendorAdapter(vendorAdapter);
return em;
}
@Bean(name = "secondaryTransactionManager")
public PlatformTransactionManager secondaryTransactionManager(
@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
return new JpaTransactionManager(entityManagerFactory);
}
}6. 定義實(shí)體管理器
為每個(gè)數(shù)據(jù)庫(kù)定義實(shí)體類。確保將它們放在配置類中指定的相應(yīng)包中。
主數(shù)據(jù)庫(kù)實(shí)體
package com.example.primary.entity;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
@Entity
public class PrimaryEntity {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
private String name;
// getters and setters
}輔助數(shù)據(jù)庫(kù)實(shí)體
package com.example.secondary.entity;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
@Entity
public class SecondaryEntity {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
private String description;
// getters and setters
}7. 創(chuàng)建存儲(chǔ)庫(kù)
為每個(gè)數(shù)據(jù)庫(kù)創(chuàng)建存儲(chǔ)庫(kù)接口，確保它們按照配置放置在正確的包中。
主存儲(chǔ)庫(kù)
package com.example.primary.repository;
import com.example.secondary.entity.SecondaryEntity;
import org.springframework.data.jpa.repository.JpaRepository;
public interface SecondaryRepository extends JpaRepository<SecondaryEntity, Long> {
}二級(jí)存儲(chǔ)庫(kù)
package com.example.secondary.repository;
import com.example.secondary.entity.SecondaryEntity;
import org.springframework.data.jpa.repository.JpaRepository;
public interface SecondaryRepository extends JpaRepository<SecondaryEntity, Long> {
}8.測(cè)試配置
最后，創(chuàng)建一個(gè)簡(jiǎn)單的 REST 控制器來(lái)測(cè)試設(shè)置。此控制器將使用兩個(gè)存儲(chǔ)庫(kù)來(lái)執(zhí)行 CRUD 操作。
package com.example.controller;
import com.example.primary.entity.PrimaryEntity;
import com.example.primary.repository.PrimaryRepository;
import com.example.secondary.entity.SecondaryEntity;
import com.example.secondary.repository.SecondaryRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class TestController {
@Autowired
private PrimaryRepository primaryRepository;
@Autowired
private SecondaryRepository secondaryRepository;
@GetMapping("/test")
public String test() {
PrimaryEntity primaryEntity = new PrimaryEntity();
primaryEntity.setName("Primary Entity");
primaryRepository.save(primaryEntity);
SecondaryEntity secondaryEntity = new SecondaryEntity();
secondaryEntity.setDescription("Secondary Entity");
secondaryRepository.save(secondaryEntity);
return "Entities saved!";
}
}以上就是在SpringBoot微服務(wù)中設(shè)置和管理多個(gè)數(shù)據(jù)庫(kù)的代碼示例的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot微服務(wù)設(shè)置和管理數(shù)據(jù)庫(kù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
本文介紹了在Spring Boot應(yīng)用中如何指定和使用配置文件,創(chuàng)建配置類讀取Nacos配置,并通過(guò)接口返回給前端,同時(shí)使用@RefreshScope實(shí)現(xiàn)配置實(shí)時(shí)刷新2026-01-01
JAVA使用TreeMap對(duì)字符串進(jìn)行排序
這篇文章主要介紹了JAVA使用TreeMap對(duì)字符串進(jìn)行排序,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02
Java?面向?qū)ο笸ㄟ^(guò)new揭開(kāi)對(duì)象實(shí)例化
各位鐵汁們大家好呀，我們上次博客講了，通過(guò)?Student?student1?=?new?Student();就可以實(shí)例化一個(gè)對(duì)象，這個(gè)對(duì)象就有Student類中的所以成員變量?？墒?對(duì)象student1?和?類Student到底是怎樣建立聯(lián)系的，在內(nèi)存中到底發(fā)生了什么2022-04-04
下面小編就為大家?guī)?lái)一篇老生常談java中的fail-fast機(jī)制。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-08-08
super?代表父類的存儲(chǔ)空間標(biāo)識(shí)(可以理解為父親的引用)。?this代表當(dāng)前對(duì)象的引用(誰(shuí)調(diào)用就代表誰(shuí))。本文將通過(guò)簡(jiǎn)單的示例介紹二者的使用與區(qū)別，需要的可以了解一下2022-10-10
原來(lái)Java接口多實(shí)現(xiàn)還可以這樣玩
JAVA中類不直接支持多繼承,因?yàn)闀?huì)出現(xiàn)調(diào)用的不確定性,所以JAVA將多繼承機(jī)制進(jìn)行改良,在JAVA中變成了多實(shí)現(xiàn),這篇文章主要給大家介紹了關(guān)于Java接口多實(shí)現(xiàn)的相關(guān)資料,需要的朋友可以參考下2021-09-09
SpringBoot中TypeExcludeFilter的作用及使用方式
在SpringBoot應(yīng)用程序中,TypeExcludeFilter通過(guò)過(guò)濾特定類型的組件,使它們不被自動(dòng)掃描和注冊(cè)為bean,這在排除不必要的組件或特定實(shí)現(xiàn)類時(shí)非常有用,通過(guò)創(chuàng)建自定義過(guò)濾器并注冊(cè)到spring.factories文件中,我們可以在應(yīng)用啟動(dòng)時(shí)生效2025-01-01
詳解Spring AOP 實(shí)現(xiàn)“切面式”valid校驗(yàn)
本篇文章主要介紹了詳解Spring AOP 實(shí)現(xiàn)“切面式”valid校驗(yàn)，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-01-01
Javase隨機(jī)數(shù)類、日期類、包裝類的基礎(chǔ)知識(shí)示例詳解
我們?cè)陂_(kāi)發(fā)時(shí),除了操作一些固定的數(shù)字之外,有時(shí)候還要操作一些不確定的隨機(jī)數(shù),這篇文章主要介紹了Javase隨機(jī)數(shù)類、日期類、包裝類的基礎(chǔ)知識(shí),文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2025-09-09
解決eclipse啟動(dòng)tomcat時(shí)不能加載web項(xiàng)目的問(wèn)題
這篇文章主要介紹了解決eclipse啟動(dòng)tomcat時(shí)不能加載web項(xiàng)目的問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-06-06