chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Updated ClientAPI (markdown)

agapple
2013-10-28 23:45:16 -07:00
parent 0c5482dfd5
commit f6c4dbec6a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ClientAPI.md

@@ -98,12 +98,12 @@ Column
<p> </p> <p> </p>
<div class="iteye-blog-content-contain"> <div class="iteye-blog-content-contain">
<h3>1. 创建Connector</h3> <h3>1. 创建Connector</h3>
<p>1. 创建SimpleCanalConnector (直连ip，不支持server/client的failover机制)</p> <p>a. 创建SimpleCanalConnector (直连ip，不支持server/client的failover机制)</p>
<pre class="java" name="code">CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(AddressUtils.getHostIp(),11111), destination, "", "");</pre> <pre class="java" name="code">CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(AddressUtils.getHostIp(),11111), destination, "", "");</pre>
</div> </div>
<div class="iteye-blog-content-contain">2. 创建ClusterCanalConnector (基于zookeeper获取canal server ip，支持server/client的failover机制) <div class="iteye-blog-content-contain">b. 创建ClusterCanalConnector (基于zookeeper获取canal server ip，支持server/client的failover机制)
<pre class="java" name="code">CanalConnector connector = CanalConnectors.newClusterConnector("10.20.144.51:2181", destination, "", "");</pre> <pre class="java" name="code">CanalConnector connector = CanalConnectors.newClusterConnector("10.20.144.51:2181", destination, "", "");</pre>
3. 创建ClusterCanalConnector (基于固定canal server的地址，支持固定的server ip的failover机制，不支持client的failover机制</div> c. 创建ClusterCanalConnector (基于固定canal server的地址，支持固定的server ip的failover机制，不支持client的failover机制</div>
<div class="iteye-blog-content-contain"> <div class="iteye-blog-content-contain">
<pre class="java" name="code">CanalConnector connector = CanalConnectors.newClusterConnector(Arrays.asList(new InetSocketAddress(AddressUtils.getHostIp(),11111)), destination,"", "");</pre> <pre class="java" name="code">CanalConnector connector = CanalConnectors.newClusterConnector(Arrays.asList(new InetSocketAddress(AddressUtils.getHostIp(),11111)), destination,"", "");</pre>
<p> </p> <p> </p>