census/sql

一个用来解析binlog的到sql的包

1.3.4 2021-03-05 09:43 UTC

Requires

• php: >=7.3.0
• illuminate/console: ^5.5|^6.0|^7.0|^8.0
• illuminate/database: ^5.5|^6.0|^7.0|^8.0
• illuminate/filesystem: ^5.5|^6.0|^7.0|^8.0
• illuminate/support: ^5.5|^6.0|^7.0|^8.0
• krowinski/php-mysql-replication: ^7.0
• predis/predis: ^1.1

Requires (Dev)

• phpunit/phpunit: ~7

MIT

• guoshipeng

README

一个用来解析binlog的到sql的包，主要是之前准备用binlog做恢复的操作，但是后来没有找到合适的插件，有考虑过有考虑过用ali的canal，这个功能介绍的很全，但是使用起来会有些问题，服务端可以跑起来，但是 做数据同步的时候一直有问题，php的客户端没什么问题。可以正常获取到数据。后来找到 krowinski/php-mysql-replication 包，准备加点数据处理的功能在里面。

安装

$ composer require census/sql -vvv

运行环境要求

- PHP 7.3+
- Mysql 5.7+

使用

基于Laravel框架，在Commands目录下，新建命令BinlogConsumer，代码如下：

    namespace App\Console\Commands\BinlogWatcher;
    
    use Illuminate\Console\Command;
    use Parse\Sql\Binlog;
    use Parse\Sql\Exceptions\Exception;
    use Parse\Sql\Exceptions\InvalidArgumentException;
    use Parse\Sql\Exceptions\InvalidInstanceException;
    
    class BinlogConsumer extends Command
    {
        protected $signature = 'binlog-consumer';
    
        // 命令描述信息
        protected $description = '监听binlog日志服务';
    
        public function handle()
        {
            try {
                (new Binlog(config('sys.binlogConsumer')))->watcher();
            } catch (Exception $exception) {
                $message = $exception->getMessage();
    
                // 参数异常捕获
                if ($exception instanceof InvalidArgumentException) {
                    $message = '参数异常:' . $message . PHP_EOL;
                }
    
                // 实例化异常捕获
                if ($exception instanceof InvalidInstanceException) {
                    $message = '实例化异常:' . $message . PHP_EOL;
                }
    
                echo $message;
            }
        }
    
    }

如果打算用supervisorctl来执行上面的脚本的话，会有问题，因为上面的程序执行后本身就是守护进程 所以通过nohup方式运行： nohup php artisan binlog-consumer > /var/log/binlog-operate.log 2>&1 &

建议

License

MIT