我的编程空间,编程开发者的网络收藏夹
学习永远不晚

MySQL 读写分离 (基于Amoeba)

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

MySQL 读写分离 (基于Amoeba)

一.MySQL读写分离

    主数据库处理事务性查询,从数据库处理select查询。数据库复制用来把事务性查询导致的变更同步到从数据库中。

MySQL 读写分离 (基于Amoeba)

二.最为常见的读写分离有两种:

1.基于程序代码实现

   在代码中根据select,insert进程路由分类;

   优点:性能好,因为在代码中实现,不需要额外的硬件设备;

   缺点:需要开发人员来实现,对代码改动比较大,不适合大型复杂应用;

2.基于代理层实现

  MySQL-Proxy:隶属于MySQL开源项目;

  Amoeba:Amoeba是一个以MySQL为底层数据存储,并对应用提供MySQL协议接口的proxy。它集中地响应应用的请求,依据用户事先设置的规则,将SQL请求发送到特定的数据库上执行。基于此可以实现负载均衡、读写分离、高可用性等需求;

三.实验环境

OS:CentOS 6.5 x64

Amoeba:192.168.0.128

master:192.168.0.134

slave:192.168.0.135

client:192.168.0.137

三.配置主从复制

1.MySQL读写分离是基于主从复制配置的,先配置好主从复制,再配置读写分离。

  主从复制博文连接:http://guoxh.blog.51cto.com/10976315/1922643

2.添加授权账号供Amoeba访问

 master和slave:

mysql> grant all on *.* to  'proxy'@'192.168.0.128' identified by '123456';
Query OK, 0 rows affected (0.00 sec)

mysql> flush privileges;
Query OK, 0 rows affected (0.00 sec)

四.Amoeba安装配置

1. Amoeba是基于JDK开发的,所有先安装JAVA环境

[root@amoeba ~]# chmod +x jdk-6u14-linux-x64.bin 
[root@amoeba ~]# ./jdk-6u14-linux-x64.bin 
[root@amoeba ~]# cat /etc/profile.d/java.sh 
export JAVA_HOME=/usr/local/jdk1.6
export CLASSPATH=$CLASSPATH:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/lib:$PATH:$HOME/bin
[root@amoeba ~]# source  /etc/profile.d/java.sh 
[root@amoeba ~]# java -version
java version "1.6.0_14"
Java(TM) SE Runtime Environment (build 1.6.0_14-b08)
Java HotSpot(TM) 64-Bit Server VM (build 14.0-b16, mixed mode)
#JAVA环境配置完成

2.安装Amoeba

[root@amoeba ~]# mkdir /usr/local/amoeba
[root@amoeba ~]# tar xf  amoeba-mysql-binary-2.2.0.tar.gz  -C /usr/local/amoeba
[root@amoeba ~]# ls /usr/local/amoeba/
benchmark  bin  changelogs.txt  conf  lib  LICENSE.txt  README.html
[root@amoeba ~]# cat /etc/profile.d/amoeba.sh 
export AMOEBA_HOME=/usr/local/amoeba/
export PATH=$PATH:$AMOEBA_HOME/bin
[root@amoeba ~]# source  /etc/profile.d/amoeba.sh 
[root@amoeba ~]# /usr/local/amoeba/bin/amoeba
amoeba start|stop  # Amoeba安装成功

3.编辑amoeba.xml配置文件

[root@amoeba conf]# cd /usr/local/amoeba/conf/
[root@amoeba conf]# cp amoeba.xml  amoeba$(date +"%Y_%m_%d").xml #修改前备份一份
[root@amoeba conf]# vim amoeba.xml
27  <property name="authenticator">
28       <bean class="com.meidusa.amoeba.mysql.server.MysqlClientAuthenticator">
29 
30           <property name="user">amoeba</property>   #设置client连接的用户
31 
32           <property name="password">amoeba</property> #设置client连接的密码
33 
34              <property name="filter">
35              <bean class="com.meidusa.amoeba.server.IPAccessController">
36                <property name="ipFile">${amoeba.home}/conf/access_list.conf</property>
37              </bean>
38            </property>
39       </bean>
40  </property>

