spring boot集成canal实现数据库同步，且mysql主库宕机canal自动切换到从库

Spring Boot 整合 Canal 实现数据库同步，并在 MySQL 主库宕机时自动切换到从库，可以通过以下步骤实现：

1. 配置 Canal 服务器，确保它能监听到主库的变更事件。
2. 在 Spring Boot 应用中配置 Canal 客户端，连接到 Canal 服务器。
3. 监听 Canal 服务器的变更事件，并在主库宕机时切换到从库。

以下是一个简化的示例代码：

配置 Canal 客户端：

canal:
  host: canal服务器地址
  port: 11111
  destination: example
  username: canal
  password: canal

Canal 监听器配置：

@Component
@Slf4j
public class DataChangeListener {
 
    @Autowired
    private CanalConnector connector;
 
    @PostConstruct
    public void start() {
        connector.connect();
        connector.subscribe();
        new Thread(this::listen).start();
    }
 
    private void listen() {
        while (true) {
            try {
                Message message = connector.getWithoutAck(1024); // 获取指定数量的数据
                long batchId = message.getId();
                if (batchId == -1 || message.getEntries().isEmpty()) {
                    // 没有数据或者已经获取完毕
                    Thread.sleep(1000);
                } else {
                    // 处理数据变更事件
                    for (Entry entry : message.getEntries()) {
                        if (EntryType.ROWDATA == entry.getEntryType()) {
                            // 对事件进行处理
                        }
                    }
                    connector.ack(batchId); // 确认消息已被处理
                }
            } catch (Exception e) {
                log.error("处理数据变更事件失败", e);
            }
        }
    }
}

主库宕机时切换逻辑：

public class CanalClient {
 
    private CanalConnector connector;
 
    public void connect(String host, int port, String destination) {
        connector = new CanalConnector(destination, host, port, "", "");
        connector.connect();
        connector.subscribe();
    }
 
    public void switchToSlave() {
        // 主库宕机时，切换到从库的逻辑
        // 可能需要重新配置连接信息，并重新调用 connect 方法
    }
 
    public void start() {
        while (true) {
            try {
                Message message = connector.getWithoutAck(1024); // 获取指定数量的数据
                if (message.getEntries().is