如何通过实时更新获取数据库新增数据
问题：
用户需要及时获取 MySQL 表中的新增数据，以便通过短信发送给指定号码。传统的方法是通过服务器计划任务每 30 秒读取数据库，但这会增加服务器负担并延迟获取数据。
解决方案：
使用 MySQL Binary Log (Binlog) 和 Canal
-
打开 MySQL 的 Binlog：
- 在 my.cnf 文件中，找到 binlog-do-db 和 binlog-ignore-db 选项，并将其设置为指定要记录的数据库。
- 确保 Binlog 已打开，并通过 SHOW MASTER LOGS 命令验证。
-
安装 Canal：
- Canal 是一个开源组件，用于订阅 MySQL 的 Binlog。
- 在服务器上安装 Canal，并按照其文档进行配置。
-
配置 Canal 订阅 Binlog：
-
打开 Canal 的配置文件 canal.properties，并配置以下内容：
- canal.destinations=example
- canal.app.destination.example.dw.dbAddress=localhost (数据库地址)
- canal.app.destination.example.dw.dbPort=3306 (数据库端口)
- canal.app.destination.example.dw.dbUsername=root (数据库用户名)
- canal.app.destination.example.dw.dbPassword=password (数据库密码)
- canal.app.destination.example.dw.database=mysql (要订阅的数据库名称)
- canal.app.destination.example.dw.table=tbl_name (要订阅的表名称)
-
-
启动 Canal 服务：
- 运行 sh bin/startup.sh 命令启动 Canal。
-
实现 PHP 监听器：
- 编写一个 PHP 监听器，连接到 Canal 并处理 Binlog 事件。
- 当收到新增数据的 Binlog 事件时，监听器会提取数据并发送短信。
通过上述方法，可以实现实时获取数据库新增数据的需求，无需使用计划任务，并且可以减少服务器负担。
