Amoeba实现mysql主从读写分离1

这段在网上看了下关于amoeba的文章,整体感受好像要比mysql-proxy好的多,也参考了很多的资料,此文章可能与其余文章做者会有雷同的地方,请谅解,可是此过程确实是本人亲自试验得来的.
 

试验环境

操做系统:  SUSE Linux Enterprise Server 10 (x86_64)
 
服务器IP:  10.10.0.72  10.10.0.77  10.10.0.87
 
服务器角色:  10.10.0.72做为mysqlmaster服务器, 0.77做为mysqlslave服务
             ,0.87做为amoeba服务器
 
软件列表:    MySQL-client-community-5.1.54-1.sles10.i586.rpm
             MySQL-server-community-5.1.54-1.sles10.i586.rpm
             amoeba-mysql-1.3.1-BETA.zip
             jdk-1_5_0_16-linux-i586-rpm.bin

Amoeba的简介

Amoeba(变形虫)项目,专一分布式数据proxy 开发.座落与ClientDB Server(s)之间.对客户端透明.具备负载均衡、高可用性、sql过滤、读写分离、可路由相关的query到目标数据库、可并发请求多台数据库合并结果.
 
主要解决了哪些问题:

下降数据切分带来的复杂多数据库结构

提供切分规则并下降数据切分规则给应用带来的影响

下降db 与客户端的链接数

读写分离
 
这里关于mysql的安装就不说了,网上的教程比较多.

实现mysql的主从复制

master服务器上执行以下命令:
#mysql –uroot –ptest
mysql> grant replication slave,file on *.* to 'sxit'@'10.10.0.77' identified by '123456';
mysql> flush privileges;
mysql> exit;
 
// 修改mastermy.cnf的配置
 
log-bin=mysql-bin            // 打开mysql二进制日志
server-id = 1                // 设置mysql_id,主从不能相同
binlog-do-db=test            // 设置二进制日志记录的库
sync_binlog=1      
 
// 修改slavemy.cnf的配置
 
log-bin=mysql-bin
server-id = 2
replicate-do-db=test          //
设置同步的库
log-slave-updates            //
同步后记录二进制日志    
sync_binlog=1
slave-net-timeout=60
 
分别重启主从mysqld服务,登陆master服务器.
 
master服务器上执行以下命令
 
# mysql –u root –ptest
mysql>  flush tables with read lock;
mysql>  show master status\G;
 
*************************** 1. row ***************************
 File: mysql-bin.000002
 Position: 106
 Binlog_Do_DB: test
Binlog_Ignore_DB:
 
mysql> unlock tables;
 
登录到slave服务器,执行以下命令:
 
# mysql –u root –ptest
 
mysql>  stop slave;
 
mysql> change master to master_host='10.10.0.72', master_user='sxit', master_password='123456',
       master_log_file='mysql-bin.000002',master_log_pos=106;
 
mysql>  start slave;
 
mysql>  show slave status\G;
 
若是出现下面的状况,说明主从同步已经成功!
Slave_IO_Running: Yes
Slave_SQL_Running: Yes

安装amoeba

因为amoeba基于JDK1.5开发的,采用了JDK1.5的特性,因此咱们这里要安装JDK,10.10.0.87服务器上安装相关程序
 
# chmod +x jdk-1_5_0_16-linux-i586-rpm.bin
# ./ jdk-1_5_0_16-linux-i586-rpm.bin
#  vi /etc/profile          //在文件里面添加jdk的环境变量,添加内容以下
 
JAVA_HOME=/usr/java/jdk1.5.0_16
export JAVA_HOME
PATH=$JAVA_HOME/bin:$PATH
export PATH
CLASSPATH=$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:$CLASSPATH
export CLASSPATH
 
# source  /etc/profile
 
# mkdir amoeba
# cd  /usr/local/amoeba
# unzip amoeba-mysql-1.3.1-BETA.zip
# chmod -R +x /usr/local/amoeba/bin/
 
