mysql数据库的读写分离 amoeba

2022-08-12 19:20:52

一 amoeba

Amoeba是一个以MySQL为底层数据存储，并对应用提供MySQL协议接口的proxy。它集中地响应应用的请求，依据用户事先设置的规则，将SQL请求发送到特定的数据库上执行。基于此可以实现负载均衡、读写分离、高可用性等需求。与MySQL官方的MySQL Proxy相比，作者强调的是amoeba配置的方便（基于XML的配置文件，用SQLJEP语法书写规则，比基于lua脚本的MySQL Proxy简单）。

Amoeba优缺点

优点：

1、降低数据切分带来的复杂多数据库结构

2、提高系统整体可用性

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

4、降低db 与客户端的连接数

5、可以直接实现读写分离及负载均衡效果，而不用修改代码

缺点：

1、不支持事务与存储过程

2、暂不支持分库分表，amoeba目前只做到分数据库实例

3、不适合从amoeba导数据的场景或者对大数据量查询的query并不合适（比如一次请求返回10w以上甚至更多数据的场合）

二数据库读写分离配置

环境

系统 centos 6.4 x86_64

软件 mysql5.6.19 jdk1.7 amoeba2.2

amoeba服务器 192.168.200.19

master 192.168.200.17

slave 192.168.200.18

主从服务器复制见以前的博客此处略

1 配置JDK

[root@bogon ~]# rpm -ivh jdk-7u60-linux-x64.rpm 
[root@bogon ~]# vim /etc/profile.d/java.sh 
export JAVA_HOME=/usr/java/latest
export PATH=$PATH:$JAVA_HOME/bin
[root@bogon ~]# .  /etc/profile.d/java.sh 
[root@bogon ~]# java -version
java version "1.7.0_60"
Java(TM) SE Runtime Environment (build 1.7.0_60-b19)
Java HotSpot(TM) 64-Bit Server VM (build 24.60-b09, mixed mode)

2 安装amoeba

[root@bogon ~]# mkdir /usr/local/amoeba
[root@bogon ~]# tar -xf amoeba-mysql-binary-2.2.0.tar.gz -C /usr/local/amoeba

encoding="gbk"?> <!DOCTYPE amoeba:dbServers SYSTEM "dbserver.dtd"> <amoeba:dbServers xmlns:amoeba="http://amoeba.meidusa.com/">  <dbServer name="abstractServer" abstractive="true"> <factoryConfig class="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory"> <property name="manager">${defaultManager}</property> <property name="sendBufferSize">64</property> <property name="receiveBufferSize">128</property>  <property name="port">3306</property>  <property name="schema">test</property> # 设置amoeba连接后端数据库服务器的账号密码需在后端服务器上创建该用户，并授权amoeba连接  <property name="user">root</property> <property name="password">redhat</property>  </factoryConfig> <poolConfig class="com.meidusa.amoeba.net.poolable.PoolableObjectPool"> <property name="maxActive">500</property> <property name="maxIdle">500</property> <property name="minIdle">10</property> <property name="minEvictableIdleTimeMillis">600000</property> <property name="timeBetweenEvictionRunsMillis">600000</property> <property name="testOnBorrow">true</property> <property name="testOnReturn">true</property> <property name="testWhileIdle">true</property> </poolConfig> </dbServer> # 设置一个后端服务器名字可以随便取 <dbServer name="server1" parent="abstractServer"> <factoryConfig>  <property name="ipAddress">192.168.200.17</property> </factoryConfig> </dbServer> <dbServer name="server2" parent="abstractServer"> <factoryConfig>  <property name="ipAddress">192.168.200.18</property> </factoryConfig> </dbServer> #指定一个虚拟数据库服务器，可以将上面定义的dbserver加入这个虚拟服务器，相当组成一个组 <dbServer name="multiPool" virtual="true"> <poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">  <property name="loadbalance">1</property>  <property name="poolNames">server1,server2</property> </poolConfig> </dbServer> </amoeba:dbServers>

[root@bogon conf]# vim amoeba.xml 
<?xml version="1.0" encoding="gbk"?>

<!DOCTYPE amoeba:configuration SYSTEM "amoeba.dtd">
<amoeba:configuration xmlns:amoeba="http://amoeba.meidusa.com/">

        <proxy>

                <!-- service class must implements com.meidusa.amoeba.service.Service -->
                <service name="Amoeba for Mysql" class="com.meidusa.amoeba.net.ServerableConnectionManager">
#设置amoeba监听的端口
                        <!-- port -->
                        <property name="port">8066</property>
#设置监听的接口，如果不设置，则监听所有的IP
                        <!-- bind ipAddress -->
                        <!-- 
                        <property name="ipAddress">127.0.0.1</property>
                         -->

                        <property name="manager">${clientConnectioneManager}</property>

                        <property name="connectionFactory">
                                <bean class="com.meidusa.amoeba.mysql.net.MysqlClientConnectionFactory">
                                        <property name="sendBufferSize">128</property>
                                        <property name="receiveBufferSize">64</property>
                                </bean>
                        </property>

                        <property name="authenticator">
                                <bean class="com.meidusa.amoeba.mysql.server.MysqlClientAuthenticator">
#提供客户端连接amoeba时需要使用的账号 密码 与 amoeba连接后端数据库服务器密码无关
                                        <property name="user">root</property>

                                        <property name="password">redhat</property>

                                        <property name="filter">
                                                <bean class="com.meidusa.amoeba.server.IPAccessController">
                                                        <property name="ipFile">${amoeba.home}/conf/access_list.conf</property>
                                                </bean>
                                        </property>
                                </bean>
                        </property>

                </service>
................................................（省略）

 <dbServerLoader class="com.meidusa.amoeba.context.DBServerConfigFileLoader">
                <property name="configFile">${amoeba.home}/conf/dbServers.xml</property>
        </dbServerLoader>

        <queryRouter class="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">
                <property name="ruleLoader">
                        <bean class="com.meidusa.amoeba.route.TableRuleFileLoader">
                                <property name="ruleFile">${amoeba.home}/conf/rule.xml</property>
                                <property name="functionFile">${amoeba.home}/conf/ruleFunctionMap.xml</property>
                        </bean>
                </property>
                <property name="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>
                <property name="LRUMapSize">1500</property>
                <property name="defaultPool">server1</property>
#设置读写分离选项
                <property name="writePool">server1</property>
                <property name="readPool">server2</property>
                <!--
                <property name="writePool">server1</property>
                <property name="readPool">server1</property>
                -->
                <property name="needParse">true</property>
        </queryRouter>
</amoeba:configuration>

配置amoeba 环境变量

[root@bogon conf]# vim /etc/profile.d/amoeba.sh
export AMOEBA_HOME=/usr/local/amoeba
export PATH=$PATH:$AMOEBA_HOME/bin：
[root@bogon conf]# .  /etc/profile.d/amoeba.sh

码农公寓

相关文章