ホームページ Java &#&チュートリアル SpringBoot で動的データソースを使用して複数のデータソースを構成する方法

SpringBoot で動的データソースを使用して複数のデータソースを構成する方法

May 16, 2023 pm 07:07 PM
springboot dynamic datasource

機能的特徴:

  1. さまざまなシナリオに適したデータ ソースのグループ化、純粋なマルチデータベース、読み取りと書き込みの分離、1 つのマスター、複数のデータ ソースのグループ化をサポートスレーブ、混合モード。

  2. データ ソースなしの起動をサポートし、遅延起動データ ソースの構成をサポートします (3.3.2)。

  3. データベースの機密構成情報の暗号化 ENC() をサポートします。

  4. 各データベースのテーブル構造スキーマとデータベース データベースの独立した初期化をサポートします。

  5. カスタム アノテーションをサポートし、DS (3.2.0) を継承する必要があります。

  6. Druid、Mybatis-Plus、P6sy、Jndi の高速統合を提供します。

  7. Druid と HikariCp の構成を簡素化し、グローバル パラメーター構成を提供します。一度設定すれば、それをグローバルに使用できます。

  8. カスタム データ ソース ソリューションを提供します。

  9. プロジェクトの開始後にデータ ソースを動的に追加および削除するためのソリューションを提供します。

  10. Mybatis 環境で純粋な読み取り/書き込み分離ソリューションを提供します。

  11. SpEL 動的パラメーターを使用して、データ ソース スキームを解析するメソッドを提供します。組み込みのスペル、セッション、ヘッダー、サポートのカスタマイズ。

  12. マルチレイヤー データ ソースのネストされた切り替えをサポートします。 (サービス A >>> サービス B >>> サービス C)。

  13. hiro、sharding-jdbc、quartz などのサードパーティ ライブラリを統合するためのソリューション、注意事項、および例を提供します。

  14. Seata に基づいた分散トランザクション ソリューションを提供します。添付ファイル: ネイティブ Spring トランザクションはサポートされていません。

  15. ローカルのマルチデータ ソース トランザクション ソリューションを提供します。添付ファイル: ネイティブ Spring トランザクション (3.3.1) はサポートされていません。

この記事では、主に読み取りと書き込みの分離と、1 つのマスター、複数のスレーブ環境を実装します。

  • メイン データベースでは、INSERT、UPDATE、および DELETE 操作のみを実行することをお勧めします。

  • データベースからの SELECT 操作のみを実行することをお勧めします。

1. データベースの準備

メイン データベース: PiaoDB

SpringBoot中如何使用Dynamic Datasource配置多数据源

##スレーブ データベース 1: PiaoDB2

SpringBoot中如何使用Dynamic Datasource配置多数据源

スレーブ データベース 2: PiaoDB3

SpringBoot中如何使用Dynamic Datasource配置多数据源

2. POM ファイルをインポート

dynamic-datasource-spring-boot-starter の紹介。

<!-- 多数据源 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.3.2</version>
</dependency>
ログイン後にコピー

3. 設定ファイルを編集します

マスター ライブラリと 2 つのスレーブ ライブラリを設定しました。

  • 設定ファイル内のアンダースコア _ で区切られたすべてのデータ ソースの「ヘッダー」はグループの名前です。同じグループ名のデータ ソースは 1 つのグループの下に配置されます。グループ。

  • デフォルトのデータ ソース名は master ですが、spring.datasource.dynamic.primary を通じて変更できます。

spring:
  datasource:
    dynamic:
      primary: master #设置默认的数据源或者数据源组,默认值即为master
      strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/PiaoDB?serverTimezone=Asia/Shanghai
          username: root
          password: root
          driver-class-name: com.mysql.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
        slave_1:
          url: jdbc:mysql://localhost:3306/PiaoDB2?serverTimezone=Asia/Shanghai
          username: root
          password: root
          driver-class-name: com.mysql.jdbc.Driver
        slave_2:
          url: jdbc:mysql://localhost:3306/PiaoDB3?serverTimezone=Asia/Shanghai
          username: root
          password: root
          driver-class-name: com.mysql.jdbc.Driver
