老师，我的binlog监听不了

来源：9-3 【先来个栗子】使用开源工具监听 Binlog 的演示

张婧仪

2019-05-23

这是代码

public class BinlogServiceTest {
    public static void main(String[] args) throws IOException {
        BinaryLogClient client=new BinaryLogClient(
                "127.0.0.1",
         3306,"root","123456"
        );
       // client.setBinlogFilename();
        //client.setBinlogPosition();
        client.registerEventListener(event -> {
            EventData data=event.getData();
            if(data instanceof UpdateRowsEventData){
                System.out.println("Update------");
                System.out.println(data.toString());
            }else if(data instanceof WriteRowsEventData){
                System.out.println("Wirte-------");
                System.out.println(data.toString());
            }else if(data instanceof DeleteRowsEventData){
                System.out.println("Delete-------");
                System.out.println(data.toString());
            }
        });
        client.connect();
    }
}

![图片描述](http://img.mukewang.com/szimg/5ce64f8a00011f9314130395.jpg)

写回答

1回答