ToB企服应用市场:ToB评测及商务社交产业平台

标题: 01-读写分离测试案例 [打印本页]

---

作者: 愛在花開的季節    时间: 2022-8-9 14:42
标题: 01-读写分离测试案例
二、读写分离案例

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依赖
  
  
  
  • 1. <dependency>
    2.     <groupId>org.apache.shardingsphere</groupId>
    3.     <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    4.     <version>4.0.0-RC1</version>
    5. </dependency>

    复制代码
  
  

2.3、测试工程创建

2.3.1、数据准备

• 1. CREATE DATABASE tb_user;
  3. USE tb_user;
  5. CREATE TABLE t_user(
  6. NAME VARCHAR(30),
  7. sex CHAR,
  8. location VARCHAR(50)
  9. )ENGINE = INNODB DEFAULT CHARSET=utf8;
  11. INSERT INTO t_user VALUES
  12. ('h1', 'm', '广州'),
  13. ('h2', 'w', '深圳'),
  14. ('h3', 'm', '上海'),
  15. ('h4', 'w', '北京'),
  16. ('h5', 'w', '苏州');

  复制代码

2.3.1、简易SpringBoot项目搭建

• Step1：初始项目结构如下所示
  
  
  
  • 
    
  
  
• Step2：编写基本的增删改查业务操作
  
  
  
  • 编写业务操作之前，添加数据库连接的相关pom配置和yml配置
    
  • pom坐标导入
    
    
    
    • 1. <?xml version="1.0" encoding="UTF-8"?>
      2. <project xmlns="http://maven.apache.org/POM/4.0.0"
      3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5.     <modelVersion>4.0.0</modelVersion>
      7.     <groupId>com.coolman</groupId>
      8.     <artifactId>HelloWorld</artifactId>
      9.     <version>1.0-SNAPSHOT</version>
      11.     <properties>
      12.         <maven.compiler.source>8</maven.compiler.source>
      13.         <maven.compiler.target>8</maven.compiler.target>
      14.     </properties>
      16.    
      17.     <parent>
      18.         <artifactId>spring-boot-starter-parent</artifactId>
      19.         <groupId>org.springframework.boot</groupId>
      20.         <version>2.3.3.RELEASE</version>
      21.     </parent>
      23.     <dependencies>
      24.         
      25.         <dependency>
      26.             <groupId>org.springframework.boot</groupId>
      27.             <artifactId>spring-boot-starter-web</artifactId>
      28.         </dependency>
      30.         
      31.         <dependency>
      32.             <groupId>org.projectlombok</groupId>
      33.             <artifactId>lombok</artifactId>
      34.         </dependency>
      36.         
      37.         <dependency>
      38.             <groupId>mysql</groupId>
      39.             <artifactId>mysql-connector-java</artifactId>
      40.             <version>5.1.46</version>
      41.         </dependency>
      43.         
      44.         <dependency>
      45.             <groupId>org.mybatis.spring.boot</groupId>
      46.             <artifactId>mybatis-spring-boot-starter</artifactId>
      47.             <version>2.2.0</version>
      48.         </dependency>
      50.         
      51.         <dependency>
      52.             <groupId>com.alibaba</groupId>
      53.             <artifactId>druid-spring-boot-starter</artifactId>
      54.             <version>1.1.23</version>
      55.         </dependency>
      57.         
      59.     </dependencies>
      61.     <build>
      62.         
      63.         <finalName>helloWorld</finalName>
      64.         <plugins>
      65.             <plugin>
      66.                 <groupId>org.springframework.boot</groupId>
      67.                 <artifactId>spring-boot-maven-plugin</artifactId>
      68.             </plugin>
      69.         </plugins>
      70.     </build>
      72. </project>

      复制代码
    
    
  • yml配置文件编写
    
    
    
    • 1. spring:
      2.   datasource:
      3.     driver-class-name: com.mysql.jdbc.Driver
      4.     url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
      5.     username: root
      6.     password: root
      8. mybatis:
      9.   type-aliases-package: com.coolman.model   #
      10.   configuration:
      11.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
      12.     map-underscore-to-camel-case: true
      13.   mapper-locations:
      14.     - classpath:mappers/*.xml
      16. server:
      17.   port: 80

      复制代码
    
    
  • 编写业务操作代码
    
    
    
    • 1. package com.coolman.controller;
      3. import com.coolman.model.User;
      4. import com.coolman.service.UserService;
      5. import lombok.extern.slf4j.Slf4j;
      6. import org.springframework.beans.factory.annotation.Autowired;
      7. import org.springframework.web.bind.annotation.*;
      9. import java.util.List;
      11. @RestController
      12. @Slf4j
      13. public class HelloWorldController {
      15.     @Autowired
      16.     private UserService userService;
      18.     @GetMapping("/hello")
      19.     public String sayHello() {
      20.         log.info("==========hahhhhhhhhhhhhhhhhh=========");
      21.         return "hello coolman";
      22.     }
      24.     // 查询
      25.     @GetMapping("/select")
      26.     public List<User> selectAll() {
      28.         return userService.selectAll();
      29.     }
      31.     // 增加
      32.     @PostMapping ("/add")
      33.     public String add(@RequestBody User user) {
      35.         userService.add(user);
      37.         return "添加成功，User = " + user;
      38.     }
      40.     // 删除
      41.     @DeleteMapping("/delete")
      42.     public String delete(Integer id) {
      43.         userService.delete(id);
      44.         return "删除成功， id = " + id;
      45.     }
      47.     // 修改
      48.     @PutMapping("/edit")
      49.     public String edit(@RequestBody User user) {
      50.         userService.edit(user);
      51.         return user + "";
      52.     }
      53. }

      复制代码
    
    
  
  
• Step3：接口测试
  
  
  
  • 这里就不过多地演示，上述代码可以正常运行
    
  
  

2.3.3、引入Sharding-JDBC，并测试

• Step1：在pom文件中增加sharding-jdbc的maven坐标
  
  
  
  • 1.         
    2.         <dependency>
    3.             <groupId>org.apache.shardingsphere</groupId>
    4.             <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    5.             <version>4.0.0-RC1</version>
    6.         </dependency>

    复制代码
  
  
• Step2：在application.yml文件中增加数据源的配置
  
  
  
  • 1. #spring:
    2. #  datasource:
    3. #    driver-class-name: com.mysql.jdbc.Driver
    4. #    url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
    5. #    username: root
    6. #    password: root
    8. spring:
    9.   shardingsphere:
    10.     datasource:
    11.       names: master,slave
    12.       # 主数据源
    13.       master:
    14.         type: com.alibaba.druid.pool.DruidDataSource
    15.         dirver-class-name: com.mysql.jdbc.Driver
    16.         url: jdbc:mysql://192.168.222.135:3306/tb_user?useSSL=false&characterEncoding=UTF-8
    17.         username: root
    18.         password: root
    19.       #从数据源
    20.       slave:
    21.         type: com.alibaba.druid.pool.DruidDataSource
    22.         dirver-class-name: com.mysql.jdbc.Driver
    23.         url: jdbc:mysql://192.168.222.140:3306/tb_user?useSSL=false&characterEncoding=UTF-8
    24.         username: root
    25.         password: root
    26.     masterslave:
    27.       # 读写分离配置
    28.       load-balance-algorithm-type: round_robin  # 轮询负载均衡
    29.       # 最终的数据源名称
    30.       name: dataSource
    31.       # 主数据库的名称
    32.       master-data-source-name: master
    33.       slave-data-source-names: slave
    34.     props:
    35.       sql:
    36.         show: true  # 开启SQL显示，默认为false
    40. mybatis:
    41.   type-aliases-package: com.coolman.model   #
    42.   configuration:
    43.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    44.     map-underscore-to-camel-case: true
    45.   mapper-locations:
    46.     - classpath:mappers/*.xml
    48. server:
    49.   port: 80

    复制代码
  • 配置解析
    
    
    
    • 
      
    
    
  
  
• Step3：在application.yml中增加配置
  
  
  
  • 1. spring:
    2.   main:
    3.     # 该配置项的目的,就是如果当前项目中存在同名的bean,后定义的bean会覆盖先定义的。
    4.     # 如果不配置该项，项目启动之后会报错
    5.     allow-bean-definition-overriding: true

    复制代码
  
  
• Step4：测试
  
  
  
  • 添加数据
    
    
    
    • 
      
    
    
  • 修改数据
    
    
    
    • 
      
    
    
  • 删除数据
    
    
    
    • 
      
    
    
  • 查询数据
    
    
    
    • 
      
    
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4