Amoeba实现读写分离配置详解

作为一名小白,在发现项目中环境崩溃的时候我果断选择了各种暴力删除和重启,经过不断的尝试终于把Amoeba所在的环境彻底搞废了。。。

项目场景

1、主数据库服务器10.10.20.111作为写库,从数据库服务器10.10.20.116作为读库
2、Amoeba安装在主数据库服务器上

准备工作

1、安装java环境
Amoeba是基于jdk1.5开发的,所以需要先安装java环境,安装步骤戳这里,jdk下载戳这里
2、安装Amoeba
Amoeba下载戳这里,我下载的是amoeba-mysql-3.0.5-RC-distribution.zip。下载完成后将压缩文件解压到/usr/local/amoeba目录下

Amoeba配置

Amoeba配置文件位于/usr/local/amoeba/conf目录下,配置读写分离我们只需关注dbServers.xml和amoeba.xml
1、dbServers.xml

<?xml version="1.0" encoding="gbk"?>

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

        <!-- 
            Each dbServer needs to be configured into a Pool,
            If you need to configure multiple dbServer with load balancing that can be simplified by the following configuration:
             add attribute with name virtual = "true" in dbServer, but the configuration does not allow the element with name factoryConfig
             such as 'multiPool' dbServer   
        -->
        
    <dbServer name="abstractServer" abstractive="true">
        <factoryConfig class="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory">
            <property name="connectionManager">${defaultManager}</property>
            <property name="sendBufferSize">64</property>
            <property name="receiveBufferSize">128</property>
                
            <!-- mysql port -->
            #设置Amoeba要连接的mysql数据库的端口,默认是3306
            <property name="port">3306</property>
            
            <!-- mysql schema -->
            #设置缺省的数据库,当连接amoeba时,操作表必须显式的指定数据库名,即采用dbname.tablename的方式,不支持 use dbname指定缺省库,因为操作会调度到各个后端数据库
            <property name="schema">db</property>
            
            <!-- mysql user -->
            #设置amoeba连接后端数据库服务器的账号和密码,因此需要在所有后端数据库上创建该用户,并授权amoeba服务器可连接
            <property name="user">amoeba</property>
            
            <property name="password">1234</property>
        </factoryConfig>

        <poolConfig class="com.meidusa.toolkit.common.poolable.PoolableObjectPool">
            #最大连接数,默认500
            <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="testWhileIdle">true</property>
        </poolConfig>
    </dbServer>

    #设置写库信息,名字可以任意命名
    <dbServer name="master"  parent="abstractServer">
        <factoryConfig>
            <!-- mysql ip -->
            #写库既主数据库服务器地址
            <property name="ipAddress">10.10.20.111</property>
        </factoryConfig>
    </dbServer>
    
    #设置读库信息,名字可以任意命名
    <dbServer name="slave1"  parent="abstractServer">
        <factoryConfig>
            <!-- mysql ip -->
            #读库既从数据库服务器地址
            <property name="ipAddress">10.10.20.116</property>
        </factoryConfig>
    </dbServer>
        
</amoeba:dbServers>

