Amobea读写分离-白红宇

Amobea读写分离

阅读量：5330 次

发布时间：2019-06-14

本文共 9045 字，大约阅读时间需要 30 分钟。

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

　　 Amoeba相当于一个SQL请求的，目的是为负载均衡、读写分离、高可用性提供机制，而不是完全实现它们。用户需要结合使用MySQL的 Replication等机制来实现副本同步等功能。amoeba对底层数据库连接管理和路由实现也采用了可插拨的机制，第三方可以开发更高级的策略类来替代作者的实现。这个程序总体上比较符合的思想。

　　主要解决：
　　　　• 降低数据切分带来的复杂多数据库结构
　　　　• 提供切分规则并降低数据切分规则给应用带来的影响
　　　　• 降低db 与客户端的连接数
　　　　• 读写分离

不足之处:

　　　　a)目前还不支持事务
　　　　b)暂时不支持（近期会支持）
　　　　c)不适合从amoeba导数据的场景或者对量查询的query并不合适（一次请求返回10w以上甚至更多数据的场合）
　　　　d)暂时不支持分库分表，amoeba目前只做到分数据库实例，每个被切分的节点需要保持库表结构一致：
Amoeba：阿米巴原虫

1》环境介绍

　　master--IP:192.168.100.161

　　slave---IP:192.168.100.160
　　Amoeba--IP:192.168.100.214
2》安装JDK

　　#mkdir /Amoeba

　　#tar –xvf jdk-7u40-linux-x64.tar.gz -C /Amoeba
　　# vim /etc/profile
　　JAVA_HOME=/Amoeba/jdk1.7.0_40
　　export JAVA_HOME
　　PATH=$JAVA_HOME/bin:$PATH
　　export PATH
　　CLASSPATH=:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:$CLASSPATH
　　export CLASSPATH

3》安装Amoeba　　#:mkdir /usr/local/amoeba

　　#:unzip amoeba-mysql-1.3.1-BETA.zip -d /usr/local/amoeba

　　#:chmod -R +x /usr/local/amoeba/bin/
　　#java -version
　　java version "1.7.0_40"
　　Java(TM) SE Runtime Environment (build 1.7.0_40-b43)
　　Java HotSpot(TM) 64-Bit Server VM (build 24.0-b56, mixed mode)
4》主从授权，增加用户

　　mysql-->grant all privileges on *.* to amoeba@'%' identified by 'amoeba123';

　　mysql-->flush privileges;

5》Amoeba配置介绍　　

Amoeba For MySQL 的使用非常简单，所有的配置文件都是标准的XML 文件，总共有四个配置文件。分别为：amoeba.xml：主配置文件，配置所有数据源以及 Amoeba 自身的参数设置；实现主从的话配置这个文件就可以了；

　　rule.xml：配置所有Query 路由规则的信息；

　　functionMap.xml：配置用于解析Query 中的函数所对应的Java 实现类；
　　rullFunctionMap.xml：配置路由规则中需要使用到的特定函数的实现类；
6》配置Amoeba IP 与用户

　　# vim /usr/local/amoeba/conf/amoeba.xml

7》Amoeba配置Master基本信息

8》Amoeba配置Slave基本信息

9》Master负载配置

10》Slave负载配置

11》最后配置读写分离

启动Amoeba

　　# cd /usr/local/amoeba/bin
这种启动方便看nohup.log日志.防止提示溢出
　　#:nohup bash -x amoeba &

常见错误：1

　　　　The stack size specified is too small, Specify at least 228k
　　　　Error: Could not create the Java Virtual Machine.
　　　　Error: A fatal exception has occurred. Program will exit.
　　解决办法:
　　　　# vim /usr/local/amoeba/bin/amoeba
　　　　#DEFAULT_OPTS="-server -Xms256m -Xmx256m -Xss128k" 注释
　　　　DEFAULT_OPTS="-server -Xms256m -Xmx256m -Xss256k" 增加
　　常见错误2:
　　org.xml.sax.SAXParseException; lineNumber: 406; columnNumber: 6; 注释中不允许出现字符串"--"。
　　解决办法：
　　后来改了一大通，试了一下午，才发现。我们的注释两边要有空格，才行。

举例

12》测试是否读写分离

　　1>在(master)主上的test库建立一个alvin的表

　　　　Mysql->use test;

　　　　Mysql->create table alvin(id int(10),name char(10));

2>在(slave)从上查看test库是否同步了alvin表

　　　　Mysql-> use test;

　　　　Mysql->show tables;

　 3>在主(master)操作.插入一条数据.

　　　　mysql-->insert into alvin values(1,'master');

　 4>在从(slave)操作,插入一条数据.

　　　　mysql-->insert into alvin values(2,'slave');

　　注意因为从同步主的数据。所以这里有2条数据，

