MySQL 5.6.13 GTID复制，以及基于Amoeba实现读写分离

一、MySQL 5.6介绍

MySQL 5.6引入的GTID(Global Transaction IDs)使得其复制功能的配置、监控及管理变得更加易于实现，且更加健壮。

复制功能的改进：

1、支持多线程复制，指的是针对每个database开启相应的独立线程。

2、支持启用GTID，就是每个mysql服务器都一个全局的事务ID，GTID，这个是由每个服务器的UUID（唯一的）和server_id组成的，mysql会保证事务与GTID之间1:1的映射，保证了GTID的全局唯一性。

二、Amoeba介绍

Amoeba是一个SQL请求的路由器，可以为mysql提供负载均衡、读写分离、高可用性提供机制，用户需要结合使用MySQL的Replication等机制来实现副本同步等功能，它主要在应用层访问MySQL的时候充当query 路由功能，专注分布式数据库 proxy 开发，座落与Client、DB Server(s)之间，对客户端透明，它是一个虚拟的mysql，对外提供mysql协议，客户端连接amoeba就象连接mysql一样。

Amoeba主要优势：

1、数据切分后复杂数据源整合；

2、提供数据切分规则并降低数据切分规则给数据库带来的影响；

3、降低数据库与客户端连接；

4、读写分离路由。

Amoeba不足：

1、不支持事务；

2、不支持存储过程；

3、不适合从amoeba导数据的场景或者对大数据量查询的query并不合适；

4、不支持分库分表，amoeba只支持分数据库实例，每个被切分的节点需要保持库表结构一致。

三、实验环境

192.168.30.115 OS：CentOS 6.4 x86_64 amoeba.luojianlong.com

192.168.30.116 OS：CentOS 6.4 x86_64 master.luojianlong.com

192.168.30.117 OS：CentOS 6.4 x86_64 slave.luojianlong.com

MySQL version：mysql-5.6.13-linux-glibc2.5-x86_64

Amoeba version：amoeba-mysql-binary-2.1.0-RC5

拓扑图如下：

首先，分别在master.luojianlong.com和slave.luojianlong.com上安装mysql 5.6.13，这里使用通用的二进制包来安装

<code>[root@master ~]</code><code># useradd -r -u 27 mysql</code>

<code>[root@master ~]</code><code># tar zxvf mysql-5.6.13-linux-glibc2.5-x86_64.tar.gz -C /usr/local/</code>

<code>[root@master ~]</code><code># cd /usr/local/</code>

<code>[root@master </code><code>local</code><code>]</code><code># ln -s mysql-5.6.13-linux-glibc2.5-x86_64 mysql</code>

<code>[root@master </code><code>local</code><code>]</code><code># cd mysql</code>

<code>[root@master mysql]</code><code># mkdir /mydata/data -p</code>

<code>[root@master mysql]</code><code># chown -R root.mysql ./*</code>

<code>[root@master mysql]</code><code># chown -R mysql.mysql /mydata/data/</code>

<code>[root@master mysql]</code><code># ./scripts/mysql_install_db --user=mysql --datadir=/mydata/data</code>

<code>[root@master mysql]</code><code># cp support-files/mysql.server /etc/rc.d/init.d/mysqld</code>

<code>[root@master mysql]</code><code># chkconfig --add mysqld</code>

<code>[root@master mysql]</code><code># chkconfig mysqld on</code>

<code>[root@master mysql]</code><code># chmod +x /etc/rc.d/init.d/mysqld</code>

<code>[root@master ~]</code><code># vi /etc/profile.d/mysql.sh</code>

<code>export</code> <code>PATH=</code><code>/usr/local/mysql/bin</code><code>:$PATH</code>

<code>[root@master ~]</code><code># . /etc/profile.d/mysql.sh</code>

<code># 由于mysql 5.6版本默认的配置文件配置参数很少，需要自己定制，为了方便，这里使用mysql 5.5的配置文件</code>

<code>[root@master mysql]</code><code># cp my-large.cnf /etc/my.cnf</code>

<code>[root@master mysql]</code><code># vi /etc/my.cnf</code>

<code># 在[mysqld]中添加如下</code>

<code>datadir = </code><code>/mydata/data</code>