2、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.mysql.server.MySQLService">
            <!-- port -->
            #设置amoeba监听的端口,默认是8066
            <property name="port">8066</property>
            
            <!-- bind ipAddress -->
            #设置amoeba监听的地址,如果不设置,默认监听所有地址
            <!-- 
            <property name="ipAddress">127.0.0.1</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="authenticateProvider">
                <bean class="com.meidusa.amoeba.mysql.server.MysqlClientAuthenticator">
                    <!-- 登录Amoeba的账号密码(这里的账号密码和amoeba连接后端数据库服务器的密码无关) -->
                    <property name="user">root</property>
                    
                    <property name="password">root</property>
                    
                    <property name="filter">
                        <bean class="com.meidusa.toolkit.net.authenticate.server.IPAccessController">
                            <property name="ipFile">${amoeba.home}/conf/access_list.conf</property>
                        </bean>
                    </property>
                </bean>
            </property>
            
        </service>
        
        <runtime class="com.meidusa.amoeba.mysql.context.MysqlRuntimeContext">
            <property name="readThreadPoolSize">20</property> 
            
            <property name="clientSideThreadPoolSize">30</property> 
            
            <property name="serverSideThreadPoolSize">30</property>
            
            <!-- proxy server client process thread size -->
            <property name="executeThreadSize">128</property>
            
            <!-- per connection cache prepared statement size  -->
            <property name="statementCacheSize">500</property>
            
            <!-- default charset -->
            <property name="serverCharset">utf8</property>
            
            <!-- query timeout( default: 60 second , TimeUnit:second) -->
            <property name="queryTimeout">60</property>
        </runtime>
        
    </proxy>
    
    <!-- 
        Each ConnectionManager will start as thread
        manager responsible for the Connection IO read , Death Detection
    -->
    <connectionManagerList>
        <connectionManager name="defaultManager" class="com.meidusa.toolkit.net.MultiConnectionManagerWrapper">
            <property name="subManagerClassName">com.meidusa.toolkit.net.AuthingableConnectionManager</property>
        </connectionManager>
    </connectionManagerList>
    
        <!-- default using file loader -->
    <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>
        #设置amoeba默认的池,这里设置为master
        <property name="defaultPool">master</property>
        
        #设置读写池,在上一个配置文件中已定义好
        <property name="writePool">master</property>
        <property name="readPool">slave1</property>
        <property name="needParse">true</property>
    </queryRouter>
</amoeba:configuration>

3、授权Amoeba
分别在主数据库和从数据库为Amoeba授权

mysql>grant all on db.* to 'amoeba'@'10.10.20.111' identified by '1234';
mysql>flush privileges;

4、启动Amoeba

cd /usr/local/amoeba/bin
./launcher start

由于Amoeba的运行是基于Java的,所以在初次运行时由于stack size太小导致jvm启动失败。我们可以修改jvm.properties文件中的参数,然后重新启动

vi /usr/local/amoeba/jvm.properties
#JVM_OPTIONS="-server -Xms256m -Xmx1024m -Xss196k -XX:PermSize=16m -XX:MaxPermSize=96m"
JVM_OPTIONS="-server -Xms256m -Xmx1024m -Xss512k"

测试读写分离

1、关闭MySQL主从同步功能,在从数据库服务器中执行

mysql>stop slave;

2、登录Amoeba,插入数据

mysql -uroot -proot -P8066
mysql>use db;
mysql>insert into test(name) values('amoeba');
mysql>select * from test;

并没有查到新增的数据
3、登录主数据库服务器

mysql -uroot -proot
mysql>use db;
mysql>select * from test;

可以看到刚才新增的数据
4、从数据库服务器开启MySQL主从同步

mysql>start slave;

5、在Amoeba中重新查询

mysql>select * from test

现在可以查到新增的数据了,说明写是在主数据库执行,查是在从数据库执行

参考:Amoeba+Mysql实现数据库读写分离

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,504评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,434评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,089评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,378评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,472评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,506评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,519评论 3 413
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,292评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,738评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,022评论 2 329
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,194评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,873评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,536评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,162评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,413评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,075评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,080评论 2 352

推荐阅读更多精彩内容

  • !/bin/sh 02 03 mysql-proxy This script starts and stops t...
    __XY__阅读 823评论 0 15
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,971评论 25 707
  • 前几天看到我的你们大学室友,和自己的老公去青岛旅游度假的照片,看到她的生活状态,我脑海中突然有一个疑问:什么才是自...
    与君倾城恋阅读 351评论 0 1
  • 几天前我一个人走在路上,看到一对情侣穿着情侣装,坐在候车亭的长椅上互相依偎着 我稍微打量了一眼,那女孩不算漂亮,脸...
    樱晓兮阅读 379评论 2 2
  • 将近半个月没有写日记了,我总是坚持不下来,这段日子,自己没有进步了,太懒了,不想动。工作可以说是一塌糊涂,...
    灶神阅读 146评论 0 0