数据库–Cobar分布式数据库集群MySQL中间件

╰+攻爆jí腚メ 2022-01-15 02:49 409阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

### 运行环境： ###

*  主机1：Ubuntu14.04 Desktop + MySQL5.5 + JDK 1.7(HP Z400) 内网IP地址:192.168.137.8
 *  NODE1：Ubuntu 13.04 server + MySQL5.5 内网IP地址:192.168.137.31
 *  NODE2：Ubuntu 13.04 server + MySQL5.5 内网IP地址:192.168.137.32

注：(NODE1和NODE2运行于XEN虚拟化平台，硬件环境HP Z800)

## Cobar简介： ##

#### Cobar是关系型数据库的分布式处理系统，它可以在分布式的环境下看上去像传统数据库一样为您提供海量数据服务。 ####

*  产品在阿里巴巴B2B公司已经稳定运行了3年以上。
 *  目前已经接管了3000+个MySQL数据库的schema，为应用提供数据服务。
 *  据最近统计cobar集群目前平均每天处理近50亿次的SQL执行请求。

#### Cobar最主要解决的问题是：分布式和HA。 ####

分布式：主要是通过将同一个表的数据拆分成多个，放入不同的数据库实例，查询的时候也会按照同样的操作方式，来更新具体数据库实例中的对应的数据。

HA：高可用性，在设置了MYSQL心跳的情况下，如果主数据库发生了异常，Cobar会自动连接从数据库，如果主数据库恢复正常，只能手动恢复到主数据库。Cobar只负责切换数据库实例，不负责主从数据库的同步，所以需要提前将主从数据库设置双向同步。

#### 存在的不足: ####

*  (1).不支持跨库情况下的join、分页、排序、子查询操作。
 *  (2).SET语句执行会被忽略，事务和字符集设置除外。
 *  (3).分库情况下，insert语句必须包含拆分字段列名。
 *  (4).分库情况下，update语句不能更新拆分字段的值。
 *  (5).不支持SAVEPOINT操作。
 *  (6).暂时只支持MySQL数据节点。
 *  (7).使用JDBC时，不支持rewriteBatchedStatements=true参数设置(默认为false)。
 *  (8).使用JDBC时，不支持useServerPrepStmts=true参数设置(默认为false)。
 *  (9).使用JDBC时，BLOB, BINARY, VARBINARY字段不能使用setBlob()或setBinaryStream()方法设置参数。