<code>innodb_file_per_table = 1</code>

<code>binlog-</code><code>format</code><code>=ROW</code>

<code>log-bin=master-bin</code>

<code>log-slave-updates=</code><code>true</code>

<code>enforce-gtid-consistency=</code><code>true</code>

<code>master-info-repository=TABLE</code>

<code>relay-log-info-repository=TABLE</code>

<code>sync</code><code>-master-info=1</code>

<code>slave-parallel-workers=2</code>

<code>binlog-checksum=CRC32</code>

<code>master-verify-checksum=1</code>

<code>slave-sql-verify-checksum=1</code>

<code>binlog-rows-query-log_events=1</code>

<code>server-</code><code>id</code><code>=1</code>

<code>report-port=3306</code>

<code>report-host=192.168.30.116</code>

在slave.luojianlong.com中也使用相同的方式安装mysql 5.6

<code># 安装完成后，修改配置文件</code>

<code>[root@slave ~]</code><code># vi /etc/my.cnf</code>

<code>server-</code><code>id</code><code>=11</code>

<code>log-bin=mysql-bin.log</code>

<code>datadir=</code><code>/mydata/data</code>

<code>report-host=192.168.30.117</code>

binlog-format：二进制日志的格式，有row、statement和mixed几种类型；

需要注意的是：当设置隔离级别为READ-COMMITED必须设置二进制日志格式为ROW，现在MySQL官方认为STATEMENT这个已经不再适合继续使用；但mixed类型在默认的事务隔离级别下，可能会导致主从数据不一致；

log-slave-updates、gtid-mode、enforce-gtid-consistency、report-port和report-host：用于启动GTID及满足附属的其它需求；

master-info-repository和relay-log-info-repository：启用此两项，可用于实现在崩溃时保证二进制及从服务器安全的功能；

sync-master-info：启用之可确保无信息丢失；

slave-paralles-workers：设定从服务器的SQL线程数；0表示关闭多线程复制功能；

binlog-checksum、master-verify-checksum和slave-sql-verify-checksum：启用复制有关的所有校验功能；

binlog-rows-query-log-events：启用之可用于在二进制日志记录事件相关的信息，可降低故障排除的复杂度；

log-bin：启用二进制日志，这是保证复制功能的基本前提；

server-id：同一个复制拓扑中的所有服务器的id号必须惟一；

分别启动俩台服务器的mysql

<code>[root@master ~]</code><code># service mysqld start</code>

<code>Starting MySQL............ SUCCESS!</code>

<code>[root@slave ~]</code><code># service mysqld start</code>

<code>Starting MySQL... SUCCESS!</code>

在master服务器上创建复制用户

<code>mysql> grant replication slave on *.* to </code><code>'repluser'</code><code>@</code><code>'192.168.30.%'</code> <code>identified by </code><code>'123456'</code><code>;</code>

<code>Query OK, 0 rows affected (0.06 sec)</code>

<code>mysql> flush privileges;</code>

<code>Query OK, 0 rows affected (0.00 sec)</code>

启动从节点的复制线程

<code>mysql> change master to master_host=</code><code>'192.168.30.116'</code><code>, master_user=</code><code>'repluser'</code><code>, master_password=</code><code>'123456'</code><code>, master_auto_position=1;</code>

<code>Query OK, 0 rows affected, 2 warnings (0.45 sec)</code>

<code>mysql> start slave;</code>

<code>Query OK, 0 rows affected, 1 warning (0.12 sec)</code>

在slave上查看线程启动情况

<code>mysql> show slave status\G;</code>

<code> </code><code>Slave_IO_State: Waiting </code><code>for</code> <code>master to send event</code>

<code> </code><code>Master_Host: 192.168.30.116</code>

<code> </code><code>Master_User: repluser</code>

<code> </code><code>Master_Port: 3306</code>

<code> </code><code>Connect_Retry: 60</code>

<code> </code><code>Master_Log_File: master-bin.000002</code>

<code> </code><code>Read_Master_Log_Pos: 539</code>

<code> </code><code>Relay_Log_File: slave-relay-bin.000002</code>

<code> </code><code>Relay_Log_Pos: 751</code>

