01-讀寫分離測試案例

来源:https://www.cnblogs.com/OnlyOnYourself-lzw/archive/2022/06/23/16406826.html
-Advertisement-
Play Games

二、讀寫分離案例 2.1、背景介紹 面對日益增加的系統訪問量,資料庫的吞吐量面臨著巨大瓶頸,對於同一時刻有大量併發讀操作和較少寫操作類型的應用系統來說,將資料庫拆分為主庫和從庫,主庫負責處理事務性的增刪改操作,從庫負責處理查詢操作,這樣可以有效地避免由數據更新導致的行鎖,使得整個系統的查詢性能得到極 ...


二、讀寫分離案例

2.1、背景介紹

  • 面對日益增加的系統訪問量,資料庫的吞吐量面臨著巨大瓶頸,對於同一時刻有大量併發讀操作和較少寫操作類型的應用系統來說,將資料庫拆分為主庫和從庫主庫負責處理事務性的增刪改操作,從庫負責處理查詢操作這樣可以有效地避免由數據更新導致的行鎖,使得整個系統的查詢性能得到極大的改善(通過讀寫分離,就可以降低單台資料庫的訪問壓力,提高訪問效率,也可以避免單機故障)

2.2、ShardingJDBC介紹

  • Sharding-JDBC定位為輕量級Java框架,在Java的JDBC層提供的額外服務。 它使用客戶端直連資料庫,以jar包形式提供服務,無需額外部署和依賴,可理解為增強版的JDBC驅動,完全相容JDBC和各種ORM框架。

    • 使用Sharding-JDBC可以在程式中輕鬆的實現資料庫讀寫分離
  • Sharding-JDBC的特點

    • ①、 適用於任何基於JDBC的ORM框架,如:JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC
    • ②、支持任何第三方的資料庫連接池,如:DBCP, C3P0, BoneCP, Druid, HikariCP等
    • ③、支持任意實現JDBC規範的資料庫。目前支持MySQL,Oracle,SQLServer,PostgreSQL以及任何遵循SQL92標準的資料庫
  • 導入Sharding-JDBC依賴

    • <dependency>
          <groupId>org.apache.shardingsphere</groupId>
          <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
          <version>4.0.0-RC1</version>
      </dependency>
      

2.3、測試工程創建

2.3.1、數據準備

  • CREATE DATABASE tb_user;
    
    USE tb_user;
    
    CREATE TABLE t_user(
    NAME VARCHAR(30),
    sex CHAR,
    location VARCHAR(50)
    )ENGINE = INNODB DEFAULT CHARSET=utf8;
    
    INSERT INTO t_user VALUES
    ('h1', 'm', '廣州'),
    ('h2', 'w', '深圳'),
    ('h3', 'm', '上海'),
    ('h4', 'w', '北京'),
    ('h5', 'w', '蘇州');
    