112                 </property>
113                 <property name="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>
114                 <property name="LRUMapSize">1500</property>
115                 <property name="defaultPool">master/property> #指定默认为master
116 
117                 <!--  #删除注释
118                 <property name="writePool">master</property> #指定写操作为master
119                 <property name="readPool">slaves</property> #指定读操作为slave
120                 -->  #删除注释
121                 <property name="needParse">true</property>

3.编辑dbServers.xml

25       <!-- mysql user -->
26       <property name="user">proxy</property>  #填mysql授权的用户
27 
28       <!--  mysql password -->
29       <property name="password">123456</property> #填MySQL授权的用户密码
30
 
45         <dbServer name="master"  parent="abstractServer">
46                 <factoryConfig>
47                         <!-- mysql ip -->
48                         <property name="ipAddress">192.168.0.134</property> #指定master的IP
49                 </factoryConfig>
50         </dbServer>
51 
52         <dbServer name="slave"  parent="abstractServer">
53                 <factoryConfig>
54                         <!-- mysql ip -->
55                         <property name="ipAddress">192.168.0.135</property> #指定slave的IP
56                 </factoryConfig>
57         </dbServer>
58         <dbServer name="slaves" virtual="true">
59                 <poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">
60                         <!-- Load balancing strategy: 1=ROUNDROBIN , 2=WEIGHTBASED , 3=HA-->
61                         <property name="loadbalance">1</property>
62 
63                         <!-- Separated by commas,such as: server1,server2,server1 -->
64                         <property name="poolNames">slave</property>
65                 </poolConfig>
66         </dbServer>

4.启动服务

[root@amoeba ~]# amoeba start &
[1] 2666
[root@amoeba ~]# log4j:WARN log4j config load completed from file:/usr/local/amoeba/conf/log4j.xml
2017-05-07 00:42:16,692 INFO  context.MysqlRuntimeContext - Amoeba for Mysql current versoin=5.1.45-mysql-amoeba-proxy-2.2.0
log4j:WARN ip access config load completed from file:/usr/local/amoeba/conf/access_list.conf
2017-05-07 00:42:17,064 INFO  net.ServerableConnectionManager - Amoeba for Mysql listening on 0.0.0.0/0.0.0.0:8066.
2017-05-07 00:42:17,067 INFO  net.ServerableConnectionManager - Amoeba Monitor Server listening on /127.0.0.1:56460.

[root@amoeba ~]# netstat -anptl | grep java
tcp        0      0 ::ffff:127.0.0.1:56460      :::*                        LISTEN      2666/java           
tcp        0      0 :::8066                     :::*                        LISTEN      2666/java           
tcp        0      0 ::ffff:192.168.0.128:37361  ::ffff:192.168.0.135:3306   ESTABLISHED 2666/java           
tcp        0      0 ::ffff:192.168.0.128:35241  ::ffff:192.168.0.134:3306   ESTABLISHED 2666/java           
#Amoeba默认端口为8066


五.测试

1.客户端连接Amoeba

[root@client ~]# mysql -uamoeba -p123456 -h 192.168.0.128  -P8066

2.新建一个数据库

mysql> create database guoxh;
Query OK, 1 row affected (0.01 sec)

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| aaa                |
| guoxh              |
| mysql              |
| test               |
+--------------------+
5 rows in set (0.01 sec)

3.master和slave查看数据库

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| aaa                |
| guoxh              | #刚建的数据库已经同步
| mysql              |
| test               |
+--------------------+
5 rows in set (0.00 sec)

五.测试读写分离:

1.在master新建一个表,同步到slave上,然后关掉slave功能,在slave上插入区别语句

master:创建名为student的表

mysql> show tables;
Empty set (0.00 sec)

mysql> create table student (id int(10),name varchar(10),info varchar(50));
Query OK, 0 rows affected (0.01 sec)

mysql> show tables;
+-----------------+
| Tables_in_guoxh |
+-----------------+
| student         |
+-----------------+
1 row in set (0.00 sec)

slave:停止同步

mysql> show tables;
+-----------------+
| Tables_in_guoxh |
+-----------------+
| student         |
+-----------------+
1 row in set (0.00 sec)
mysql> stop slave;
Query OK, 0 rows affected (0.00 sec)

master:插入区别数据