<code> </code><code>Relay_Master_Log_File: master-bin.000002</code>

<code> </code><code>Slave_IO_Running: Yes</code>

<code> </code><code>Slave_SQL_Running: Yes</code>

<code> </code><code>Replicate_Do_DB:</code>

<code> </code><code>Replicate_Ignore_DB:</code>

<code> </code><code>Replicate_Do_Table:</code>

<code> </code><code>Replicate_Ignore_Table:</code>

<code> </code><code>Replicate_Wild_Do_Table:</code>

<code> </code><code>Replicate_Wild_Ignore_Table:</code>

<code> </code><code>Last_Errno: 0</code>

<code> </code><code>Last_Error:</code>

<code> </code><code>Skip_Counter: 0</code>

<code> </code><code>Exec_Master_Log_Pos: 539</code>

<code> </code><code>Relay_Log_Space: 955</code>

<code> </code><code>Until_Condition: None</code>

<code> </code><code>Until_Log_File:</code>

<code> </code><code>Until_Log_Pos: 0</code>

<code> </code><code>Master_SSL_Allowed: No</code>

<code> </code><code>Master_SSL_CA_File:</code>

<code> </code><code>Master_SSL_CA_Path:</code>

<code> </code><code>Master_SSL_Cert:</code>

<code> </code><code>Master_SSL_Cipher:</code>

<code> </code><code>Master_SSL_Key:</code>

<code> </code><code>Seconds_Behind_Master: 0</code>

<code>Master_SSL_Verify_Server_Cert: No</code>

<code> </code><code>Last_IO_Errno: 0</code>

<code> </code><code>Last_IO_Error:</code>

<code> </code><code>Last_SQL_Errno: 0</code>

<code> </code><code>Last_SQL_Error:</code>

<code> </code><code>Replicate_Ignore_Server_Ids:</code>

<code> </code><code>Master_Server_Id: 1</code>

<code> </code><code>Master_UUID: b05c9b5c-bfac-11e3-a4bc-000c29f3fcba</code>

<code> </code><code>Master_Info_File: mysql.slave_master_info</code>

<code> </code><code>SQL_Delay: 0</code>

<code> </code><code>SQL_Remaining_Delay: NULL</code>

<code> </code><code>Slave_SQL_Running_State: Slave has </code><code>read</code> <code>all relay log; waiting </code><code>for</code> <code>the slave I</code><code>/O</code> <code>thread to update it</code>

<code> </code><code>Master_Retry_Count: 86400</code>

<code> </code><code>Master_Bind:</code>

<code> </code><code>Last_IO_Error_Timestamp:</code>

<code> </code><code>Last_SQL_Error_Timestamp:</code>

<code> </code><code>Master_SSL_Crl:</code>

<code> </code><code>Master_SSL_Crlpath:</code>

<code> </code><code>Retrieved_Gtid_Set: b05c9b5c-bfac-11e3-a4bc-000c29f3fcba:1-2</code>

<code> </code><code>Executed_Gtid_Set: b05c9b5c-bfac-11e3-a4bc-000c29f3fcba:1-2</code>

<code> </code><code>Auto_Position: 1</code>

Connect_Retry：slave服务器连接master服务器的重试次数；

Exec_Master_Log_Pos：当前slave服务器最后一次所执行二进制日志的位置；

Relay_Log_Space：relaylog的空间；

Seconds_Behind_Master：slave滞后master的时长（通过当前服务器的时间戳与二进制日志中的时间戳对比得到的）；

Slave_IO_Running：slave服务器I/O线程的运行情况；

Slave_SQL_Running：slave服务器SQL线程的运行情况；

发现gtid复制已经启动成功，并可以查看主从服务器的uuid（对于每一个mysql服务器都是唯一的）

<code>mysql> show global variables like </code><code>'%uuid'</code><code>;</code>

<code>| Variable_name | Value |</code>

<code>| server_uuid | b05c9b5c-bfac-11e3-a4bc-000c29f3fcba |</code>

<code>| server_uuid | ba83181a-bfac-11e3-a4bc-000c295b50f9 |</code>

在slave 可以看到启动的复制线程数

<code>mysql> show processlist;</code>

在master创建数据库，看是否同步到slave

