canal与spring整合demo

canal与spring整合demo，整合内容包含服务方，消费方 canal消费方采用策略模式，将不同表的数据分配到相应的Process类中。定义BaseProcess抽象类，包含processInsert、processUpdate、processDelete三个抽象方法，分别用于处理三种类型的数据操作。

package com.scy.canal.client;

import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.protocol.Message;
import com.alibaba.otter.canal.protocol.CanalEntry.Column;
import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
import com.alibaba.otter.canal.protocol.CanalEntry.EventType;
import com.alibaba.otter.canal.protocol.CanalEntry.RowChange;
import com.alibaba.otter.canal.protocol.CanalEntry.RowData;
import com.scy.canal.entity.CanalRowChange;
import com.scy.canal.process.baseProcess;

/**
 * 数据消费
 * @author suicy
 *
 */
public class CanalConsumer {

    private static final Logger logger = LoggerFactory.getLogger（CanalConsumer.class）;

    //数据处理类key为表名，value为对应的处理类
    private MapseProcess> proce

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        1364  2017-09-19 16:23  canalDemo\.classpath
     文件        1085  2017-09-05 09:43  canalDemo\.project
     文件         639  2017-09-05 09:39  canalDemo\.settings\.jsdtscope
     文件         153  2017-09-06 17:14  canalDemo\.settings\org.eclipse.core.resources.prefs
     文件         430  2017-09-05 09:39  canalDemo\.settings\org.eclipse.jdt.core.prefs
     文件          90  2017-09-05 09:39  canalDemo\.settings\org.eclipse.m2e.core.prefs
     文件         756  2017-09-19 14:40  canalDemo\.settings\org.eclipse.wst.common.component
     文件         252  2017-09-05 09:44  canalDemo\.settings\org.eclipse.wst.common.project.facet.core.xml
     文件          49  2017-09-05 09:39  canalDemo\.settings\org.eclipse.wst.jsdt.ui.superType.container
     文件           6  2017-09-05 09:39  canalDemo\.settings\org.eclipse.wst.jsdt.ui.superType.name
     文件          50  2017-09-05 09:39  canalDemo\.settings\org.eclipse.wst.validation.prefs
     文件        8115  2017-09-19 16:37  canalDemo\pom.xml
     文件        6308  2017-09-21 14:43  canalDemo\src\main\java\com\scy\canal\client\CanalConsumer.java
     文件        1061  2017-09-19 17:06  canalDemo\src\main\java\com\scy\canal\entity\CanalRowChange.java
     文件        1773  2017-09-19 17:06  canalDemo\src\main\java\com\scy\canal\entity\DateConverter.java
     文件        1101  2017-09-19 17:12  canalDemo\src\main\java\com\scy\canal\entity\Goods.java
     文件        3149  2017-09-21 14:52  canalDemo\src\main\java\com\scy\canal\process\baseProcess.java
     文件        1571  2017-09-21 13:48  canalDemo\src\main\java\com\scy\canal\process\GoodsProcess.java
     文件        2087  2017-09-21 14:31  canalDemo\src\main\java\com\scy\canal\server\CanalServer.java
     文件         773  2017-09-20 14:36  canalDemo\src\main\resources\dbinstance\A1\instance.properties
     文件        1767  2017-09-19 14:28  canalDemo\src\main\resources\log4j.xml
     文件        2590  2017-09-20 14:28  canalDemo\src\main\resources\props\canal.properties
     文件         850  2017-09-21 14:44  canalDemo\src\main\resources\spring\spring-config-canal-client.xml
     文件        9214  2017-09-20 14:43  canalDemo\src\main\resources\spring\spring-config-canal-instance.xml
     文件         527  2017-09-06 17:21  canalDemo\src\main\resources\spring\spring-config-canal-server.xml
     文件        1321  2017-09-20 14:55  canalDemo\src\main\resources\spring-config.xml
     文件         919  2017-09-21 11:18  canalDemo\src\main\webapp\WEB-INF\web.xml
     文件         418  2017-09-05 09:41  canalDemo\src\main\webapp\index.jsp
     文件         267  2017-09-20 14:54  canalDemo\src\test\java\canalDemo\Test.java
     文件        1777  2017-09-21 13:51  canalDemo\src\test\resource\log4j.xml
     文件        2319  2017-09-21 14:43  canalDemo\target\classes\com\scy\canal\client\CanalConsumer$1.class
............此处省略20个文件信息