java解析mysql binlog

import com.github.shyiko.mysql.binlog.BinaryLogClient;
import com.github.shyiko.mysql.binlog.event.Event;
import com.github.shyiko.mysql.binlog.event.EventType;
import com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer;

public class BinlogParser {
    public static void main(String[] args) {
        String hostname = "localhost";
        int port = 3306;
        String username = "root";
        String password = "password";
        String binlogFilename = "mysql-bin.000001";

        EventDeserializer eventDeserializer = new EventDeserializer();
        eventDeserializer.setCompatibilityMode(
            EventDeserializer.CompatibilityMode.CHAR_AND_BINARY,
            EventDeserializer.CompatibilityMode.CHAR_AND_BINARY,
            EventDeserializer.CompatibilityMode.CHAR
        );

        BinaryLogClient client = new BinaryLogClient(hostname, port, username, password);
        client.setBinlogFilename(binlogFilename);
        client.setEventDeserializer(eventDeserializer);

        client.registerEventListener(event -> {
            EventType eventType = event.getHeader().getEventType();
            System.out.println("Event type: " + eventType);
            // 根据不同的事件类型处理事件
        });

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