ログイン後にコピー
Alibaba データベース接続プール Druid を使用しているため、ネイティブ Druid クイック構成クラスを除外する必要があります。

その他のサードパーティ統合アドレス: Druid 統合

@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)
public class Application {

  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }
}
ログイン後にコピー
一部の springBoot バージョンは除外できない場合があり、次の方法で除外できます。

spring:
  autoconfigure:
    exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
ログイン後にコピー
1 つのマスターと複数のスレーブを構成することに加えて、それを構成することもできます。

# 多主多从                      纯粹多库(记得设置primary)                   混合配置
spring:                               spring:                               spring:
  datasource:                           datasource:                           datasource:
    dynamic:                              dynamic:                              dynamic:
      datasource:                           datasource:                           datasource:
        master_1:                             mysql:                                master:
        master_2:                             oracle:                               slave_1:
        slave_1:                              sqlserver:                            slave_2:
        slave_2:                              postgresql:                           oracle_1:
        slave_3:                              h3:                                   oracle_2:
ログイン後にコピー

4. コードを記述します

@DS を使用してデータ ソースを切り替えます。 @DS はメソッドとクラスにアノテーションを付けることができます。両方が存在する場合、メソッド アノテーションがクラス アノテーションより優先されます。サービス実装またはマッパー インターフェイス メソッドにアノテーションを付けることを強くお勧めします。

  • @DS("xxx") はデータ ソース xxx を指定します。xxx はグループ名または特定のライブラリの名前です。グループ名の場合、切り替え時に負荷分散アルゴリズムが使用されます。指定したグループ名またはライブラリが存在しない場合は、デフォルトのデータ ソース (メイン ライブラリ) が自動的に使用されます。

  • #@DS がない場合は、デフォルトのデータ ソース (メイン ライブラリ)

  • @DS が設定されているが、グループまたはライブラリが指定されていない場合は、DynamicDataSourceStrategy 戦略に基づいてスレーブ ライブラリが選択されます。デフォルトの負荷分散ポリシー。

1. コントローラーの書き込み
@RestController
@RequiredArgsConstructor
@RequestMapping("/demo")
public class DemoController {

    private final DemoService demoService;

    @GetMapping("/add")
    public String add() {
        return demoService.add(null) + "";
    }

    @GetMapping("/selectGoodsInfo")
    public List<GoodsInfo> selectGoodsInfo(){
        return demoService.selectGoodsInfo();
    }

    @GetMapping("/selectMasterGoodsInfo")
    public List<GoodsInfo> selectMasterGoodsInfo(){
        return demoService.selectMasterGoodsInfo();
    }

}
ログイン後にコピー

2. サービスの書き込み

public interface DemoService {

    boolean add(GoodsInfo param);

    List<GoodsInfo> selectGoodsInfo();

    List<GoodsInfo> selectMasterGoodsInfo();

}
ログイン後にコピー
@Service
@RequiredArgsConstructor
public class DemoServiceImpl implements DemoService {

    private final DemoMapper demoMapper;

    @DS("master")
    @Override
    public boolean add(GoodsInfo param) {
        param = new GoodsInfo();
        param.setGname("1200元秒杀华为Pad");
        param.setGnum(100);

        return demoMapper.insertGoodsInfo(param);
    }

    @DS("slave")
    @Override
    public List<GoodsInfo> selectGoodsInfo() {
        return demoMapper.selectGoodsInfo();
    }

    @DS("master")
    @Override
    public List<GoodsInfo> selectMasterGoodsInfo() {
        return demoMapper.selectGoodsInfo();
    }

}
ログイン後にコピー

3. マッパーの書き込み

@Mapper
public interface DemoMapper {

    boolean insertGoodsInfo(GoodsInfo param);

