canal是阿里巴巴团队基于数据库日志增量订阅&消费的框架，项目中我们经常使用Spring来集成管理其它框架，本文讲述自定义spring xsd schema的方式配置集成canal到Spring容器.
项目地址：http://git.oschina.net/damivip/spring-xsd-canal
使用canal可以清楚的知道数据库记录的IUD的具体内容。
-
新增：可解析出新增数据的字段和内容
-
删除：可解析出删除数据的行所有内容
-
更新：可解析出更新记录前后的字段内容，和更新的字段是哪些
-
1.应用场景：
B2C网站更新订单（用户下单/退单），订单业务相关的其他非实时服务需要被通知。
常规方式是B2C使用消息中间件通知其他服务，当DBA因特殊情况直接更改数据库数据时，其他服务就无法得到此消息，而使用canal能知道所有来自数据库的更改，无需其他服务通知，完全的业务解耦。
2.配置预览
自己写了一个简单的spring xsd schema，简化canal配置，如下：
<config:canal-config
id="singleCanalClient"
destination="example"
fetchSize="1"
host="localhost:2181,localhost:2182,localhost:2183" hostType="zkCluster">
<!-- 处理所有库表IUD-->
<config:globalInvoke value="globalCanalInvoke"/>
<config:tableInvoke>
<!-- 指定数据库database表tableName 暂不支持通配符方式-->
<config:invoke database="test" tableName="user">
<config:bean ref="globalCanalInvoke"/>
</config:invoke>
</config:tableInvoke>
</config:canal-config>
hostType 可选：
-
socketCluster：socket集群方式
-
zkCluster：zookeeper集群方式
-
single：但服务器方
destination字段对应canal服务配置中的instance名字；
fetchSize 表示尝试拿记录条数
globalInvoke 所有数据库表IDU操作时，执行globalInvoke制定的javaBean方法
tableInvoke 制定数据库和表执行IDU操作时，调用特定javaBean的方法
3. 测试用例
@Test
public void testStartClient() throws Exception {
String xml = "classpath:conf/applicationContext.xml";
ApplicationContext context = new ClassPathXmlApplicationContext(new String[] { xml });
System.out.println(context.getBean("singleCanalClient"));
System.in.read();
}