2.3.1、簡易SpringBoot項目搭建

  • Step1:初始項目結構如下所示

  • Step2:編寫基本的增刪改查業務操作

    • 編寫業務操作之前,添加資料庫連接的相關pom配置和yml配置

    • pom坐標導入

      • <?xml version="1.0" encoding="UTF-8"?>
        <project xmlns="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>com.coolman</groupId>
            <artifactId>HelloWorld</artifactId>
            <version>1.0-SNAPSHOT</version>
        
            <properties>
                <maven.compiler.source>8</maven.compiler.source>
                <maven.compiler.target>8</maven.compiler.target>
            </properties>
        
            <!--導入父模塊-->
            <parent>
                <artifactId>spring-boot-starter-parent</artifactId>
                <groupId>org.springframework.boot</groupId>
                <version>2.3.3.RELEASE</version>
            </parent>
        
            <dependencies>
                <!--        SpringBoot啟動器-->
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-web</artifactId>
                </dependency>
        
                <!--lombok配置-->
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                </dependency>
        
                <!--mysql驅動-->
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>5.1.46</version>
                </dependency>
        
                <!--mybatis啟動器-->
                <dependency>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-boot-starter</artifactId>
                    <version>2.2.0</version>
                </dependency>
        
                <!--資料庫連接池-->
                <dependency>
                    <groupId>com.alibaba</groupId>
                    <artifactId>druid-spring-boot-starter</artifactId>
                    <version>1.1.23</version>
                </dependency>
        
                <!--讀寫分離:ShardingJDBC-->
        
            </dependencies>
        
            <build>
                <!--指定打包後jar的名字-->
                <finalName>helloWorld</finalName>
                <plugins>
                    <plugin>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-maven-plugin</artifactId>
                    </plugin>
                </plugins>
            </build>
        
        </project>
        
    • yml配置文件編寫

      • spring:
          datasource:
            driver-class-name: com.mysql.jdbc.Driver
            url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
            username: root
            password: root
        
        mybatis:
          type-aliases-package: com.coolman.model   #
          configuration:
            log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
            map-underscore-to-camel-case: true
          mapper-locations:
            - classpath:mappers/*.xml
        
        server:
          port: 80
        
        
    • 編寫業務操作代碼

      • package com.coolman.controller;
        
        import com.coolman.model.User;
        import com.coolman.service.UserService;
        import lombok.extern.slf4j.Slf4j;
        import org.springframework.beans.factory.annotation.Autowired;
        import org.springframework.web.bind.annotation.*;
        
        import java.util.List;
        
        @RestController
        @Slf4j
        public class HelloWorldController {
        
            @Autowired
            private UserService userService;
        
            @GetMapping("/hello")
            public String sayHello() {
                log.info("==========hahhhhhhhhhhhhhhhhh=========");
                return "hello coolman";
            }
        
            // 查詢
            @GetMapping("/select")
            public List<User> selectAll() {
        
                return userService.selectAll();
            }
        
            // 增加
            @PostMapping ("/add")
            public String add(@RequestBody User user) {
        
                userService.add(user);
        
                return "添加成功,User = " + user;
            }
        
            // 刪除
            @DeleteMapping("/delete")
            public String delete(Integer id) {
                userService.delete(id);
                return "刪除成功, id = " + id;
            }
        
            // 修改
            @PutMapping("/edit")
            public String edit(@RequestBody User user) {
                userService.edit(user);
                return user + "";
            }
        }
        
        
  • Step3:介面測試

    • 這裡就不過多地演示,上述代碼可以正常運行

2.3.3、引入Sharding-JDBC,並測試

  • Step1:在pom文件中增加sharding-jdbc的maven坐標

    •         <!--讀寫分離:ShardingJDBC-->
              <dependency>
                  <groupId>org.apache.shardingsphere</groupId>
                  <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
                  <version>4.0.0-RC1</version>
              </dependency>
      
  • Step2:在application.yml文件中增加數據源的配置

    • #spring:
      #  datasource:
      #    driver-class-name: com.mysql.jdbc.Driver
      #    url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
      #    username: root
      #    password: root
      
      spring:
        shardingsphere:
          datasource:
            names: master,slave
            # 主數據源
            master:
              type: com.alibaba.druid.pool.DruidDataSource
              dirver-class-name: com.mysql.jdbc.Driver
              url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
              username: root
              password: root
            #從數據源
            slave:
              type: com.alibaba.druid.pool.DruidDataSource
              dirver-class-name: com.mysql.jdbc.Driver
              url: jdbc:mysql://192.168.222.140:3306/tb_user?useSSL=false&characterEncoding=UTF-8
              username: root
              password: root
          masterslave:
            # 讀寫分離配置
            load-balance-algorithm-type: round_robin  # 輪詢負載均衡
            # 最終的數據源名稱
            name: dataSource
            # 主資料庫的名稱
            master-data-source-name: master
            slave-data-source-names: slave
          props:
            sql:
              show: true  # 開啟SQL顯示,預設為false
      
      
      
      mybatis:
        type-aliases-package: com.coolman.model   #
        configuration:
          log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
          map-underscore-to-camel-case: true
        mapper-locations:
          - classpath:mappers/*.xml
      
      server:
        port: 80
      
      
    • 配置解析

  • Step3:在application.yml中增加配置

    • spring:
        main:
          # 該配置項的目的,就是如果當前項目中存在同名的bean,後定義的bean會覆蓋先定義的。
          # 如果不配置該項,項目啟動之後會報錯
          allow-bean-definition-overriding: true
      
  • Step4:測試

    • 添加數據
    • 修改數據
    • 刪除數據
    • 查詢數據

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • TinyMCE是一款易用、且功能強大的所見即所得的富文本編輯器。同類程式有:UEditor、Kindeditor、Simditor、CKEditor、wangEditor、Suneditor、froala等等。 配置靈活,界面簡潔,支持自定義插件。 TinyMCE中文手冊:http://tinymc ...
  • 一、前言 小編最近開始學習typescript,懂得人都知道,typescript是vue3的基礎伴生,配合更加默契。就像vue2和js一樣!typescript不像js那樣瀏覽器直接可以解讀,需要我們把ts文件編譯成js文件,這樣瀏覽器才可以解讀。所以我們要安裝一下ts的環境和自動編譯,方便我們後 ...
  • 前言 : 組件系統是Vue.js其中一個重要的概念,它提供了一種抽象,讓我們可以使用獨立可復用的小組件來構建大型應用,任意類型的應用界面都可以抽象為一個組件樹。 現在基於vue的UI組件庫有很多,比如iview,element-ui等。但有時候這些組件庫滿足不了我們的開發需求,這時候我們就需要自己寫 ...
  • 1 前言 在嵌入式MCU軟體開發過程中,程式分層設計也是重中之重,關係到整個軟體開發過程中的協同開發,降低系統軟體的複雜度(複雜問題分解)和依賴關係、同時有利於標準化,便於管理各層的程式,提高各層邏輯的復用等。 2 分層介紹 2.1 硬體抽象層(HAL) 嵌入式開發的核心就是晶元,它提供固定的片內資 ...
  • 目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • 前言 回歸分析就是用於預測輸入變數(自變數)和輸出變數(因變數)之間的關係,特別當輸入的值發生變化時,輸出變數值也發生改變!回歸簡單來說就是對數據進行擬合。線性回歸就是通過線性的函數對數據進行擬合。機器學習並不能實現預言,只能實現簡單的預測。我們這次對房價關於其他因素的關係。 波士頓房價預測 下載相 ...
  • 迎面走來了你的面試官,身穿格子衫,挺著啤酒肚,髮際線嚴重後移的中年男子。 手拿泡著枸杞的保溫杯,胳膊夾著MacBook,MacBook上還貼著公司標語:“我愛加班”。 面試開始,直入正題。 面試官: 你知道MySQL索引底層數據結構為啥用B+樹?而不用B樹、紅黑樹或者普通二叉樹? 我: 這事誰知道作 ...
  • 簡介 是什麼? 確保應用能夠在這些環境中運行和通過質量檢測.並且在部署過程中不出現令人頭疼的版本、配置問題,也無需重新編寫代碼和進行故障修複. Docker之所以發展如此迅速,也是因為它對此給出了一個標準化的解決方案 系統平滑移植,容器虛擬化技術。 解決了運行環境和配置問題的軟體容器,方便做持續集成 ...
一周排行
    -Advertisement-
    Play Games
  • 用例演示 - 創建實體 本節將演示一些示例用例並討論可選場景。 創建實體 從實體/聚合根類創建對象是實體生命周期的第一步。聚合/聚合根規則和最佳實踐部分 建議為Entity類創建一個主構造函數,以保證創建一個有效的實體。因此,無論何時我們需要創建實體的實例,我們都應該使用那個構造函數 參見下麵的問題 ...
  • 領域邏輯 & 應用邏輯 如前所述,領域驅動設計中的業務邏輯分為兩部分(層):領域邏輯和應用邏輯: 領域邏輯由系統的核心領域規則組成,應用邏輯實現應用特定的用例 雖然定義很明確,但實現起來可能並不容易。您可能無法決定哪些代碼應該位於應用程式層,哪些代碼應該位於領域層。本節試圖解釋其中的差異 多個應用程 ...
  • 表弟大學快畢業了,學了一個學期Python居然還不會寫學生管理系統,真的給我丟臉啊,教他又不肯學,還讓我直接給他寫,我真想兩巴掌上去,最終還是寫了給他,誰讓他是我表弟呢,關鍵時候還是得幫他一把! 寫完了放在那也是放著,所以今天分享給大家吧! 話不多說,咱們直接開始吧! 代碼解析 一、登錄頁面 1、定 ...
  • Zookeeper3.7源碼剖析 能力目標 掌握Zookeeper中Session的管理機制 能基於Client進行Debug測試Session創建/刷新操作 能搭建Zookeeper集群源碼配置 掌握集群環境下Leader選舉啟動過程 能說出Zookeeper選舉過程中的概念 能說出Zookeep ...
  • 前言 今天給大家分享一下我自己寫的筆記,純純的都是乾貨,關於字好像也能看。這是我學python整理出來的一些資料,希望對大家 有用。想要更多的資料那就的給一個關註了… python學習交流Q群:903971231### #導入Counter from collections import Count ...
  • Hi,大家好,我是Mic 一個工作5年的粉絲找到我。 他說: “Mic老師,你要是能回答出這個問題,我就佩服你” 我當場就懵了,現在打賭都這麼隨意了嗎? 我問他問題是什麼,他說“Kafka如何避免重覆消費的問題!” 下麵看看普通人和高手的回答! 普通人: Kafka怎麼避免重覆消費就是我們可以通過 ...
  • 前言 Steam是由美國電子游戲商Valve於2003年9月12日推出的數字發行平臺,被認為是電腦游戲界最大的數位發行平臺之一,Steam平臺是全球最大的綜合性數字發行平臺之一。玩家可以在該平臺購買、下載、討論、上傳和分享游戲和軟體。 而每周的steam會開啟了一輪特惠,可以讓游戲打折,而玩家就會 ...
  • 本篇內容將在上一篇已有的內容基礎上,進一步的聊一下項目中使用JPA的一些高階複雜場景的實踐指導,覆蓋了主要核心的JPA使用場景,可以讓你在需求開發的時候對JPA的使用更加的游刃有餘。 ...
  • 1.路徑處理 1.找模塊:sys.path import sys print(sys.path) - 1.理解 - 1.是python去查找包或模塊 - 2.項目開始根目錄,python內置的目錄 - 3.雖然說python的安裝目錄下也可以存放我們寫的模塊,但是不建議(太多了,不大好找) - 4. ...
  • Go 語言入門練手項目系列 01 基於命令行的圖書的增刪查改 02 文件管理 持續更新中... > 本文來自博客園,作者:Arway,轉載請註明原文鏈接:https://www.cnblogs.com/cenjw/p/gobeginner-proj-bookstore-cli.html 介紹 這是一 ...