Canal installation configuration

Download resources

link ：https://pan.baidu.com/s/1wKqJ0VypFxKd6WnJxIoEqg

Extraction code ：wrmf

To configure Mysql

newly build canal library

CREATE USER canal IDENTIFIED BY 'canal';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'canal'@'%';
FLUSH PRIVILEGES;

Unzip to directory

> tar -xf canal.deployer-1.1.5-SNAPSHOT.tar.gz -C /pandora/soft/canal-1.1.5

Modify the configuration file

> vi /pandora/soft/canal-1.1.5/conf/canal.properties

#  Set database instance 
canal.destinations = oidd

> cp -R example/ oidd

> cd /pandora/soft/canal-1.1.5/conf/oidd

> vi instance.properties

#  Database address to be monitored 
canal.instance.master.address=127.0.0.1:30000

#  Database user name 
canal.instance.dbUsername = canal
#  Database password 
canal.instance.dbPassword = canal
#  Specify the database that needs to be synchronized 
canal.instance.defaultDatabaseName = oidd
#  Specify encoding method 
canal.instance.connectionCharset = UTF-8 

start-up Canal

> cd /pandora/soft/cannal-1.1.5/bin
> ./startup.sh

open Canal Sample project run

Modify the parameters ：IP port database user name password

package com.alibaba.otter.canal.example;

import java.net.InetSocketAddress;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.common.utils.AddressUtils;

/**
 *  Test example of stand-alone mode 
 *
 * @author jianghang 2013-4-15  Afternoon 04:19:20
 * @version 1.0.4
 */
public class SimpleCanalClientTest extends AbstractCanalClientTest {

    public SimpleCanalClientTest(String destination) {
        super(destination);
    }

    public static void main(String[] args) {
        //  according to ip, Create links directly , nothing HA The function of 

        String destination = "oidd";
        String ip = "106.13.73.198";
        Integer port = 11111;
        String userName = "canal";
        String password = "canal";

        CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(ip, port),
                destination,
                userName,
                password);

        final SimpleCanalClientTest clientTest = new SimpleCanalClientTest(destination);
        clientTest.setConnector(connector);
        clientTest.start();
        Runtime.getRuntime().addShutdownHook(new Thread() {

            public void run() {
                try {
                    logger.info("## stop the canal client");
                    clientTest.stop();
                } catch (Throwable e) {
                    logger.warn("##something goes wrong when stopping canal:", e);
                } finally {
                    logger.info("## canal client is down.");
                }
            }

        });
    }

}

Create new table

use oidd;


CREAETE TABLE ***

You can see the latest LOG