<code>mysql> create database student;</code>

<code>Query OK, 1 row affected (0.01 sec)</code>

<code>mysql> show databases;</code>

<code>| Database |</code>

<code>| information_schema |</code>

<code>| mysql |</code>

<code>| performance_schema |</code>

<code>| student |</code>

<code>| testdb |</code>

发现已经同步到slave

主从服务器数据不一致的常见原因：

1、在slave服务器上直接执行写操作；

2、基于SQL语句的复制，建议使用基于数据本身的复制；

3、relaylog日志出现故障；

4、数据库架构复制有问题；

5、在一个数据库里面混合使用myisam和innodb引擎；

6、mysql的主从版本不一致（从服务器的版本必须高于主服务器版本）；

7、使用myisam存储引擎时，执行的语句被意外终止；

修复主从服务器数据不一致的方案：

1、使用pt-table-checksum工具，能够监控主从服务器数据表中的数据是否一致；

2、使用pt-table-sync工具，能够实现同步主从服务器上表的数据；

防止主从复制崩溃后带来的损失：

1、设置master服务器的sync_binlog=1，意思是只要有数据更新就立即同步到磁盘上面，同时要求磁盘本身不具有缓存能力；

2、使用innodb存储引擎时，当slave服务器意外关闭后，重新启动会重新读取master_info文件，这个时候master_info数据没刷新到磁盘上面，这样会导致数据复制出现错误，这个时候可以在slave上启用innodb_overwrite_relay_log_info；可以覆盖relay_log_info里面的数据，避免造成数据丢失；

3、或者也可以使用工具pt-slave-restart，从节点意外关闭时，用于安全启动复制进程；

4、当master服务器二进制日志出现错误时，可以在slave服务器上执行set global sql_slave_skip_counter=1;start slave; 跳过错误，或者删除二进制日志重新生成，然后重新建立复制；

下面开始配置amoeba，首先安装jdk环境

<code>[root@amoeba ~]</code><code># tar zxvf jdk-7u25-linux-x64.gz -C /usr/local/</code>

<code>[root@amoeba ~]</code><code># cd /usr/local/</code>

<code>[root@amoeba </code><code>local</code><code>]</code><code># ln -s jdk1.7.0_25 jdk</code>

<code>[root@amoeba </code><code>local</code><code>]</code><code># vi /etc/profile.d/jdk.sh</code>

<code>export</code> <code>JAVA_HOME=</code><code>/usr/local/jdk</code>

<code>export</code> <code>CLASSPATH=$CLASSPATH:$JAVA_HOME</code><code>/lib</code><code>:$JAVA_HOME</code><code>/jre/lib</code>

<code>export</code> <code>PATH=</code><code>/usr/local/jdk/bin</code><code>:$PATH</code>

<code>[root@amoeba </code><code>local</code><code>]</code><code># . /etc/profile.d/jdk.sh</code>

<code>[root@amoeba </code><code>local</code><code>]</code><code># java -version</code>

<code>java version </code><code>"1.7.0_25"</code>

<code>Java(TM) SE Runtime Environment (build 1.7.0_25-b15)</code>

<code>Java HotSpot(TM) 64-Bit Server VM (build 23.25-b01, mixed mode)</code>

下载安装amoeba

<code>[root@amoeba ~]</code><code># mkdir /usr/local/amoeba</code>

<code>[root@amoeba ~]</code><code># tar zxvf amoeba-mysql-binary-2.1.0-RC5.tar.gz -C /usr/local/amoeba/</code>

<code>[root@amoeba ~]</code><code># vi /etc/profile.d/amoeba.sh</code>

<code>export</code> <code>PATH=</code><code>/usr/local/amoeba/bin</code><code>:$PATH</code>

<code>[root@amoeba ~]</code><code># . /etc/profile.d/amoeba.sh</code>

<code>[root@amoeba ~]</code><code># cp /usr/local/amoeba/conf/amoeba.xml /usr/local/amoeba/conf/amoeba.xml.bak</code>

<code>[root@amoeba ~]</code><code># cp /usr/local/amoeba/conf/dbServers.xml /usr/local/amoeba/conf/dbServers.xml.bak</code>

调整amoeba配置文件，设置读写分离