Amoeba For MySQL 的使用很是简单,全部的配置文件都是标准的XML 文件,总共有四个配置文件.分别为:
 
amoeba.xml:主配置文件,配置全部数据源以及Amoeba自身的参数设置,实现主从的话配
   置这个文件就能够了;
 
rule.xml:配置全部Query 路由规则的信息;
 
functionMap.xml:配置用于解析Query 中的函数所对应的Java 实现类;
 
rullFunctionMap.xml:配置路由规则中须要使用到的特定函数的实现类;
 
经过更改amoeba.xml配置文件实现mysql主从读写分离,配置以下:
 
<?xml version="1.0" encoding="gbk"?>
 
<!DOCTYPE amoeba:configuration SYSTEM "amoeba.dtd">
<amoeba:configuration xmlns:amoeba="http://amoeba.meidusa.com/">
 
        <server>
                <!-- proxy server 绑定的端口 -->
                <property name="port">8066</property>
 
                <!-- proxy server 绑定的IP -->
                <property name="ipAddress">10.10.0.87</property>
                <!-- proxy server net IO Read thread size -->
                <property name="readThreadPoolSize">20</property>
 
                <!-- proxy server client process thread size -->
                <property name="clientSideThreadPoolSize">30</property>
 
                <!-- mysql server data packet process thread size -->
                <property name="serverSideThreadPoolSize">30</property>
 
                <!-- socket Send and receive BufferSize(unit:K)  -->
                <property name="netBufferSize">128</property>
 
                <!-- Enable/disable TCP_NODELAY (disable/enable Nagle's algorithm). -->
                <property name="tcpNoDelay">true</property>
 
                <!-- 对外验证的用户名 -->
                <property name="user">root</property>
 
                <!-- 对外验证的密码 -->
              
                <property name="password">sxit</property>
 
                <!-- query timeout( default: 60 second , TimeUnit:second) -->
                <property name="queryTimeout">60</property>
        </server>
 
        <!--
                每一个ConnectionManager都将做为一个线程启动。
                manager 负责Connection IO读写/死亡检测
        -->
        <connectionManagerList>
           <connectionManager name="defaultManager" class="com.meidusa.amoeba.net.MultiConnectionManagerWrapper">
  <property name="subManagerClassName">com.meidusa.amoeba.net.AuthingableConnectionManager
</property>
     <!--
       default value is avaliable Processors
         <property name="processors">5</property>
     -->
</connectionManager>
</connectionManagerList>
 
<dbServerList>
     <!--
        一台mysqlServer 须要配置一个pool
        若是多台 平等的mysql须要进行loadBalance
        平台已经提供一个具备负载均衡能力的objectPoolcom.meidusa.amoeba.mysql.server.MultipleServerPool
         简单的配置是属性加上 virtual="true",Pool 不容许配置factoryConfig
         或者本身写一个ObjectPool
     -->
<dbServer name="server1">
 
     <!-- PoolableObjectFactory 实现类 -->
        <factoryConfig class="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory">
             <property name="manager">defaultManager</property>
 
                <!-- 真实mysql数据库端口 -->
                     <property name="port">3306</property>
 
                <!-- 真实mysql数据库IP -->
                      <property name="ipAddress">10.10.0.72</property>
                      <property name="schema">test</property>
 
                <!-- 用于登录mysql的用户名 -->
                       <property name="user">test</property>
 
                 <!-- 用于登录mysql的密码 -->
 
                        <property name="password">123456</property>
 
            </factoryConfig>
 
      <!-- ObjectPool 实现类 -->
         <poolConfig class="com.meidusa.amoeba.net.poolable.PoolableObjectPool">
                <property name="maxActive">200</property>
                  <property name="maxIdle">200</property>
                  <property name="minIdle">10</property>
                  <property name="minEvictableIdleTimeMillis">600000
</property>
                   <property name="timeBetweenEvictionRunsMillis">600000</property>
                        <property name="testOnBorrow">true</property>
                         <property name="testWhileIdle">true</property>
                   </poolConfig>
</dbServer>
相关文章
相关标签/搜索