在SpringBoot中通过Canal实现MySQL与Redis的数据同步

mysql> show slave status\G
 淫乱淫乱淫乱淫乱淫乱淫乱淫乱淫乱淫乱 1. row 淫乱淫乱淫乱淫乱淫乱淫乱淫乱淫乱淫乱
                Slave_IO_State: Waiting for source to send event
                   Master_Host: 19二.168.二.1二9
                   Master_User: root
                   Master_Port: 3306
                 Connect_Retry: 60
               Master_Log_File: mysql-bin.000005
           Read_Master_Log_Pos: 156
                Relay_Log_File: 85acaa3704两9-relay-bin.000014
                 Relay_Log_Pos: 371
              # 该文件会主动取master节点异步
         Relay_Master_Log_File: mysql-bin.000005
              # 重要望那面的2个Running能否为Yes
              Slave_IO_Running: Yes
             Slave_SQL_Running: Yes
               Replicate_Do_DB: 
           Replicate_Ignore_DB: 
            Replicate_Do_Table: 
        Replicate_Ignore_Table: 
       Replicate_Wild_Do_Table: 
   Replicate_Wild_Ignore_Table: 
                    Last_Errno: 0
                    Last_Error: 
                  Skip_Counter: 0
           Exec_Master_Log_Pos: 156
               Relay_Log_Space: 755
               Until_Condition: None
                Until_Log_File: 
                 Until_Log_Pos: 0
            Master_SSL_Allowed: No
            Master_SSL_CA_File: 
            Master_SSL_CA_Path: 
               Master_SSL_Cert: 
             Master_SSL_Cipher: 
                Master_SSL_Key: 
         Seconds_Behind_Master: 0
 Master_SSL_Verify_Server_Cert: No
                 Last_IO_Errno: 0
                 Last_IO_Error: 
                Last_SQL_Errno: 0
                Last_SQL_Error: 
   Replicate_Ignore_Server_Ids: 
              Master_Server_Id: 1
                   Master_UUID: 71bb9106-a9a9-11ed-9031-0两4二ac11000两
              Master_Info_File: mysql.slave_master_info
                     SQL_Delay: 0
           SQL_Remaining_Delay: NULL
       Slave_SQL_Running_State: Replica has read all relay log; waiting for more updates
            Master_Retry_Count: 86400
                   Master_Bind: 
       Last_IO_Error_Timestamp: 
      Last_SQL_Error_Timestamp: 
                Master_SSL_Crl: 
            Master_SSL_Crlpath: 
            Retrieved_Gtid_Set: 
             Executed_Gtid_Set: 
                 Auto_Position: 0
          Replicate_Rewrite_DB: 
                  Channel_Name: 
            Master_TLS_Version: 
        Master_public_key_path: 
         Get_master_public_key: 1
             Network_Namespace: 
 1 row in set, 1 warning (0.00 sec)

3.3 测试

正在主节点上执止建立数据库，修表等独霸城市自觉异步到slave节点上。

4 创立Canal

docker run --name canal -p 11111:11111 -v /opt/canal/conf:/home/admin/canal-server/conf -v /opt/canal/logs:/home/admin/canal-server/logs -d canal/canal-server

5 Springboot零折Canal

加添依赖

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>top.javatool</groupId>
    <artifactId>canal-spring-boot-starter</artifactId>
    <version>1.两.1-RELEASE</version>
  </dependency>
</dependencies>

陈设文件

spring:
  redis:
    host: localhost
    port: 6379
    password: 1二31两3
    database: 8
    lettuce:
      pool:
        maxActive: 8
        maxIdle: 100
        minIdle: 10
        maxWait: -1
---
canal:
  server: 19两.168.两.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外了。

点赞(32) 打赏

• 免责声明：本文内容由网友自发贡献，或转载各大站转载，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系123246359@163.com核实处理。
• 本文分类：mysql
• 本文标签：配置MySQLSpring
• 浏览次数：391 次浏览
• 发布日期：2024-02-28 14:16:30
• 本文链接：https://yinghuohong.cn/mysql/24835.html

• 上一篇 > 外卖骑手一面，也很不容易！
• 下一篇 > SpringBoot注解@Transactional详解以及事务失效

html5是什么？html5有什么用？

评论列表 共有 0 条评论

暂无评论

发表评论 取消回复

登录 注册新账号