mysql> insert into student values('1','zhangsan','Mysql_master');
Query OK, 1 row affected (0.01 sec)
mysql> select * from student;
+------+----------+--------------+
| id   | name     | info         |
+------+----------+--------------+
|    1 | zhangsan | Mysql_master |
+------+----------+--------------+
1 row in set (0.00 sec)

slave:插入区别数据

mysql> select * from student;
Empty set (0.00 sec)

mysql> insert into student values('2','lisi','Mysql_slave');
Query OK, 1 row affected (0.00 sec)

mysql> select * from student;
+------+------+-------------+
| id   | name | info        |
+------+------+-------------+
|    2 | lisi | Mysql_slave |
+------+------+-------------+
1 row in set (0.00 sec)

3.测试读操作:

client:

mysql> show tables;
+-----------------+
| Tables_in_guoxh |
+-----------------+
| student         |
+-----------------+
1 row in set (0.00 sec)

mysql> select * from student;
+------+------+-------------+
| id   | name | info        |
+------+------+-------------+
|    2 | lisi | Mysql_slave |
+------+------+-------------+
1 row in set (0.00 sec)

mysql> select * from student;
+------+------+-------------+
| id   | name | info        |
+------+------+-------------+
|    2 | lisi | Mysql_slave |
+------+------+-------------+
1 row in set (0.00 sec)

# 此时,读操作已经已经全部分配到slave上面。

4.测试写操作

client:插入一条数据,这里是看不到数据的,得到master查看

mysql> insert into student values('3','wangwu','Mysql_client');
Query OK, 1 row affected (0.00 sec)

mysql> select * from student;
+------+------+-------------+
| id   | name | info        |
+------+------+-------------+
|    2 | lisi | Mysql_slave |
+------+------+-------------+
1 row in set (0.00 sec)

master:

mysql> select * from student;
+------+----------+--------------+
| id   | name     | info         |
+------+----------+--------------+
|    1 | zhangsan | Mysql_master |
|    3 | wangwu   | Mysql_client |
+------+----------+--------------+
2 rows in set (0.00 sec)

#此时,写操作全部分给了master。


到此为止,MySQL已经实现了读写分离!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

MySQL 读写分离 (基于Amoeba)

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

mysql 基于mysql-proxy实现读写分离

mysql 读写分离读写分离首先不推荐使用,很多业务场景也没有必要,不仅增加技术复杂度,而且可能会导致读到落后的数据,建议优化数据库,推荐使用keepalive+mysql双主复制的方案然后mysql-proxy是官方推出的中间件,不仅无法高可用,而且这个项目
mysql 基于mysql-proxy实现读写分离
2015-08-29

基于 SpringBoot 实现 MySQL 读写分离的问题

- 前言 - 首先思考一个问题: 在高并发的场景中,关于数据库都有哪些优化的手段? 常用的实现方法有以下几种:读写分离、加缓存、主从架构集群、分库分表等,在互联网应用中,大部分都是读多写少的场景,设置两个库,主库和读库。
2022-05-21

利用amoeba(变形虫)实现mysql数据库读写分离

前期准备工作: 1.两个数据库,一主一从,主从同步; master: 172.22.10.237:3306 ;主库负责写入操作; slave: 10.4.66.58:3306 ; 从库负责读取操作; amoeba: 172.22.10.237:8066 ; 我
利用amoeba(变形虫)实现mysql数据库读写分离
2015-09-22

Java基于JNDI怎么实现读写分离

这篇文章主要介绍“Java基于JNDI怎么实现读写分离”,在日常操作中,相信很多人在Java基于JNDI怎么实现读写分离问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java基于JNDI怎么实现读写分离”的疑
2023-06-22

MySQL-mycat读写分离

Mycat 需要安装JDK 1.7 或者以上版本第一步:下载jdk-8u131-linux-x64.tar.gz文件 http://haixi.sfkcn.com:8080/201704/tools/jdk-linux-x64.tar.gz第二步:新建/usr
MySQL-mycat读写分离
2021-04-03

mysql如何读写分离

mysql 读写分离是一种数据库架构,将数据库分为主库和从库,主库负责写入操作,从库负责读操作,以降低主库负载和提高并发读能力。实现 mysql 读写分离需要:搭建主从复制环境、修改应用程序配置、使用代理或中间件。读写分离的优势包括:降低主
mysql如何读写分离
2024-04-14

编程热搜

目录