高可用数据库集群，使用SpringBoot和MyCat实现主从复制-精创网络云防护

帮助文档
高可用数据库集群，使用SpringBoot和MyCat实现主从复制
来源：www.jcwlyf.com浏览：18更新：2025-11-14
在当今的互联网应用中，数据的可靠性和高可用性至关重要。高可用数据库集群是保障数据安全和系统稳定运行的关键技术之一。本文将详细介绍如何使用Spring Boot和MyCat实现数据库的主从复制，构建高可用的数据库集群。
一、高可用数据库集群概述
高可用数据库集群是指通过多个数据库服务器组成一个集群，以实现数据的冗余备份、负载均衡和故障自动切换等功能，确保在部分节点出现故障时，系统仍然能够正常运行。主从复制是高可用数据库集群中常用的一种架构，它将数据从主数据库复制到一个或多个从数据库，主数据库负责处理写操作，从数据库负责处理读操作，从而提高系统的读写性能和可用性。
二、Spring Boot简介
Spring Boot是Spring社区推出的一个用于简化Spring应用开发的框架。它通过自动配置和约定优于配置的原则，使得开发者可以快速搭建和部署Spring应用。Spring Boot提供了丰富的插件和依赖管理，方便集成各种数据库和中间件，为开发高可用的数据库应用提供了便利。
三、MyCat简介
MyCat是一个开源的数据库中间件，它可以将多个数据库实例虚拟成一个逻辑数据库，为应用提供统一的访问接口。MyCat支持主从复制、读写分离、分库分表等功能，能够有效地提高数据库的性能和可用性。通过MyCat，开发者可以将应用与底层数据库解耦，方便进行数据库的扩展和维护。
四、环境准备
在开始实现主从复制之前，需要准备以下环境：
1. 安装MySQL数据库，至少准备一个主数据库和一个从数据库。
2. 安装MyCat中间件。
3. 创建一个Spring Boot项目，可以使用Spring Initializr快速创建。
五、配置MySQL主从复制
1. 配置主数据库
编辑主数据库的配置文件my.cnf，添加以下配置：
```
[mysqld]
server-id = 1
log-bin = mysql-bin
binlog-do-db = your_database_name
```
其中，server-id是数据库的唯一标识，log-bin开启二进制日志，binlog-do-db指定需要复制的数据库。
重启主数据库，创建一个用于复制的用户：
```
CREATE USER 'repl'@'%' IDENTIFIED BY 'password';
GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%';
FLUSH PRIVILEGES;
SHOW MASTER STATUS;
```
记录下File和Position的值，后续配置从数据库时会用到。
2. 配置从数据库
编辑从数据库的配置文件my.cnf，添加以下配置：
```
[mysqld]
server-id = 2
```
重启从数据库，执行以下命令配置从数据库连接主数据库：
```
CHANGE MASTER TO
MASTER_HOST='master_host_ip',
MASTER_USER='repl',
MASTER_PASSWORD='password',
MASTER_LOG_FILE='mysql-bin.xxxxxx',
MASTER_LOG_POS=xxxxxx;
START SLAVE;
SHOW SLAVE STATUS\G;
```
确保Slave_IO_Running和Slave_SQL_Running都为Yes，表示主从复制配置成功。
六、配置MyCat
1. 编辑schema.xml文件
在MyCat的conf目录下找到schema.xml文件，添加以下配置：
```
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
    <table name="your_table_name" dataNode="dn1"/>
</schema>
<dataNode name="dn1" dataHost="localhost1" database="your_database_name"/>
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
    <heartbeat>select user()</heartbeat>
    <writeHost host="hostM1" url="jdbc:mysql://master_host_ip:3306" user="root" password="password">
        <readHost host="hostS1" url="jdbc:mysql://slave_host_ip:3306" user="root" password="password"/>
    </writeHost>
</dataHost>
```
其中，schema定义了逻辑数据库，dataNode定义了数据节点，dataHost定义了数据库主机，writeHost表示主数据库，readHost表示从数据库。
2. 编辑server.xml文件
在MyCat的conf目录下找到server.xml文件，配置用户和权限：
```
<user name="root">
    <property name="password">password</property>
    <property name="schemas">TESTDB</property>
</user>
```
七、Spring Boot集成MyCat
1. 添加依赖
在Spring Boot项目的pom.xml文件中添加MySQL和MyBatis的依赖：
```
<dependencies>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>2.3.1</version>
    </dependency>
</dependencies>
```
2. 配置数据源
在application.properties文件中配置数据源，连接MyCat：
```
spring.datasource.url=jdbc:mysql://mycat_host_ip:8066/TESTDB
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
```
3. 创建实体类和Mapper接口
创建一个简单的实体类和Mapper接口，用于操作数据库：
```
public class User {
    private Long id;
    private String name;
    // getters and setters
}

@Mapper
public interface UserMapper {
    @Select("SELECT * FROM your_table_name WHERE id = #{id}")
    User findById(Long id);

    @Insert("INSERT INTO your_table_name (name) VALUES (#{name})")
    void insert(User user);
}
```
4. 创建Service和Controller
创建Service和Controller类，处理业务逻辑和请求：
```
@Service
public class UserService {
    @Autowired
    private UserMapper userMapper;

    public User findById(Long id) {
        return userMapper.findById(id);
    }

    public void insert(User user) {
        userMapper.insert(user);
    }
}

@RestController
@RequestMapping("/users")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping("/{id}")
    public User findById(@PathVariable Long id) {
        return userService.findById(id);
    }

    @PostMapping
    public void insert(@RequestBody User user) {
        userService.insert(user);
    }
}
```
八、测试主从复制和读写分离
启动Spring Boot项目，使用Postman或其他工具发送请求进行测试。
1. 写操作：发送POST请求到/users，添加一条数据，数据会写入主数据库。
2. 读操作：发送GET请求到/users/{id}，查询数据，MyCat会自动将读请求路由到从数据库。
九、总结
通过使用Spring Boot和MyCat，我们成功实现了数据库的主从复制和读写分离，构建了一个高可用的数据库集群。Spring Boot简化了应用开发的过程，MyCat提供了强大的数据库中间件功能，使得应用可以方便地与多个数据库进行交互。在实际应用中，还可以根据需求进一步扩展和优化数据库集群，如增加从数据库数量、配置故障自动切换等，以提高系统的性能和可用性。