php如何读取binlog

PHP如何读取MySQL Binlog：实现数据变更追踪与同步

在MySQL数据库中，Binlog（Binary Log）是记录所有数据变更操作（增删改）的二进制日志文件，常用于数据恢复、主从复制和实时数据同步，PHP作为广泛使用的后端语言，有时需要直接读取Binlog以实现业务逻辑（如变更审计、实时数据处理等），本文将详细介绍PHP读取MySQL Binlog的原理、方法及实践步骤。

Binlog基础：为什么能被读取？

Binlog记录了MySQL的“写操作”（DML和DDL），以事件（Event）的形式按顺序存储，每个事件包含操作类型、时间、影响的数据等信息,常见的Binlog事件包括：

• QUERY_EVENT：普通SQL语句（如INSERT、UPDATE）；
• TABLE_MAP_EVENT：表结构映射；
• WRITE_ROWS_EVENT/UPDATE_ROWS_EVENT/DELETE_ROWS_EVENT：行级变更数据；
• XID_EVENT：事务标识符。

要读取Binlog,需满足两个前提：

1. MySQL已开启Binlog：在MySQL配置文件（my.cnf或my.ini）中设置：

   [mysqld]
   log-bin=mysql-bin          # 开启Binlog，文件前缀为mysql-bin
   binlog-format=ROW          # 格式建议用ROW（记录行变更，非SQL语句）
   server-id=1                # 服务器唯一ID（主从复制必需）

   配置后重启MySQL，通过SHOW VARIABLES LIKE 'log_bin';确认是否开启。

2. 具备足够权限：需授予REPLICATION SLAVE权限（用于读取Binlog）：

   GRANT REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'binlog_reader'@'%' IDENTIFIED BY 'password';

PHP读取Binlog的常见方法

PHP读取Binlog的核心思路是“连接MySQL并解析Binlog文件”,目前主要有三种实现方式：

方法1：使用MySQL原生函数（简单但功能有限）

PHP的MySQL扩展（如mysqli）提供了直接读取Binlog的函数mysqli_binlog_read()，但该函数底层依赖MySQL客户端库，且仅支持解析特定版本的Binlog事件，灵活性较低,适合简单场景。

示例代码：

<?php
$mysqli = new mysqli('localhost', 'root', 'password', 'mysql');
if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}
// 获取最新Binlog文件列表
$result = $mysqli->query("SHOW MASTER LOGS");
$logs = $result->fetch_all(MYSQLI_ASSOC);
$latestLog = end($logs)['Log_name']; // mysql-bin.000003
// 读取Binlog事件（需指定文件名和位置）
$binlogPath = "/var/lib/mysql/" . $latestLog; // Binlog文件物理路径（需确保PHP有读取权限）
$event = $mysqli->binlog_read($binlogPath, 4); // 参数4表示读取事件类型（需查阅文档）
if ($event) {
    echo "事件类型: " . $event->type . "\n";
    echo "事件数据: " . bin2hex($event->data) . "\n";
}
$mysqli->close();
?>

注意：mysqli_binlog_read()需要PHP编译时启用mysqli扩展，且对Binlog事件的解析能力有限,无法直接获取行级变更数据。

方法2：调用MySQL命令行工具（推荐，功能完整）

通过PHP的exec()或shell_exec()函数调用MySQL提供的mysqlbinlog工具（需MySQL客户端安装），这是最灵活的方式，支持解析所有Binlog事件类型,并能输出格式化数据。

步骤1：安装mysqlbinlog工具

在Linux服务器上,通常通过MySQL客户端包安装：

# CentOS/RHEL
sudo yum install mysql-community-client
# Ubuntu/Debian
sudo apt-get install mysql-client

步骤2：PHP调用mysqlbinlog并解析输出

mysqlbinlog支持多种输出格式（如--raw输出二进制、--base64-output=decode-rows输出可读行事件），结合PHP的进程流解析,可实现高效读取。

示例代码：

<?php
$host = 'localhost';
$user = 'binlog_reader';
$pass = 'password';
$binlogFile = 'mysql-bin.000003'; // Binlog文件名（通过SHOW MASTER LOGS获取）
$startPos = 4; // 起始位置（从4开始跳过文件头）
// 构建mysqlbinlog命令
$command = sprintf(
    "mysqlbinlog --start-position=%d --base64-output=decode-rows -R -h%s -u%s -p%s %s",
    $startPos,
    $host,
    $user,
    $pass,
    $binlogFile
);
// 执行命令并获取输出
$handle = popen($command, 'r');
if (!$handle) {
    die("无法执行mysqlbinlog命令");
}
// 逐行解析输出
while (!feof($handle)) {
    $line = fgets($handle);
    if (strpos($line, '#') === 0) {
        continue; // 跳过注释行
    }
    // 解析行级变更事件（示例：匹配INSERT语句）
    if (preg_match('/### INSERT INTO `(.+)` VALUES \((.+)\)/', $line, $matches)) {
        $table = $matches[1];
        $values = $matches[2];
        echo "表: {$table}, 变更数据: {$values}\n";
    }
}
pclose($handle);
?>

输出示例：

表: test.users, 变更数据: (1, 'Alice', 'alice@example.com')
表: test.users, 变更数据: (2, 'Bob', 'bob@example.com')

优势：mysqlbinlog功能强大，支持时间范围过滤（--start-datetime）、GTID（--include-gtids）等,适合生产环境。

方法3：使用第三方库（封装底层细节，适合快速开发）

社区中已有成熟的PHP库封装了Binlog读取逻辑，例如php-binlog-reader（需通过Composer安装），无需关心底层命令或二进制格式,直接调用API即可获取变更数据。

步骤1：安装库

composer require mersenne-binlog/php-binlog-reader

步骤2：使用库读取Binlog

示例代码：

<?php
require 'vendor/autoload.php';
use MersenneBinlog\Reader\BinlogReader;
use MersenneBinlog\Reader\Event\RowEvent;
$reader = new BinlogReader('localhost', 'binlog_reader', 'password', '3306');
$reader->setBinlogFile('mysql-bin.000003');
$reader->setStartPosition(4); // 从指定位置开始
// 遍历Binlog事件
foreach ($reader->read() as $event) {
    if ($event instanceof RowEvent) {
        $table = $event->getTable();
        $database = $event->getDatabase();
        $action = $event->getAction(); // INSERT/UPDATE/DELETE
        $rows = $event->getRows(); // 行级数据
        echo "数据库: {$database}, 表: {$table}, 操作: {$action}\n";
        foreach ($rows as $row) {
            echo "  行数据: " . json_encode($row) . "\n";
        }
    }
}
?>

优势：代码简洁，无需处理命令行输出或二进制解析,适合快速集成。

实践案例：实时同步Binlog到Redis

假设需求是将MySQL的test.users表的变更实时同步到Redis,实现步骤如下：

确认Binlog配置

确保MySQL已开启ROW格式Binlog,并记录当前Binlog文件和位置：

SHOW MASTER STATUS;

输出示例：

+------------------+----------+--------------+------------------+-------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+------------------+----------+--------------+------------------+-------------------+
| mysql-bin.000003 | 154      |              |                  |                   |
+------------------+----------+--------------+------------------+-------------------+

编写PHP同步脚本

使用mysqlbinlog方式实现，通过pcntl扩展实现守护进程（监听Binlog新增）。

<?php
class BinlogSyncer {
    private $host;
    private $user;
    private $pass;
    private $redis;
    private $binlogFile;
    private $binlogPos;
    public function __construct($host, $user, $pass, $redisHost) {
        $this->host = $host;
        $this->user = $user;
        $this->pass = $