一个完整的mysql读写分离环境包括以下几个部分:
- 应用程序client
- database proxy
- database集群
在本次实战中,应用程序client基于c3p0连接后端的database proxy。database proxy负责管理client实际访问database的路由策略,采用开源框架amoeba。database集群采用mysql的master-slave的replication方案。整个环境的结构图如下所示:
实战步骤与详解
一.搭建mysql的master-slave环境
1)分别在host1(10.20.147.110)和host2(10.20.147.111)上安装mysql(5.0.45),具体安装方法可见官方文档
2)配置master
首先编辑/etc/my.cnf,添加以下配置:
log-bin=mysql-bin #slave会基于此log-bin来做replication
server-id=1 #master的标示
binlog-do-db = amoeba_study #用于master-slave的具体数据库
然后添加专门用于replication的用户:
mysql> GRANT REPLICATION SLAVE ON *.* TO repl@10.20.147.111 IDENTIFIED BY '111111';
重启mysql,使得配置生效:
/etc/init.d/mysqld restart
最后查看master状态:
3)配置slave
首先编辑/etc/my.cnf,添加以下配置:
server-id=2 #slave的标示
配置生效后,配置与master的连接:
mysql> CHANGE MASTER TO
-> MASTER_HOST='10.20.147.110',
-> MASTER_USER='repl',
-> MASTER_PASSWORD='111111',
-> MASTER_LOG_FILE='mysql-bin.000003',
-> MASTER_LOG_POS=161261;
其中MASTER_HOST是master机的ip,MASTER_USER和MASTER_PASSWORD就是我们刚才在master上添加的用户,MASTER_LOG_FILE和MASTER_LOG_POS对应与master status里的信息
最后启动slave:
mysql> start slave;
4)验证master-slave搭建生效
通过查看slave机的log(/var/log/mysqld.log):
100703 10:51:42 [Note] Slave I/O thread: connected to master 'repl@10.20.147.110:3306', replication started in log 'mysql-bin.000003' at position 161261
如看到以上信息则证明搭建成功,如果有问题也可通过此log找原因
二.搭建database proxy
此次实战中database proxy采用amoeba ,它的相关信息可以查阅官方文档,不在此详述
1)安装amoeba
下载amoeba(1.2.0-GA)后解压到本地(D:\openSource\amoeba-mysql-1.2.0-GA),即完成安装
2)配置amoeba
先配置proxy连接和与各后端mysql服务器连接信息(D:\openSource\amoeba-mysql-1.2.0-GA\conf\amoeba.xml):
- <server>
- <!-- proxy server绑定的端口 -->
- <property name="port">8066</property>
- <!-- proxy server绑定的IP -->
- <!--
- <property name="ipAddress">127.0.0.1</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">root</property>
- </server>
- <server>
- <!-- proxy server绑定的端口 -->
- <property name="port">8066</property>
- <!-- proxy server绑定的IP -->
- <!--
- <property name="ipAddress">127.0.0.1</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">root</property>
- </server>
以上是proxy提供给client的连接配置
- <dbServerList>
- <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.20.147.110</property>
- <property name="schema">amoeba_study</property>
- <!-- 用于登陆mysql的用户名 -->
- <property name="user">root</property>
- <!-- 用于登陆mysql的密码 -->
- <property name="password"></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>
- <dbServer name="server2">
- <!-- 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.20.147.111</property>
- <property name="schema">amoeba_study</property>
- <!-- 用于登陆mysql的用户名 -->
- <property name="user">root</property>
- <!-- 用于登陆mysql的密码 -->
- <property name="password"></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>
- </dbServerList>
- <dbServerList>
- <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.20.147.110</property>
- <property name="schema">amoeba_study</property>
- <!-- 用于登陆mysql的用户名 -->
- <property name="user">root</property>
- <!-- 用于登陆mysql的密码 -->
- <property name="password"></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>
- <dbServer name="server2">
- <!-- 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.20.147.111</property>
- <property name="schema">amoeba_study</property>
- <!-- 用于登陆mysql的用户名 -->
- <property name="user">root</property>
- <!-- 用于登陆mysql的密码 -->
- <property name="password"></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>
- </dbServerList>
以上是proxy与后端各mysql数据库服务器配置信息,具体配置见注释很明白了
最后配置读写分离策略:
- <queryRouter class="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">
- <property name="LRUMapSize">1500</property>
- <property name="defaultPool">server1</property>
- <property name="writePool">server1</property>
- <property name="readPool">server2</property>
- <property name="needParse">true</property>
- </queryRouter>
- <queryRouter class="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">
- <property name="LRUMapSize">1500</property>
- <property name="defaultPool">server1</property>
- <property name="writePool">server1</property>
- <property name="readPool">server2</property>
- <property name="needParse">true</property>
- </queryRouter>
从以上配置不然发现,写操作路由到server1(master),读操作路由到server2(slave)
3)启动amoeba
在命令行里运行D:\openSource\amoeba-mysql-1.2.0-GA\amoeba.bat即可:
log4j:WARN log4j config load completed from file:D:\openSource\amoeba-mysql-1.2.0-GA\conf\log4j.xml
log4j:WARN ip access config load completed from file:D:\openSource\amoeba-mysql-1.2.0-GA/conf/access_list.conf
2010-07-03 09:55:33,821 INFO net.ServerableConnectionManager - Server listening on 0.0.0.0/0.0.0.0:8066.
三.client端调用与测试
1)编写client调用程序
具体程序细节就不详述了,只是一个最普通的基于mysql driver的jdbc的数据库操作程序
2)配置数据库连接
本client基于c3p0,具体数据源配置如下:
- <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
- destroy-method="close">
- <property name="driverClass" value="com.mysql.jdbc.Driver" />
- <property name="jdbcUrl" value="jdbc:mysql://localhost:8066/amoeba_study" />
- <property name="user" value="root" />
- <property name="password" value="root" />
- <property name="minPoolSize" value="1" />
- <property name="maxPoolSize" value="1" />
- <property name="maxIdleTime" value="1800" />
- <property name="acquireIncrement" value="1" />
- <property name="maxStatements" value="0" />
- <property name="initialPoolSize" value="1" />
- <property name="idleConnectionTestPeriod" value="1800" />
- <property name="acquireRetryAttempts" value="6" />
- <property name="acquireRetryDelay" value="1000" />
- <property name="breakAfterAcquireFailure" value="false" />
- <property name="testConnectionOnCheckout" value="true" />
- <property name="testConnectionOnCheckin" value="false" />
- </bean>
- <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
- destroy-method="close">
- <property name="driverClass" value="com.mysql.jdbc.Driver" />
- <property name="jdbcUrl" value="jdbc:mysql://localhost:8066/amoeba_study" />
- <property name="user" value="root" />
- <property name="password" value="root" />
- <property name="minPoolSize" value="1" />
- <property name="maxPoolSize" value="1" />
- <property name="maxIdleTime" value="1800" />
- <property name="acquireIncrement" value="1" />
- <property name="maxStatements" value="0" />
- <property name="initialPoolSize" value="1" />
- <property name="idleConnectionTestPeriod" value="1800" />
- <property name="acquireRetryAttempts" value="6" />
- <property name="acquireRetryDelay" value="1000" />
- <property name="breakAfterAcquireFailure" value="false" />
- <property name="testConnectionOnCheckout" value="true" />
- <property name="testConnectionOnCheckin" value="false" />
- </bean>
值得注意是,client端只需连到proxy,与实际的数据库没有任何关系,因此jdbcUrl、user、password配置都对应于amoeba暴露出来的配置信息
3)调用与测试
首先插入一条数据:insert into zone_by_id(id,name) values(20003,'name_20003')
通过查看master机上的日志/var/lib/mysql/mysql_log.log:
100703 11:58:42 1 Query set names latin1
1 Query SET NAMES latin1
1 Query SET character_set_results = NULL
1 Query SHOW VARIABLES
1 Query SHOW COLLATION
1 Query SET autocommit=1
1 Query SET sql_mode='STRICT_TRANS_TABLES'
1 Query SHOW VARIABLES LIKE 'tx_isolation'
1 Query SHOW FULL TABLES FROM `amoeba_study` LIKE 'PROBABLYNOT'
1 Prepare [1] insert into zone_by_id(id,name) values(?,?)
1 Prepare [2] insert into zone_by_id(id,name) values(?,?)
1 Execute [2] insert into zone_by_id(id,name) values(20003,'name_20003')
得知写操作发生在master机上
通过查看slave机上的日志/var/lib/mysql/mysql_log.log:
100703 11:58:42 2 Query insert into zone_by_id(id,name) values(20003,'name_20003')
得知slave同步执行了这条语句
然后查一条数据:select t.name from zone_by_id t where t.id = 20003
通过查看slave机上的日志/var/lib/mysql/mysql_log.log:
100703 12:02:00 33 Query set names latin1
33 Prepare [1] select t.name from zone_by_id t where t.id = ?
33 Prepare [2] select t.name from zone_by_id t where t.id = ?
33 Execute [2] select t.name from zone_by_id t where t.id = 20003
得知读操作发生在slave机上
并且通过查看slave机上的日志/var/lib/mysql/mysql_log.log发现这条语句没在master上执行
通过以上验证得知简单的master-slave搭建和实战得以生效
相关推荐
springboot结合mysql主从来实现读写分离 一、实现的功能 1、基于springboot框架,application.yml配置多个数据源,使用AOP以及AbstractRootingDataSource、ThreadLocal来实现多数据源切换,以实现读写分离。mysql...
Spring与MySQL读写分离** Spring作为一个灵活的Java应用程序框架,提供了多种方式来支持数据库的读写分离。通过配置数据源、事务管理器以及AOP(面向切面编程)等机制,Spring可以帮助我们透明地处理读写操作的路由...
常见的MySQL读写分离软件有MySQL Proxy、MaxScale、HAProxy、AMQP等。每款软件都有其特点和适用场景,比如MySQL Proxy轻量级但功能相对简单,MaxScale是MySQL公司官方出品,功能强大且易于集成,HAProxy则常用于网络...
在IT行业中,数据库读写分离...总之,通过SpringBoot实现MySQL读写分离,不仅提高了系统的可扩展性和稳定性,还降低了单点故障的风险。在实际项目中,需要根据业务需求和系统规模,灵活选择合适的技术方案和配置策略。
### 使用mysql-proxy实现MySQL读写分离 随着业务规模的不断扩大,数据库系统往往成为整个系统中的瓶颈之一。为了提高系统的响应速度以及数据处理能力,一种常用的技术手段就是采用**读写分离**的方式。读写分离的...
MySQL 读写分离实现原理和解决方案 MySQL 读写分离是指将数据库的读写操作分离到不同的服务器上,以提高数据库的性能和可用性。MySQL 读写分离可以通过主从复制实现,即一个主库和多个从库。主库负责写操作,从库...
本文将深入探讨如何利用Spring AOP(面向切面编程)实现应用层的MySQL读写分离,并结合一主多从的配置来进行详细讲解。 首先,我们需要理解MySQL的主从复制机制。在主从复制中,数据的写操作(INSERT、UPDATE、...
### MySQL读写分离及主从同步延时解决方案 #### 一、引言 在现代互联网应用中,随着用户量的增长和业务复杂度的提高,单一数据库服务器往往难以满足高并发场景下的性能需求。为了有效应对这种挑战,许多企业选择了...
基于SpringBoot,来实现MySQL读写分离技术.zip基于SpringBoot,来实现MySQL读写分离技术.zip基于SpringBoot,来实现MySQL读写分离技术.zip基于SpringBoot,来实现MySQL读写分离技术.zip基于SpringBoot,来实现MySQL...
MySQL读写分离是一种数据库优化策略,它通过将数据库的读操作和写操作分离到不同的服务器上,以提高系统的并发处理能力和整体性能。在高流量的Web应用中,数据库经常成为性能瓶颈,读写分离可以有效地解决这个问题。...
### MySQL读写分离集群最佳实践 #### 一、概述 在现代互联网应用中,随着数据量的不断增长以及用户访问量的激增,单一数据库服务器往往难以满足高性能、高可用性的需求。为了应对这一挑战,一种常见的解决方案是...
在进行MySQL读写分离配置前,我们需要确保有一个稳定的环境。本次配置环境为CentOS 7.2,并使用MySQL 5.7版本。 - **主数据库服务器(Master)**:192.168.206.100 - **从数据库服务器(Slave)**:192.168.206.200...
mysql读写分离 中间件amoeba配置文件配置号的改几个参数就可以直接用https://blog.csdn.net/z13615480737/article/details/79951505 参考这个改2个文件就可直接用
### MySQL读写分离实现 #### 一、MySQL读写分离概述 MySQL的读写分离是一种常用的数据库优化技术,主要用于提高数据库系统的并发处理能力和可用性。它通过将数据查询(读操作)与数据更新(写操作)分布在不同的...
在linux下用于部署读写分离的中间件maxscale。它是实现mysql数据库的读写分离的
基于Mycat实现Mysql读写分离以及分库分表详解 本文档详细介绍了基于Mycat实现Mysql读写分离以及分库分表的技术,涵盖了Mycat安装、配置、读写分离、分库分表等多方面的知识点。 一、读写分离 Mycat读写分离是指将...
构建高性能web之路mysql读写分离实战 本文将详细介绍如何构建高性能的Web应用程序之路的MySQL读写分离实战。读写分离是MySQL高性能解决方案之一,将读写操作分离到不同的数据库服务器上,以提高数据库的性能和可...
本教程将通过一系列视频和文档,详细讲解如何在MySQL环境中实现读写分离。 首先,我们来看“11-主从复制的原理.avi”。主从复制是实现读写分离的基础,它是指在一个MySQL集群中,一个节点(主节点)负责数据的写入...
MySQL主从复制(Master-Slave)的方式来同步数据,再通过读写分离(MySQL-Proxy/Amoeba)来提升数据库的并发负载能力 这样的方案来进行部署与实施的