<code>[root@amoeba ~]</code><code># vi /usr/local/amoeba/conf/amoeba.xml</code>

<code># 在<service name="Amoeba for Mysql" class="com.meidusa.amoeba.net.ServerableConnectionManager">子标签中修改如下几项</code>

<code><property name=</code><code>"port"</code><code>>3306<</code><code>/property</code><code>></code>

<code><property name=</code><code>"ipAddress"</code><code>>0.0.0.0<</code><code>/property</code><code>></code>

<code><property name=</code><code>"password"</code><code>>mypass<</code><code>/property</code><code>></code>

<code># 在<queryRouter class="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">子标签中启用修改下面几项</code>

<code><property name=</code><code>"writePool"</code><code>>server1<</code><code>/property</code><code>></code>

<code><property name=</code><code>"readPool"</code><code>>server2<</code><code>/property</code><code>></code>

<code>[root@amoeba ~]</code><code># vi /usr/local/amoeba/conf/dbServers.xml</code>

<code># 启动并修改 <dbServer name="abstractServer" abstractive="true">子标签中的</code>

<code># 修改 <dbServer name="server1" parent="abstractServer">子标签中的</code>

<code><property name=</code><code>"ipAddress"</code><code>>192.168.30.116<</code><code>/property</code><code>></code>

<code># 新添加一个dbServer如下</code>

<code><dbServer name=</code><code>"server2"</code> <code>parent=</code><code>"abstractServer"</code><code>></code>

<code> </code><code><property name=</code><code>"ipAddress"</code><code>>192.168.30.117<</code><code>/property</code><code>></code>

<code> </code><code><</code><code>/factoryConfig</code><code>></code>

<code> </code><code><</code><code>/dbServer</code><code>></code>

在master和slave中分别创建用于amoeba连接俩台mysql的用户

<code># 在master上面创建</code>

<code>mysql> grant all on *.* to </code><code>'root'</code><code>@</code><code>'192.168.30.%'</code> <code>identified by </code><code>'mypass'</code><code>;</code>

<code>#发现已经同步到slave</code>

<code>mysql> show grants </code><code>for</code> <code>'root'</code><code>@</code><code>'192.168.30.%'</code><code>;</code>

<code>| Grants </code><code>for</code> <code>[email protected].% |</code>

<code>| GRANT ALL PRIVILEGES ON *.* TO </code><code>'root'</code><code>@</code><code>'192.168.30.%'</code> <code>IDENTIFIED BY PASSWORD </code><code>'*6C8989366EAF75BB670AD8EA7A7FC1176A95CEF4'</code> <code>|</code>

启动amoeba

<code>[root@amoeba ~]</code><code># vi /usr/local/amoeba/bin/amoeba</code>

<code>DEFAULT_OPTS=</code><code>"-server -Xms256m -Xmx256m -Xss128k"</code>

<code>DEFAULT_OPTS=</code><code>"-server -Xms256m -Xmx256m -Xss256k"</code>

<code>[root@amoeba ~]</code><code># amoeba start</code>

<code>log4j:WARN log4j config load completed from </code><code>file</code><code>:</code><code>/usr/local/amoeba/conf/log4j</code><code>.xml</code>

<code>2014-04-09 15:09:15,121 INFO context.MysqlRuntimeContext - Amoeba </code><code>for</code> <code>Mysql current versoin=5.1.45-mysql-amoeba-proxy-2.1.0-RC5</code>

<code>log4j:WARN ip access config load completed from </code><code>file</code><code>:</code><code>/usr/local/amoeba/conf/access_list</code><code>.conf</code>

<code>2014-04-09 15:09:15,482 INFO net.ServerableConnectionManager - Amoeba </code><code>for</code> <code>Mysql listening on </code><code>/0</code><code>.0.0.0:3306.</code>

<code>2014-04-09 15:09:15,489 INFO net.ServerableConnectionManager - Amoeba Monitor Server listening on </code><code>/127</code><code>.0.0.1:53201.</code>

<code>[root@amoeba ~]</code><code># netstat -anptl | grep :3306</code>

<code>tcp 0 0 :::3306 :::* LISTEN 19208</code><code>/java</code>

