SpringBoot使用Canal做MySQL与Redis的数据同步

环境：Springboot2.7.8 + MySQL8

1 环境准备

master: 192.168.2.129

slave: 192.168.2.130

使用Docker安装MySQL，这里Docker安装省略，网上一堆教程。

Docker安装完成后，安装MySQL。

安装MySQL

步骤1：

步骤3：完成分别在129，130上完成上面操作。2 主从配置129.168.2.129作为master节点，修改my.cnf配置，追加下面配置：binlog_format=MIXED
 log-bin=mysql-bin
 server-id=1

129.168.2.130作为slave节点，修改my.cnf配置，追加下面配置：

这里的File，Position列再配置从节点时需要用到。3.2 配置从节点执行上面的命令如果报错如下：This operation cannot be performed with a running slave io thread; run STOP SLAVE IO_THREAD FOR CHANNEL '' first.

这时需要执行stop slave

注意：上面的mysql-bin.000003 是首次配置的，如果master节点重启了，这个文件会递增变为mysql-bin.000004，这时我们的从节点会自动连上这mysql-bin.000004

查看从节点状态：

spring:
  redis:
    host: localhost
    port: 6379
    password: 123123
    database: 8
    lettuce:
      pool:
        maxActive: 8
        maxIdle: 100
        minIdle: 10
        maxWait: -1
---
canal:
  server: 192.168.2.130:11111
  destination: redis #可设置*个，逗号隔开，对应需要创建*文件夹，且文件夹下有instance.properties文件

数据模型

public class Users {


  private Integer id ;
  private String name ;
  private Integer age ;
  @Override
  public String toString() {
    return "Users [id=" + id + ", name=" + name + ", age=" + age + "]";
  }
  
}

具体服务组件

@Component
@CanalTable(value = "users")
public class UserServiceImpl implements EntryHandler<Users> {
  
  private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);
  
  private final StringRedisTemplate stringRedisTemplate ;
  
  public UserServiceImpl(StringRedisTemplate stringRedisTemplate) {
    this.stringRedisTemplate = stringRedisTemplate ;
  }


  @Override
  public void insert(Users user) {
    logger.info("新增数据为{}", user);
    try {
      this.stringRedisTemplate.opsForValue().set("users:" + user.getId(), new ObjectMapper().writeValueAsString(user)) ;
    } catch (JsonProcessingException e) {
      e.printStackTrace();
    }
  }


  @Override
  public void update(Users before, Users after) {
    logger.info("原来数据为{}", before);
    logger.info("更新数据为{}", after);
    try {
      this.stringRedisTemplate.opsForValue().set("users:" + after.getId(), new ObjectMapper().writeValueAsString(after)) ;
    } catch (JsonProcessingException e) {
      e.printStackTrace();
    }
  }


  @Override
  public void delete(Users user) {
    logger.info("删除的数据为{}", user);
    this.stringRedisTemplate.delete("users:" + user.getId()) ;
  }


}

以上通过增，删，改数据就能同步到Redis中了。