實現(xiàn)監(jiān)聽Mysql-binlog

<dependency>
    <groupId>com.github.shyiko</groupId>
    <artifactId>mysql-binlog-connector-java</artifactId>
    <version>0.21.0</version>
</dependency>

BinaryLogClient logClient = new BinaryLogClient( "127.0.0.1", 3306, "root", "123456" );

logClient.registerEventListener(event -> {
    EventData data = event.getData();
    //如果日志是更新記錄
    if(data instanceof UpdateRowsEventData){
        System.out.println("update");
    }else if(data instanceof WriteRowsEventData){
        //寫操作
        System.out.println("write");
    }else if(data instanceof DeleteRowsEventData){
            //刪除操作
        System.out.println("delete");

    }
});

logClient.connect();