老师，我的binlog监听不了

Question

这是代码

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://img1.sycdn.imooc.com//szimg/5ce64f8a00011f9314130395.jpg)

Answer 1

张勤一 2019-05-23 19:43:47

同学你好：

    我看到这个错误信息的提示，意思就是 Binlog 监听服务没有连接上 MySQL，或者 MySQL 没有开启 Binlog 造成的错误。解决这个问题，可以考虑以下步骤：

    1. 如果使用 8.0 版本的 MySQL，那么，默认就是开启 Binlog 的，不需要额外操作；如果使用 8.0 之前的版本（5.X），可以参考很多博客完成 Binlog 的开启操作；

    2. 检查 pom 文件中配置的 MySQL 驱动与你当前的 MySQL 版本是否匹配；

    3. 修改 MySQL 之后，需要重启 MySQL 服务器。

    欢迎来 QQ 群随时交流、讨论，也非常感谢同学的支持！