    List<GoodsInfo> selectGoodsInfo();

}
ログイン後にコピー
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.example.demo.mapper.DemoMapper">

    <select id="selectGoodsInfo" resultType="com.example.demo.entity.GoodsInfo">
        select * from t_goods_info
    </select>

    <insert id="insertGoodsInfo">
        insert into t_goods_info (gname, gnum, gcreatetime)
            values (#{gname}, #{gnum}, now());
    </insert>

</mapper>
ログイン後にコピー

5. 検証結果

1. 新しいインターフェースの追加リクエスト (メインデータベースにデータを追加): 127.0.0.1:8086/demo/add

2. クエリリクエストメイン データベース データ インターフェイス: 127.0.0.1:8086/demo/selectMasterGoodsInfo

SpringBoot中如何使用Dynamic Datasource配置多数据源3. スレーブ データ インターフェイス (負荷分散) のリクエスト:

最初のリクエスト: # ##############二つ目の要求: ############

以上がSpringBoot で動的データソースを使用して複数のデータソースを構成する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

Springboot が Jasypt を統合して構成ファイルの暗号化を実装する方法 Springboot が Jasypt を統合して構成ファイルの暗号化を実装する方法 Jun 01, 2023 am 08:55 AM

Jasypt の概要 Jasypt は、開発者が最小限の労力で基本的な暗号化機能を自分のプロジェクトに追加できる Java ライブラリであり、暗号化の仕組みを深く理解する必要はありません。一方向および双方向暗号化の高いセキュリティ。標準ベースの暗号化テクノロジー。パスワード、テキスト、数値、バイナリを暗号化します... Spring ベースのアプリケーション、オープン API への統合、JCE プロバイダーでの使用に適しています... 次の依存関係を追加します: com.github.ulisesbocchiojasypt-spring-boot-starter2. 1.1 Jasypt の特典はシステムのセキュリティを保護し、コードが漏洩した場合でもデータ ソースは保証されます。

Redis を使用して SpringBoot に分散ロックを実装する方法 Redis を使用して SpringBoot に分散ロックを実装する方法 Jun 03, 2023 am 08:16 AM

1. Redis は分散ロックの原則を実装しており、分散ロックが必要な理由 分散ロックについて話す前に、分散ロックが必要な理由を説明する必要があります。分散ロックの反対はスタンドアロン ロックです。マルチスレッド プログラムを作成するとき、共有変数を同時に操作することによって引き起こされるデータの問題を回避します。通常、ロックを使用して共有変数を相互に除外し、データの正確性を確保します。共有変数の使用範囲は同じプロセス内です。共有リソースを同時に操作する必要があるプロセスが複数ある場合、どうすれば相互排他的になるのでしょうか?今日のビジネス アプリケーションは通常マイクロサービス アーキテクチャであり、これは 1 つのアプリケーションが複数のプロセスをデプロイすることも意味します。複数のプロセスが MySQL の同じレコード行を変更する必要がある場合、順序の乱れた操作によって引き起こされるダーティ データを避けるために、分散が必要です。今回導入するスタイルはロックされています。ポイントを獲得したい

SpringBoot が Redisson を統合して遅延キューを実装する方法 SpringBoot が Redisson を統合して遅延キューを実装する方法 May 30, 2023 pm 02:40 PM

使用シナリオ 1. 注文は正常に行われましたが、支払いが 30 分以内に行われませんでした。支払いがタイムアウトになり、注文が自動的にキャンセルされました 2. 注文に署名があり、署名後 7 日間評価が行われませんでした。注文がタイムアウトして評価されない場合、システムはデフォルトでプラスの評価を設定します 3. 注文は正常に行われます。販売者が 5 分間注文を受け取らない場合、注文はキャンセルされます。 4. 配送がタイムアウトします。 SMS リマインダーをプッシュします... 遅延が長く、リアルタイム パフォーマンスが低いシナリオでは、タスク スケジュールを使用して定期的なポーリング処理を実行できます。例: xxl-job 今日は選択します

Springbootがjarパッケージにファイルを読み込んだ後にファイルにアクセスできない問題を解決する方法 Springbootがjarパッケージにファイルを読み込んだ後にファイルにアクセスできない問題を解決する方法 Jun 03, 2023 pm 04:38 PM

Springboot はファイルを読み取りますが、jar パッケージにパッケージ化した後、最新の開発にアクセスできません。jar パッケージにパッケージ化した後、Springboot がファイルを読み取れない状況があります。その理由は、パッケージ化後、ファイルの仮想パスが変更されるためです。は無効であり、ストリーム経由でのみアクセスできます。読み取ります。ファイルはリソースの下にあります publicvoidtest(){Listnames=newArrayList();InputStreamReaderread=null;try{ClassPathResourceresource=newClassPathResource("name.txt");Input

SpringBootとSpringMVCの比較と差異分析 SpringBootとSpringMVCの比較と差異分析 Dec 29, 2023 am 11:02 AM

SpringBoot と SpringMVC はどちらも Java 開発で一般的に使用されるフレームワークですが、それらの間には明らかな違いがいくつかあります。この記事では、これら 2 つのフレームワークの機能と使用法を調べ、その違いを比較します。まず、SpringBoot について学びましょう。 SpringBoot は、Spring フレームワークに基づいたアプリケーションの作成と展開を簡素化するために、Pivo​​tal チームによって開発されました。スタンドアロンの実行可能ファイルを構築するための高速かつ軽量な方法を提供します。

SpringBoot が Redis をカスタマイズしてキャッシュのシリアル化を実装する方法 SpringBoot が Redis をカスタマイズしてキャッシュのシリアル化を実装する方法 Jun 03, 2023 am 11:32 AM

1. RedisAPI のデフォルトのシリアル化メカニズムである RedisTemplate1.1 をカスタマイズします。API ベースの Redis キャッシュ実装では、データ キャッシュ操作に RedisTemplate テンプレートを使用します。ここで、RedisTemplate クラスを開いて、クラスのソース コード情報を表示します。publicclassRedisTemplateextendsRedisAccessorimplementsRedisOperations、BeanClassLoaderAware{//キーを宣言、値の各種シリアル化メソッド、初期値は空 @NullableprivateRedisSe

SQL ステートメントを使用せずに Springboot+Mybatis-plus を実装して複数のテーブルを追加する方法 SQL ステートメントを使用せずに Springboot+Mybatis-plus を実装して複数のテーブルを追加する方法 Jun 02, 2023 am 11:07 AM

Springboot+Mybatis-plus が SQL ステートメントを使用して複数テーブルの追加操作を実行しない場合、私が遭遇した問題は、テスト環境で思考をシミュレートすることによって分解されます: パラメーターを含む BrandDTO オブジェクトを作成し、パラメーターをバックグラウンドに渡すことをシミュレートします。 Mybatis-plus で複数テーブルの操作を実行するのは非常に難しいことを理解してください。Mybatis-plus-join などのツールを使用しない場合は、対応する Mapper.xml ファイルを設定し、臭くて長い ResultMap を設定するだけです。対応する SQL ステートメントを記述します。この方法は面倒に見えますが、柔軟性が高く、次のことが可能です。

Springbootでapplication.ymlの値を取得する方法 Springbootでapplication.ymlの値を取得する方法 Jun 03, 2023 pm 06:43 PM

プロジェクトでは、構成情報が必要になることがよくありますが、この情報はテスト環境と本番環境で構成が異なる場合があり、実際のビジネス状況に基づいて後で変更する必要がある場合があります。これらの構成をコードにハードコーディングすることはできません。構成ファイルに記述することをお勧めします。たとえば、この情報を application.yml ファイルに書き込むことができます。では、コード内でこのアドレスを取得または使用するにはどうすればよいでしょうか?方法は2つあります。方法 1: @Value アノテーションが付けられた ${key} を介して、構成ファイル (application.yml) 内のキーに対応する値を取得できます。この方法は、マイクロサービスが比較的少ない状況に適しています。方法 2: 実際には、プロジェクト、業務が複雑な場合、ロジック

See all articles