配置文件
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的数据同步】
推荐阅读
-
张柏芝早就被绿了?谢霆锋10年后终于公开女儿,原来王菲早已知晓
-
-
月球|开始行动了!NASA登月联盟在月球上发现水,却将中国排除在外
-
华为荣耀|突然宣布!荣耀营销经理退休,引发网友猜疑
-
-
Logo设计也可以二次元化,说不准某些图标的灵感正是来自于二次元
-
世界上最古老的四种文字分别是什么 世界上最古老的六大文字
-
-
招聘|用招聘网站的后台告诉你,为什么你投了几百份简历,很少有人回复
-
无敌改装车▲RR:Type-RR,最强思域FD2!Mugen
-
张爱玲|张爱玲在晚年崇尚“极简主义生活”,并非穷困潦倒,稿费拿到手软
-
AutoR智驾 逆行外卖小哥、深夜拥堵轻松应对,元戎启行自动驾驶汽车挑战“宇宙最强街道”
-
-
-
三十年体坛故事|7连杀+赛季双杀!上港仍是国安梦魇 御林军争冠梦碎?
-
-
教育部|教育部重要通知,2条升学途径被堵死!家长无语:之前努力白费了
-
妻子伺候二婚丈夫五年,继子来医院探望一趟,妻子含泪提出离婚
-
-