SpringBoot如何实现Canal与RabbitMQ结合，高效监听数据库变更？

本文共计3698个文字，预计阅读时间需要15分钟。

目录+需求+步骤+环境搭建+canal.properties+instance.properties+修改canal配置文件+整合SpringBoot+Canal实现客户端+Canal整合RabbitMQ+SpringBoot整合RabbitMQ+需求+我想在SpringBoot中采用一种与业务代码解耦的方式

目录

• 需求
• 步骤
• 环境搭建
• canal.properties
• instance.properties
• 修改canal配置文件
• 整合SpringBoot Canal实现客户端
• Canal整合RabbitMQ
• SpringBoot整合RabbitMQ

需求

我想要在SpringBoot中采用一种与业务代码解耦合的方式，来实现数据的变更记录，记录的内容是新数据，如果是更新操作还得有旧数据内容。

经过调研发现，使用Canal来监听MySQL的binlog变化可以实现这个需求，可是在监听到变化后需要马上保存变更记录，除非再做一些逻辑处理，于是我又结合了RabbitMQ来处理保存变更记录的操作。