5>在Amoeba机器上操作

　　在192.168.100.214上面测试,这个密码就是配置文件里面对外的验证密码root 和密码123456

#mysql –u root –p 123456 –h 192.168.100.214 –P 9066

　　(1) 先验证读:我们配置文件是用的是DR轮询,注意这个IP地址要写：amoeba的IP地址，不是master也不是slave ，是通过amoeba代理登陆192.168.100.214

　　　　Mysql->use test;

　　　　测试轮询成功,主和从各查询一次。

　　(2) 验证写:正常来说。如果只有全部写到主里面，两边的数据才会以致。如果其中有一个不一致的话。那么说明写到从里面去了。因为主不会同步从的数据。都是单向数据传输。

13》常用配置写法：

　　(1)如果负载多个库,软件会根据你用户授权来决定对哪些库有权限：

　　　　grant all privileges on *.* to amoeba@'%' identified by 'amoeba123'; 这里写的是all 那么就是对所有的库有权限(会自动负载所有的库).

　　　　上面配置文件的库名test.根据这个语句来决定.如果是all.那么直接用写test来测试.方便一点.

　　(2)一主一从的负载写法一:

　　　　主只写.<property name="poolNames">server1</property>

　　　　从只读.<property name="poolNames">server2</property>

　　(3)一主一从的负载写法:

　　　　主负写:<property name="poolNames">server1</property>

　　　　主也负责读,从也负责读.比例1:1 第一读.从.第二次读住.循环写的话,只能写主.<property name="poolNames">server1,server2</property>

　　(4)一主多从的负载写法:

　　　　比如.一台主.3台从.在最上面定义了.server1(master) server2(slave1) server3(slave2) server4(slave3)

　　　　1主只写:<property name="poolNames">server1</property>

　　　　3从负载读 <property name="poolNames">server2,server3,server4</property>

　　　　权重:1:1 3台轮询各一次.持续循环

　　(5)比如我想要.slave1 权重高一点.其它的.2台从.每次读一次.slave1读.2次.

　　　　<property name="poolNames">server2,server2,server3,server4</property>

=================================================================

amoeba.xml配置文件

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

<!DOCTYPE amoeba:configuration SYSTEM "amoeba.dtd">

<amoeba:configuration xmlns:amoeba="http://amoeba.meidusa.com/">

</server>

<!--

每个ConnectionManager都将作为一个线程启动。

manager负责Connection IO读写/死亡检测

-->

<property name="subManagerClassName">com.meidusa.amoeba.net.AuthingableConnectionManager</property>

<!--

default value is avaliable Processors

-->

</connectionManager>

</connectionManagerList>

<!--

一台mysqlServer 需要配置一个pool，

如果多台平等的mysql需要进行loadBalance，

平台已经提供一个具有负载均衡能力的objectPool：com.meidusa.amoeba.mysql.server.MultipleServerPool

简单的配置是属性加上 virtual="true",该Pool 不允许配置factoryConfig

或者自己写一个ObjectPool。

-->

<property name="manager">defaultManager</property>

<property name="user">amoeba</property>

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

</factoryConfig>

</poolConfig>

</dbServer>

<property name="manager">defaultManager</property>

<property name="user">amoeba</property>

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

</factoryConfig>

</poolConfig>

</dbServer>

<property name="poolNames">server1</property>

</poolConfig>

</dbServer>

<property name="poolNames">server1,server2</property>

</poolConfig>

</dbServer>

</dbServerList>

<property name="ruleConfig">${amoeba.home}/conf/rule.xml</property>

<property name="functionConfig">${amoeba.home}/conf/functionMap.xml</property>

<property name="ruleFunctionConfig">${amoeba.home}/conf/ruleFunctionMap.xml</property>

<property name="defaultPool">master</property>

<property name="writePool">master</property>

<property name="readPool">slave</property>

</queryRouter>

</amoeba:configuration>

转载于:https://www.cnblogs.com/xiaocheche/p/7617857.html

你可能感兴趣的文章

数据持久化时的小bug

查看>>

http://www.bootcss.com/

查看>>

python tkinter GUI绘制，以及点击更新显示图片

查看>>

SRM 628 DIV2

查看>>

2018-2019-2 20165314『网络对抗技术』Exp5：MSF基础应用

查看>>

2018icpc徐州OnlineA Hard to prepare

wpf样式绑定行为绑定事件关联路由事件实例

查看>>

Oracle事务

查看>>

String类中的equals方法总结（转载）

Could not resolve view with name '***' in servlet with name 'dispatcher'

php中的isset和empty的用法区别

查看>>

把word文档中的所有图片导出

查看>>

ubuntu 18.04取消自动锁屏以及设置键盘快捷锁屏

查看>>

arcgis api 4.x for js 结合 Echarts4 实现散点图效果（附源码下载）

查看>>