<code>tcp 0 0 ::ffff:192.168.30.115:33408 ::ffff:192.168.30.116:3306 ESTABLISHED 19208</code><code>/java</code>

<code>tcp 0 0 ::ffff:192.168.30.115:59880 ::ffff:192.168.30.117:3306 ESTABLISHED 19208</code><code>/java</code>

<code>[root@amoeba ~]</code><code># mysql -u root -pmypass -h 192.168.30.115 -P 3306</code>

<code>Welcome to the MySQL monitor. Commands end with ; or \g.</code>

<code>Your MySQL connection </code><code>id</code> <code>is 1783342624</code>

<code>Server version: 5.1.45-mysql-amoeba-proxy-2.1.0-RC5 MySQL Community Server (GPL)</code>

<code>Oracle is a registered trademark of Oracle Corporation and</code><code>/or</code> <code>its</code>

<code>affiliates. Other names may be trademarks of their respective</code>

<code>owners.</code>

<code>Type </code><code>'help;'</code> <code>or </code><code>'\h'</code> <code>for</code> <code>help. Type </code><code>'\c'</code> <code>to </code><code>clear</code> <code>the current input statement.</code>

启动成功，并访问正常

下面使用tcpdump命令抓包测试读写分离效果

<code>[root@master ~]</code><code># tcpdump -i eth0 -s0 -nn -A tcp dst port 3306 and dst host 192.168.30.116</code>

<code>[root@slave ~]</code><code># tcpdump -i eth0 -s0 -nn -A tcp dst port 3306 and dst host 192.168.30.117</code>

<code># amoeba服务器上登录mysql,并创建数据库</code>

<code>mysql> create database abc;</code>

<code>Query OK, 1 row affected (0.03 sec)</code>

<code>tcpdump: verbose output suppressed, use -</code><code>v</code> <code>or -vv </code><code>for</code> <code>full protocol decode</code>

<code>listening on eth0, link-</code><code>type</code> <code>EN10MB (Ethernet), capture size 65535 bytes</code>

<code>15:16:42.492828 IP 192.168.30.115.33408 > 192.168.30.116.3306: Flags [P.], </code><code>seq</code> <code>1149949367:1149949391, ack 113323290, win 123, options [nop,nop,TS val 8373727 ecr 10837334], length 24</code>

<code>E..L&"@[email protected]....{4].....</code>

<code>......]V.....create database abc</code>

<code>15:16:42.501837 IP 192.168.30.115.33408 > 192.168.30.116.3306: Flags [.], ack 12, win 123, options [nop,nop,TS val 8373736 ecr 11221763], length 0</code>

<code>E..4&</code><code>#@[email protected]%...{.I.....</code>

<code>15:16:42.502356 IP 192.168.30.117.38626 > 192.168.30.116.3306: Flags [.], ack 3194819787, win 170, options [nop,nop,TS val 9637577 ecr 11221763], length 0</code>

<code>E..4.0@[email protected].............</code>

<code># 发现在master上面抓到了创建数据库的包</code>

<code># slave上面没有抓到任何包</code>

<code># 下面在amoeba上面执行创建表，插入，查询语句</code>

<code>mysql> use abc</code>

<code>Database changed</code>

<code>mysql> create table </code><code>test</code><code>(</code><code>id</code> <code>int);</code>

<code>Query OK, 0 rows affected (0.41 sec)</code>

<code>mysql> insert into </code><code>test</code> <code>values(1);</code>

<code>Query OK, 1 row affected (0.04 sec)</code>

<code>mysql> </code><code>select</code> <code>* from </code><code>test</code><code>;</code>

<code>15:20:42.054548 IP 192.168.30.115.33419 > 192.168.30.116.3306: Flags [P.], </code><code>seq</code> <code>976065559:976065590, ack 2591052457, win 123, options [nop,nop,TS val 8613289 ecr 11418139], length 31</code>

<code>E..S."@[email protected]....:-...pR....{.H.....</code>

<code>..m...:......insert into </code><code>test</code> <code>values(1)</code>

<code>15:20:42.085305 IP 192.168.30.117.38626 > 192.168.30.116.3306: Flags [.], ack 3194820258, win 189, options [nop,nop,TS val 9877161 ecr 11461346], length 0</code>

