配置文件
spring:redis:host: localhostport: 6379password: 123123database: 8lettuce:pool:maxActive: 8maxIdle: 100minIdle: 10maxWait: -1---canal:server: 192.168.2.130:11111destination: redis #可设置*个,逗号隔开 , 对应需要创建*文件夹,且文件夹下有instance.properties文件数据模型
public class Users {private Integer id ;private String name ;private Integer age ;@Overridepublic String toString() {return "Users [id=" + id + ", name=" + name + ", age=" + age + "]";}}具体服务组件
@Component@CanalTable(value = https://www.isolves.com/it/cxkf/jiagou/2023-09-26/"users")public class UserServiceImpl implements EntryHandler {private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);private final StringRedisTemplate stringRedisTemplate ;public UserServiceImpl(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate ;}@Overridepublic void insert(Users user) {logger.info("新增数据为{}", user);try {this.stringRedisTemplate.opsForValue().set("users:" + user.getId(), new ObjectMApper().writeValueAsString(user)) ;} catch (JsonProcessingException e) {e.printStackTrace();}}@Overridepublic 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();}}@Overridepublic void delete(Users user) {logger.info("删除的数据为{}", user);this.stringRedisTemplate.delete("users:" + user.getId()) ;}}以上通过增,删 , 改数据就能同步到Redis中了 。
【在SpringBoot中通过Canal实现MySQL与Redis的数据同步】
推荐阅读
-
环球网以蚊子为灵感 科学家研发能躲避障碍的感知系统
-
|痛心!太子奶创始人自曝男性“耻辱”之事,力证凌娅为“双面人”
-
-
-
『操作系统』反讽!一个虚构的国产操作系统被吹上知乎热榜:浮夸会害了科技创新
-
打造“江西智造”新名片,赛特智能助力江西全省工业强省推进大会胜利召开
-
-
-
于九野|微软Win10电脑可以原生跑安卓App了!首批支持手机出炉
-
国字脸适合什么样的发型图片女,国字脸剪什么发型最好看-
-
-
-
-
-
【】世卫组织警告:没有哪个国家可以假装疫情已经结束
-
-
「重庆武隆人行道垮塌行人掉入坑中」重庆武隆人行道垮塌行人掉入坑中
-
央视新闻客户端|北京通报6月30日新增3例确诊病例情况:均居住于大兴区
-
-
小盆栽3种水果籽别扔,处理一下种盆里,长成小盆栽,美极了!