Canal 直接在laravel里面安装使用了

# 安装组件canal-php

 composer require xingwenge/canal_php

# 编写脚本监听

<?php

 

namespace App\\\\Console\\\\Commands;

use xingwenge\\\\canal_php\\\\CanalClient;

use xingwenge\\\\canal_php\\\\CanalConnectorFactory;

use xingwenge\\\\canal_php\\\\Fmt;

use Illuminate\\\\Console\\\\Command;

 

ini_set('display_errors', 'On');

error_reporting(E_ALL);

class CanalDemo extends Command

{

    /**

     * The name and signature of the console command.

     *

     * @var string

     */

    protected $signature = 'CanalDemo';

 

    /**

     * The console command description.

     *

     * @var string

     */

    protected $description = '测试canal';

 

    /**

     * Create a new command instance.

     *

     * @return void

     */

    public function __construct()

    {

        parent::__construct();

    }

 

    /**

     * Execute the console command.

     *

     * @return mixed

     */

    public function handle()

    {

        try {

            $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SOCKET_CLUE);

            # $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SWOOLE);

 

            $client->connect("172.17.0.5", 11111);//此处修改为自己的配置

            $client->checkValid();

            $client->subscribe("1001", "test", ".*\\\\\\\\..*");//对应启动容器时test的队列名

            while (true) {

                $message = $client->get(100);

                if ($entries = $message->getEntries()) {

                    foreach ($entries as $entry) {

                        Fmt::println($entry);

                    }

                }

                sleep(1);

            }

 

            $client->disConnect();

        } catch (\\\\Exception $e) {

            echo $e->getMessage(), PHP_EOL;

        }

 

    }

 

}