怎样在Java中搭建Canal数据库监听环境

由于Metaspace不足，Canal启动失败需要在JVM参数中设置-XX:MetaspaceSize=256m -XX:MaxMetaspaceSize=512m；远程连接需要配置canalal.IP是服务器的真实IP；由于MySQL权限不足、instance配置错误或TSDB未启用，客户端无法收到数据；字段null主要是由于字符集不匹配或表结构不同步造成的。

Canal服务器启动失败：java.lang.OutOfMemoryError: Metaspace

Canal服务端（canal-server）默认情况下，一旦加载多个表结构或打开全库订阅，使用较小的JVM元空间就会崩溃。这不是配置错误，而是堆外元数据真的不够。

• 进conf/start.sh或bin/startup.bat，在JVM_OPTS里加-XX:MetaspaceSize=256m -XX:MaxMetaspaceSize=512m
• 别只调-Xmx；大量动态生成类(如不同表对应的Entry对象)在Canal分析binlog时，Metaspace才是瓶颈
• 如果你使用Docker，你必须在那里docker run命令里透传 JVM 参数，光改容器start.sh没用

客户端无法连接canal-server：报ConnectException: Connection refused

90% 是服务端没有真正监控到指定的端口，也不是网络不通。默认情况下，Canal监控127.0.0.1:11111，这台机器连接没有问题，但Java客户端在另一台机器上运行必然会失败。

• 检查conf/canal.properties中canal.ip是否为空-留空即绑定127.0.0.1；要进行远程连接，必须将其设置为服务器的真实IP(例如192.168.1.100）
• canal.port更改后，客户端CanalConnector结构参数也必须同步更新，不能硬写11111
• 记得关掉Linux上的防火墙：sudo ufw disable或者放行相应的端口，不要只检查netstat看端口开着就觉得通了。

Java客户端无法收到binlog变更：connector.subscribe()后一直阻塞

Canal客户端不是“注册即收”，必须先定位为合法的binlog位置。如果服务端没有配置MySQL账号权限，或者position已经过期，subscribe()卡住不返回，也不会扔异常。

• MySQL账号必须有SELECT, REPLICATION SLAVE, REPLICATION CLIENT少一个权限会默默失败
• conf/example/instance.properties中的canal.instance.master.address必须写成ip:port格式（如192.168.1.200:3306），不能写localhost或域名(DNS分析失败时) Canal 不报错）
• 在首次启动之前，建议手动执行canal.instance.master.timestamp=0(从当前位点开始)避免因找不到历史binlog文件而停止

解析出来的RowData字段值全是null或类型错乱

Canal本身不读MySQL表结构，而是通过分析binlog中的字段序号 + 客户端本地缓存列表映射填充。一旦表结构发生变化（如添加字段）、或者如果客户端没有触发自动刷新，就会失败。

• 确认canal.instance.tsdb.enable=true并配备Zookeeper或数据库存储，否则表结构只存在于内存中，重启时丢失
• 收到Java客户端EntryType.ROWDATA以后，不要直接使用column.getName()当key取值时，优先使用column.getIndex()对齐原始binlog顺序，然后查看本地schema
• 使用MySQLutf8mb4但 Canal 配置里canal.instance.connectionCharset还是UTF-8（缺mb4），它会导致字符串截断或乱码，看起来像nulll

Canal的坑不是代码怎么写的，而是 MySQL 权限，网络绑定，字符集，TSDB 这四点稍有偏差，整个链路静默失效。调整时不要急着改变客户逻辑，先盯着这四个配置项目。