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個文件信息