<code>E..4.2@[email protected].......*.....</code>

<code>15:20:42.086686 IP 192.168.30.115.33419 > 192.168.30.116.3306: Flags [.], ack 12, win 123, options [nop,nop,TS val 8613320 ecr 11461347], length 0</code>

<code>E..4.</code><code>#@[email protected]....:-.6.pR....{./.....</code>

<code>15:20:52.076327 IP 192.168.30.115.59899 > 192.168.30.117.3306: Flags [P.], </code><code>seq</code> <code>201259223:201259232, ack 2661648116, win 115, options [nop,nop,TS val 8623261 ecr 9819401], length 9</code>

<code>E..=..@[email protected].&.....</code>

<code>15:20:52.076821 IP 192.168.30.115.59899 > 192.168.30.117.3306: Flags [.], ack 12, win 115, options [nop,nop,TS val 8623261 ecr 9887103], length 0</code>

<code>E..4..@[email protected]</code><code>#q.....</code>

<code>15:20:52.077609 IP 192.168.30.115.59899 > 192.168.30.117.3306: Flags [P.], </code><code>seq</code> <code>9:32, ack 12, win 115, options [nop,nop,TS val 8623262 ecr 9887103], length 23</code>

<code>E..K..@[email protected].......</code>

<code>.............</code><code>select</code> <code>* from </code><code>test</code>

<code>15:20:52.118046 IP 192.168.30.115.59899 > 192.168.30.117.3306: Flags [.], ack 82, win 115, options [nop,nop,TS val 8623303 ecr 9887105], length 0</code>

<code>E..4..@[email protected]"......</code>

<code>观察抓包情况，发现所有的更新操作都在master，查询操作都在slave 上面</code>

登录主从数据库查看数据是否一致

<code># master</code>

<code># slave</code>

<code># 发现数据一致</code>

四、Amoeba简单的优化配置：

1、修改amoeba启动参数，增加JAVA虚拟机的内存，修改amoeba执行程序，查找DEFAULT_OPTS，修改为以下内容：

DEFAULT_OPTS="-server -Xms1024m -Xmx1024m -Xss256k"

2、 amoeba.xml中关于多线程和网络的优化

<code>[root@amoeba ~]</code><code># vim /usr/local/amoeba/conf/amoeba.xml</code>

<code># 修改如下几项</code>

<code><property name=</code><code>"readThreadPoolSize"</code><code>>500<</code><code>/property</code><code>></code>

<code><property name=</code><code>"clientSideThreadPoolSize"</code><code>>500<</code><code>/property</code><code>></code>

<code><property name=</code><code>"serverSideThreadPoolSize"</code><code>>500<</code><code>/property</code><code>></code>

<code><property name=</code><code>"sendBufferSize"</code><code>>256<</code><code>/property</code><code>></code>

<code><property name=</code><code>"receiveBufferSize"</code><code>>128<</code><code>/property</code><code>></code>

3、 amoeba.xml中还有一个处理客户端连接和网络信息使用CPU核数的配置，不过默认配置是主机拥有的CPU核的数量，一般不用修改，如果你的amoeba负载较高，并且机器上还有其他服务，你就可以降低这个配置，避免系统或者其他服务没有资源，或者出现资源争抢，从而导致整理的处理能力下降。

查找amoeba.xml文件中connectionManagerList关键字，修改

<code>default value is avaliable Processors</code>

<code><property name=</code><code>"processors"</code><code>>5<</code><code>/property</code><code>></code>

<code># 取消注释，并设置processors数量。</code>

到此，MySQL 5.6基于GTID的复制，以及Amoeba读写分离的实现配置完成。

本文转自ljl_19880709 51CTO博客，原文链接：http://blog.51cto.com/luojianlong/1392844，如需转载请自行联系原作者

MySQL 5.6.13 GTID复制，以及基于Amoeba实现读写分离

继续阅读

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

NOSQL安全攻击

mybatis_入门程序Mybatis入门

mysql使用source命令导入.sql文件

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

登录plsql 报错 the account is locked --用户被锁

Effective Java 8:通用程序设计

SequoiaDB巨杉数据库C++驱动概述

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method