当然，如果想努力实现这些功能，可以fork官方的源码：[https://github.com/alibaba/cobar][https_github.com_alibaba_cobar]

## 环境搭建 ##

*  Cobar服务器：192.168.137.8:8066 用户名/密码：root/sa 实例名：dbtest
 *  主机1:192.168.137.8:3306 用户名/密码：cobar/sa 实例名：dbtest1
 *  Node1:192.168.137.31:3306 用户名/密码：cobar/sa 实例名：dbtest2
 *  Node2:192.168.137.32:3306 用户名/密码：cobar/sa 实例名：dbtest3

Cobar-Server-1.2.7版本下载：[http://pan.baidu.com/s/1pJudQh9][http_pan.baidu.com_s_1pJudQh9]

实验拓扑图如下：

[![cobar][]][cobar 1]

#### 首先分别在三个主机创建数据库实例： ####

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> #创建dbtest1脚本 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> &nbsp;&nbsp;&nbsp;dropdatabaseif exists dbtest1; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> &nbsp;&nbsp;&nbsp;createdatabasedbtest1; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 04 </td> 
   <td> &nbsp;&nbsp;&nbsp;use dbtest1; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 05 </td> 
   <td> &nbsp;&nbsp;&nbsp;#在dbtest1上创建tb1 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 06 </td> 
   <td> &nbsp;&nbsp;&nbsp;createtabletb1( </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 07 </td> 
   <td> &nbsp;&nbsp;&nbsp;id&nbsp;&nbsp; intnotnull, </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 08 </td> 
   <td> &nbsp;&nbsp;&nbsp;gmt&nbsp;&nbsp; datetime); </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 09 </td> 
   <td> #创建dbtest2 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> &nbsp;&nbsp;&nbsp;dropdatabaseif exists dbtest2; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 11 </td> 
   <td> &nbsp;&nbsp;&nbsp;createdatabasedbtest2; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 12 </td> 
   <td> &nbsp;&nbsp;&nbsp;use dbtest2; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 13 </td> 
   <td> &nbsp;&nbsp;&nbsp;#在dbtest2上创建tb2 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 14 </td> 
   <td> &nbsp;&nbsp;&nbsp;createtabletb2( </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 15 </td> 
   <td> &nbsp;&nbsp;&nbsp;id&nbsp;&nbsp; intnotnull, </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 16 </td> 
   <td> &nbsp;&nbsp;&nbsp;val&nbsp;varchar(256)); </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 17 </td> 
   <td> #创建dbtest3 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 18 </td> 
   <td> &nbsp;&nbsp;&nbsp;dropdatabaseif exists dbtest3; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 19 </td> 
   <td> &nbsp;&nbsp;&nbsp;createdatabasedbtest3; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 20 </td> 
   <td> &nbsp;&nbsp;&nbsp;use dbtest3; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 21 </td> 
   <td> &nbsp;&nbsp;&nbsp;#在dbtest3上创建tb2 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 22 </td> 
   <td> &nbsp;&nbsp;&nbsp;createtabletb2( </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 23 </td> 
   <td> &nbsp;&nbsp;&nbsp;id&nbsp;&nbsp; intnotnull, </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 24 </td> 
   <td> &nbsp;&nbsp;&nbsp;val&nbsp;varchar(256)); </td> 
  </tr> 
 </tbody> 
</table>

####  Cobar配置： ####

schema.xml配置如下

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> &lt;!DOCTYPE cobar:schema SYSTEM "schema.dtd"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> &lt;cobar:schemaxmlns:cobar="<a href="http://cobar.alibaba.com/" rel="nofollow">http://cobar.alibaba.com/</a>"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> &nbsp;&nbsp;&lt;!-- schema定义 --&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 04 </td> 
   <td> &nbsp;&nbsp;&lt;schemaname="dbtest"dataNode="dnTest1"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 05 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;tablename="tb2"dataNode="dnTest2,dnTest3"rule="rule1"/&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 06 </td> 
   <td> &nbsp;&nbsp;&lt;/schema&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 07 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 数据节点定义，数据节点由数据源和其他一些参数组织而成。--&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 08 </td> 
   <td> &nbsp;&nbsp;&lt;dataNodename="dnTest1"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 09 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="dataSource"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;dataSourceRef&gt;dsTest[0]&lt;/dataSourceRef&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 11 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 12 </td> 
   <td> &nbsp;&nbsp;&lt;/dataNode&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 13 </td> 
   <td> &nbsp;&nbsp;&lt;dataNodename="dnTest2"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 14 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="dataSource"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 15 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;dataSourceRef&gt;dsTest[1]&lt;/dataSourceRef&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 16 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 17 </td> 
   <td> &nbsp;&nbsp;&lt;/dataNode&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 18 </td> 
   <td> &nbsp;&nbsp;&lt;dataNodename="dnTest3"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 19 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="dataSource"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 20 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;dataSourceRef&gt;dsTest[2]&lt;/dataSourceRef&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 21 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 22 </td> 
   <td> &nbsp;&nbsp;&lt;/dataNode&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 23 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 数据源定义，数据源是一个具体的后端数据连接的表示。--&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 24 </td> 
   <td> &nbsp;&nbsp;&lt;dataSourcename="dsTest"type="mysql"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 25 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="location"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 26 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;location&gt;192.168.137.8:3306/dbtest1&lt;/location&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 27 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;location&gt;192.168.137.31:3306/dbtest2&lt;/location&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 28 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;location&gt;192.168.137.32:3306/dbtest3&lt;/location&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 29 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 30 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="user"&gt;cobar&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 31 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="password"&gt;sa&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 32 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="sqlMode"&gt;STRICT_TRANS_TABLES&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 33 </td> 
   <td> &nbsp;&nbsp;&lt;/dataSource&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 34 </td> 
   <td> &lt;/cobar:schema&gt; </td> 
  </tr> 
 </tbody> 
</table>

server.xml简单配置

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 1 </td> 
   <td> &lt;!DOCTYPE cobar:server SYSTEM "server.dtd"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 2 </td> 
   <td> &lt;cobar:serverxmlns:cobar="<a href="http://cobar.alibaba.com/" rel="nofollow">http://cobar.alibaba.com/</a>"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 3 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 用户访问定义，用户名、密码、schema等信息。 --&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 4 </td> 
   <td> &nbsp;&nbsp;&lt;username="root"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 5 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="password"&gt;sa&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 6 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="schemas"&gt;dbtest&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 8 </td> 
   <td> &lt;/cobar:server&gt; </td> 
  </tr> 
 </tbody> 
</table>

rule.xml配置

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> &lt;!DOCTYPE cobar:rule SYSTEM "rule.dtd"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> &lt;cobar:rulexmlns:cobar="<a href="http://cobar.alibaba.com/" rel="nofollow">http://cobar.alibaba.com/</a>"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 路由规则定义，定义什么表，什么字段，采用什么路由算法 --&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 04 </td> 
   <td> &nbsp;&nbsp;&lt;tableRulename="rule1"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 06 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;columns&gt;val&lt;/columns&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 07 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;algorithm&gt;&lt;![CDATA[ func2(${val}) ]]&gt;&lt;/algorithm&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 09 </td> 
   <td> &nbsp;&nbsp;&lt;/tableRule&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 路由函数定义 --&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 11 </td> 
   <td> &nbsp;&nbsp;&lt;functionname="func1"class="com.alibaba.cobar.route.function.PartitionByLong"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 12 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="partitionCount"&gt;2&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 13 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="partitionLength"&gt;512&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 14 </td> 
   <td> &nbsp;&nbsp;&lt;/function&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 15 </td> 
   <td> &nbsp;&nbsp;&lt;!-- 路由函数定义 --&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 16 </td> 
   <td> &nbsp;&nbsp;&lt;functionname="func2"class="com.alibaba.cobar.route.function.PartitionByString"&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 17 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="partitionCount"&gt;2&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 18 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="partitionLength"&gt;512&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 19 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;&lt;propertyname="hashSlice"&gt;-5:&lt;/property&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 20 </td> 
   <td> &nbsp;&nbsp;&lt;/function&gt; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 21 </td> 
   <td> &lt;/cobar:rule&gt; </td> 
  </tr> 
 </tbody> 
</table>

这里需要说明，INSERT语句中必须包含路由规则定义的字段，否则Cobar不会对数据进行拆分，同时存储到多个数据库实例中，比如上面的tb2表中，id字段如果设置了auto\_increment，插入语句中不用指明id字段，这样就无法达到数据包拆分的目的。

准备完成之后直接运行bin目录下的./startup.sh即可。

然后查看输入的日志：

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> yan@yan-Z400:~/cobar-server-1.2.7/logs$ tail -f stdout.log </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> 09:57:00,155 INFO&nbsp; Cobar is ready to startup ... </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> 09:57:00,155 INFO&nbsp; Startup processors ... </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 04 </td> 
   <td> 09:57:00,198 INFO&nbsp; Startup connector ... </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 05 </td> 
   <td> 09:57:00,202 INFO&nbsp; Initialize dataNodes ... </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 06 </td> 
   <td> 09:57:00,811 INFO&nbsp; dnTest1:0 init success </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 07 </td> 
   <td> 09:57:00,816 INFO&nbsp; dnTest3:0 init success </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 08 </td> 
   <td> 09:57:00,821 INFO&nbsp; dnTest2:0 init success </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 09 </td> 
   <td> 09:57:00,835 INFO&nbsp; CobarManager is started and listening on 9066 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> 09:57:00,837 INFO&nbsp; CobarServer is started and listening on 8066 </td> 
  </tr> 
 </tbody> 
</table>

这样cobar服务端就已经启动。

直接使用jdbc或mysql终端连接cobar：

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> yan@yan-Z400:~$ mysql -uroot -psa -P8066 -h192.168.137.8 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> Welcome to the MySQL monitor.&nbsp; Commands end with ; or \g. </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> Your MySQL connection id is 1 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 04 </td> 
   <td> Server version: 5.1.48-cobar-1.2.7 Cobar Server (ALIBABA) </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 08 </td> 
   <td> Oracle is a registered trademark of Oracle Corporation and/or its </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 09 </td> 
   <td> affiliates. Other names may be trademarks of their respective </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> owners. </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 12 </td> 
   <td> Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. </td> 
  </tr> 
 </tbody> 
</table>

####  下面使用几句Pyhton进行数据库的插入操作： ####

[view source][]

<table> 
 <tbody> 
  <tr> 
   <td> 01 </td> 
   <td> #!/usr/bin/env python </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 02 </td> 
   <td> #coding=utf-8 </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 03 </td> 
   <td> importMySQLdb </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 06 </td> 
   <td> cxn=MySQLdb.Connect(host='192.168.137.8',port=8066, user='root', passwd='sa') </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 08 </td> 
   <td> cur=cxn.cursor() </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 10 </td> 
   <td> cur.execute("USE dbtest") </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 12 </td> 
   <td> foriinrange(1,200): </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 13 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;cur.execute("INSERT INTO tb2 (val) values ('this is a test record %d')"%i) </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 14 </td> 
   <td> &nbsp;&nbsp;&nbsp;&nbsp;print'insert the %d record into cobar'%i&nbsp; </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 16 </td> 
   <td> cur.close() </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 17 </td> 
   <td> cxn.commit() </td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td> 18 </td> 
   <td> cxn.close() </td> 
  </tr> 
 </tbody> 
</table>

插入后查看数据库dbtest2和数据dbtest3的情况：

可以看到有100条数据插入了dbtest2,99条数据插入了dbtest3。

后面会对Cobar进行更深入的了解。我的[Fork分支][Fork]

(完)

转载于:https://my.oschina.net/u/588516/blog/489148

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220114/1d80ff41583a403fa1979728e4a7a2d2.png
[https_github.com_alibaba_cobar]: https://github.com/alibaba/cobar
[http_pan.baidu.com_s_1pJudQh9]: http://pan.baidu.com/s/1pJudQh9
[cobar]: /images/20220114/f15089a4cfcb4102874a19af14b0e4e2.png
[cobar 1]: http://blogimagestore.u.qiniudn.com/wp-content/uploads/2014/04/cobar1.png
[view source]: http://blog.geekcome.com/archives/252#viewSource
[Fork]: https://github.com/yming0221/cobar