如何通過Java監聽MySQL資料的變化

log-bin=mysql-bin #[必須]啟用二-進位制紀錄檔
server-id=100 #[必須]伺服器唯一ID，如果是用於多臺MySQL，ID不要重複就行
binlog-format = ROW #這句也得加，下面解釋

        <dependency>
            <groupId>com.zendesk</groupId>
            <artifactId>mysql-binlog-connector-java</artifactId>
            <version>0.27.1</version> <!--2022.09.17版的-->
        </dependency>

//為什麼甚至路徑都一樣，還是com.github.shyiko.***，
// 因為com.zendesk這個包，裡面包了個com.github.shyiko.***這玩意，我懷疑是收購關係
import com.github.shyiko.mysql.binlog.BinaryLogClient;
import com.github.shyiko.mysql.binlog.event.*;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;

//此類可以監控MySQL庫資料的增刪改
@Component
@Slf4j  //用於列印紀錄檔
//在SpringBoot中，提供了一個介面：ApplicationRunner。
//該介面中，只有一個run方法，他執行的時機是：spring容器啟動完成之後，就會緊接著執行這個介面實現類的run方法。
public class MysqlBinLogClient implements ApplicationRunner {

    @Override
    public void run(ApplicationArguments args) throws Exception {
        //專案啟動完成連線bin-log
        new Thread(() -> {
            connectMysqlBinLog();
        }).start();

    }

    /**
     * 連線mysqlBinLog
     */
    public void connectMysqlBinLog() {
        log.info("監控BinLog服務已啟動");

        //自己MySQL的資訊。host，port，username，password
        BinaryLogClient client = new BinaryLogClient("localhost", 3306, "root", "root");
        /**因為binlog不是以資料庫為單位劃分的，所以監控binglog不是監控的單個的資料庫，而是整個當前所設定連線的MySQL，
         *其中任何一個庫發生資料增刪改，這裡都能檢測到，
         *所以不用設定所監控的資料庫的名字(我也不知道怎麼設定，沒發現有包含這個形參的建構函式)
         *如果需要只監控指定的資料庫，可以看後面程式碼，可以獲取到當前發生變更的資料庫名稱。可以根據名稱來決定是否監控
         **/

        client.setServerId(100); //和自己之前設定的server-id保持一致，但是我不知道為什麼不一致也能成功

//下面直接照抄就行
        client.registerEventListener(event -> {
            EventData data = event.getData();
            if (data instanceof TableMapEventData) {
                //只要連線的MySQL發生的增刪改的操作，則都會進入這裡，無論哪個資料庫

                TableMapEventData tableMapEventData = (TableMapEventData) data;

                //可以通過轉成TableMapEventData類範例的tableMapEventData來獲取當前發生變更的資料庫
                System.out.println("發生變更的資料庫："+tableMapEventData.getDatabase());

                System.out.print("TableID:");
                //表ID
                System.out.println(tableMapEventData.getTableId());
                System.out.print("TableName:");
                //表名字
                System.out.println(tableMapEventData.getTable());
            }
            //表資料發生修改時觸發
            if (data instanceof UpdateRowsEventData) {
                System.out.println("Update:");
                System.out.println(data.toString());
                //表資料發生插入時觸發
            } else if (data instanceof WriteRowsEventData) {
                System.out.println("Insert:");
                System.out.println(data.toString());
                //表資料發生刪除後觸發
            } else if (data instanceof DeleteRowsEventData) {
                System.out.println("Delete:");
                System.out.println(data.toString());
            }
        });

        try {
            client.connect();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}