Javaでバイナリログをリッスンするにはどうすれば良いですか？

2年 ago
綾乃, 一希
1 minute

MySQLのbinlogリスナーを利用することで、binlogログをリッスンできます。以下はJavaを使用してbinlogログをリッスンする1つの例です。

  1. まず、MySQLのJavaドライバをプロジェクトに追加する必要があります。最新のバージョンはMySQLの公式サイトからダウンロードできますし、Maven依存関係を通じて取得することもできます。
  2. MySQL の binlog リスニングライブラリ（例: “mysql-binlog-connector-java”）を使用して、binlog ログの変更をリッスンする Java クラスを作成します。
import java.io.IOException;
import com.github.shyiko.mysql.binlog.BinaryLogClient;
import com.github.shyiko.mysql.binlog.event.Event;
import com.github.shyiko.mysql.binlog.event.EventListener;
import com.github.shyiko.mysql.binlog.event.EventType;

public class BinlogListener {

    public static void main(String[] args) throws IOException {
        BinaryLogClient client = new BinaryLogClient("localhost", 3306, "username", "password");
        client.registerEventListener(new EventListener() {
            public void onEvent(Event event) {
                EventType eventType = event.getHeader().getEventType();
                // 处理不同类型的事件
                switch (eventType) {
                    case EXT_WRITE_ROWS:
                    case EXT_UPDATE_ROWS:
                    case EXT_DELETE_ROWS:
                    case WRITE_ROWS:
                    case UPDATE_ROWS:
                    case DELETE_ROWS:
                        System.out.println(event.toString());
                        break;
                }
            }
        });
        client.connect();
    }
}

上記のコード内では、localhost、3306、username、passwordを、お使いのMySQLデータベースのホスト、ポート、ユーザー名、パスワードに書き換えてください。

  1. 以上のコードを実行すると、MySQL データベースに接続し、binlog ログの変更を監視します。新しい書き込み、更新、または削除の操作が発生すると、関連するイベント情報が出力されます。

binlog 監視には適切な権限設定が必要で、現在実行中の MySQL インスタンスの binlog ログのみを監視できることに注意してください。複数の MySQL インスタンスまたはマスタースレーブ複製環境がある場合は、それぞれのインスタンスの binlog ログを個別に監視する必要があります。

bannerAds