amoeba mysql_Mysql 基于 Amoeba 的 读写分离

article/2025/9/13 13:01:06

首先说明一下amoeba 跟 MySQL proxy在读写分离的使用上面的区别:

在MySQL proxy 6.0版本 上面如果想要读写分离并且 读集群、写集群 机器比较多情况下,用mysql proxy

需要相当大的工作量,目前mysql proxy没有现成的 lua脚本。mysql proxy根本没有配置文件,

lua脚本就是它的全部,当然lua是相当方便的。那么同样这种东西需要编写大量的脚本才能完成一

个复杂的配置。而Amoeba只需要进行相关的配置就可以满足需求。

20cb1cdb96e1d703d4958e070c51c42a.png

假设有这样的使用场景,有三个数据库节点分别命名为Master、Slave1、Slave2如下:

Amoeba: Amoeba <192.168.14.129>

Master: Master <192.168.14.131> (可读写)

Slaves:Slave1 <192.168.14.132>、Slave2<192.168.14.133> (2个平等的数据库。只读/负载均衡)

在 主从数据库 的复制的部分, 任然需要使用数据库自己的复制机制。 Amoeba 不提供复制功能。

1. 起动数据库的主从复制功能。

a. 修改配置文件

master.cnf

server-id = 1 #主数据库标志

# 增加 日志文件, 用于验证读写分离

log = /home/mysql/mysql/log/mysql.log

slave1.cnf

server-id = 2

# 增加 日志文件, 用于验证读写分离

log = /home/mysql/mysql/log/mysql.log

slave2.cnf

server-id = 3

# 增加 日志文件, 用于验证读写分离

log = /home/mysql/mysql/log/mysql.log

b. Master 中 创建两个 只读权限 的用户。 用户名均为:repl_user   密码均为:copy  分别开放给 slave1, slave2

mysql> grant replication slave on *.* to repl_user@192.168.14.132 identified by 'copy';

mysql> grant replication slave on *.* to repl_user@192.168.14.133 identified by 'copy';

c. 查看 Master 信息

mysql> show master status;

+------------------+----------+--------------+------------------+

| File | Position | Binlog_Do_DB | Binlog_Ignore_DB |

+------------------+----------+--------------+------------------+

| mysql-bin.000017 | 2009 | | |

+------------------+----------+--------------+------------------+

1 row in set (0.00 sec)

d. Slave1 ,Slave2 中 启动 Master - Slave 复制功能。

分别执行以下命令

mysql> slave stop;

Query OK, 0 rows affected (0.02 sec)

mysql> change master to

-> master_host='192.168.14.131',

-> master_user='repl_user',

-> master_password='copy',

-> master_log_file='mysql-bin.000017',

-> master_log_pos=2009;

Query OK, 0 rows affected (0.03 sec)

mysql> start slave;

Query OK, 0 rows affected (0.00 sec)

2. Amoeba 读写分离的配置

a. Master , Slave1 ,Slave2 中开放权限给 Amoeba 访问。

在 Master , Slave1 , Slave2 中分别执行

mysql> grant all on test.* to test_user@192.168.14.129 indentified by '1234';

Amoeba 访问三个数据库的账号密码相同。

b. 修改 Amoeba 的配置文件

dbServer.xml

${defaultManager}

64

128

3306

test

test_user

1234

500

500

10

600000

600000

true

true

192.168.14.131

192.168.14.132

192.168.14.133

1

slave1,slave2

amoeba.xml

8066

${clientConnectioneManager}

128

64

root

root

${amoeba.home}/conf/access_list.conf

127.0.0.1

true

${clientConnectioneManager}

20

30

30

500

60

com.meidusa.amoeba.net.ConnectionManager

com.meidusa.amoeba.net.AuthingableConnectionManager

${amoeba.home}/conf/dbServers.xml

${amoeba.home}/conf/rule.xml

${amoeba.home}/conf/ruleFunctionMap.xml

${amoeba.home}/conf/functionMap.xml

1500

master

master

slaves

true

rule.xml

不需要 数据库分片时,不用配置。 但是不能没有 tableRule 元素, 否则报错。 随便写个空规则就行了。

3. 测试读写分离

a. 在 Master , Slave1 , Slave2  中分别查看 日志文件: mysql.log

tail -f ./log/mysql.log

b. 启动 Amoeba, 使用 Mysql GUI Tools 连接 Amoeba

0ade65e975dc002bc6cbfe4d14176053.png

8574916a6d52edb2fbc49f23f3c2949b.png

执行以上几个命令。 查看日志内容。

Master  mysql.log

[mysql@prx1 mysql]$ tail -f log/mysql.log

370 Query SET SESSION sql_mode=''

370 Query SET NAMES utf8

370 Query SHOW FULL TABLES

370 Query SHOW COLUMNS FROM `t_message`

370 Query SHOW COLUMNS FROM `t_user`

370 Query SHOW PROCEDURE STATUS

370 Query SHOW FUNCTION STATUS

110813 15:21:11 370 Query SHOW VARIABLES LIKE 'character_set_server'

370 Query SHOW FULL COLUMNS FROM `test`.`t_message`

110813 15:21:12 370 Query SHOW CREATE TABLE `test`.`t_message`

110813 15:22:40 374 Connect test_user@192.168.14.129 on test

375 Connect test_user@192.168.14.129 on test

376 Connect test_user@192.168.14.129 on test

110813 15:23:40 370 Query insert into t_message values(1, 'c1')

110813 15:24:07 377 Connect test_user@192.168.14.129 on test

378 Connect test_user@192.168.14.129 on test

379 Connect test_user@192.168.14.129 on test

110813 15:24:15 370 Query insert into t_user values(8, 'n8', 'p8')

110813 15:24:24 370 Query SHOW FULL COLUMNS FROM `test`.`t_user`

370 Query SHOW CREATE TABLE `test`.`t_user`

110813 15:24:35 370 Query SHOW FULL COLUMNS FROM `test`.`t_message`

370 Query SHOW CREATE TABLE `test`.`t_message`

Slave1  mysql.log

[mysql@prx2 mysql]$ tail -f log/mysql.log

317 Connect test_user@192.168.14.129 on test

318 Connect test_user@192.168.14.129 on test

110813 15:35:30 315 Query SELECT @@sql_mode

110813 15:35:32 315 Query SELECT @@sql_mode

110813 15:35:44 315 Query SELECT @@SQL_MODE

110813 15:35:46 315 Query SELECT @@SQL_MODE

110813 15:37:18 319 Connect test_user@192.168.14.129 on test

320 Connect test_user@192.168.14.129 on test

110813 15:37:19 321 Connect test_user@192.168.14.129 on test

110813 15:37:26 246 Quit

110813 15:38:21 315 Query SELECT @@SQL_MODE

110813 15:38:22 42 Query BEGIN

42 Query insert into t_message values(1, 'c1')

42 Query COMMIT /* implicit, from Xid_log_event */

110813 15:38:50 322 Connect test_user@192.168.14.129 on test

323 Connect test_user@192.168.14.129 on test

324 Connect test_user@192.168.14.129 on test

110813 15:38:58 42 Query BEGIN

42 Query insert into t_user values(8, 'n8', 'p8')

42 Query COMMIT /* implicit, from Xid_log_event */

110813 15:39:08 315 Query SELECT @@SQL_MODE

110813 15:39:19 315 Query SELECT @@SQL_MODE

110813 15:44:08 325 Connect test_user@192.168.14.129 on test

326 Connect test_user@192.168.14.129 on test

327 Connect test_user@192.168.14.129 on test

Slave2  mysql.log

[mysql@prx3 mysql]$ tail -f log/mysql.log

110813 15:35:08 305 Connect test_user@192.168.14.129 on test

306 Connect test_user@192.168.14.129 on test

307 Connect test_user@192.168.14.129 on test

110813 15:35:31 304 Query SELECT @@sql_mode

304 Query SELECT @@sql_mode

110813 15:35:44 304 Query SELECT @@SQL_MODE

110813 15:35:46 304 Query SELECT * FROM t_message t

110813 15:37:18 308 Connect test_user@192.168.14.129 on test

309 Connect test_user@192.168.14.129 on test

310 Connect test_user@192.168.14.129 on test

110813 15:38:21 8 Query BEGIN

8 Query insert into t_message values(1, 'c1')

8 Query COMMIT /* implicit, from Xid_log_event */

110813 15:38:50 311 Connect test_user@192.168.14.129 on test

312 Connect test_user@192.168.14.129 on test

313 Connect test_user@192.168.14.129 on test

110813 15:38:58 304 Query SELECT @@SQL_MODE

8 Query BEGIN

8 Query insert into t_user values(8, 'n8', 'p8')

8 Query COMMIT /* implicit, from Xid_log_event */

110813 15:39:08 304 Query select * from t_user

110813 15:39:19 304 Query select * from t_message

110813 15:44:08 314 Connect test_user@192.168.14.129 on test

315 Connect test_user@192.168.14.129 on test

316 Connect test_user@192.168.14.129 on test

从日志中可以看出。

在 Master  mysql.log 中,只执行了 insert into 命令。

在 Slave1 中,只是复制了 insert into 命令, 是主从复制的结果

在 Slave2 中, 复制了 insert into 命令,同时还执行了 select 命令。

说明,主从分离已经成功。


http://chatgpt.dhexx.cn/article/LAXZUxOp.shtml

相关文章

amoeba mysql binary_amoeba安装与实现amoeba for mysql读写分离

运行环境 l CentOS6.3 l Jdk1.6.0_30 l amoeba-mysql-binary-2.2.0 l amoeba&#xff1a;192.168.88.17 l master1&#xff1a;192.168.88.10 l slave1&#xff1a;192.168.88.11 一&#xff1a; 安装jdk1.5以上版本 1.1 卸载centos服务器自带版本jdk 1.1.1 …

amoeba-mysql主从复制配置

amoeba-mysql主从复制配置 主mysql192.168.8.186 1. 同步时间ntpdate ntp.org.cn 2. 打开mysql配置文件/etc/my.cnf&#xff0c;在mysqld下添加 a) log-binmaster-bin ---------启动二进制日志系统 b) server-id1 ---------服务id&#xff0c;主服务器server-id比从服务器serv…

mysql amoeba 事务_MySQL-Amoeba

Amoeba 变形虫 Amoeba 变形虫服务默认端口号8066 该软件能识别读写请求&#xff0c;把读写请求分配到不同的后端MySQL服务器 不用像MySQL-router用端口进行区分读写。 实验: 为了查看读写分离效果 本实验就不配置主从复制 1、 首先IP规划 amoeba:192.168.1.76 master:192.168.1…

amoeba mysql proxy_mysql-proxy和amoeba 分别实现Mariadb读写分离

内容概览&#xff1a; 1、mysql-proxy实现Mariadb读写分离 1、1 拓扑图和环境介绍 1、2 mysql-proxy安装 1、3 设置mysql-proxy 1、4 主节点添加mysql-proxy可访问用户 1、5 读写分离验证 2、amoeba 2、1 amoeba工作原理图 2、2 环境拓扑 2、3 配置JAVA环境 2、4 安装配置amoeb…

amoeba mysql_使用Amoeba 实现MySQL DB 读写分离

Amoeba(变形虫)项目是一个开源框架&#xff0c;于2008年开始发布一款 Amoeba for MySQL软件&#xff1b; 这个软件致力于MySQL的分布式数据库前端代理层&#xff0c;它主要在应用层访问MySQL的时候充当SQL路由功能&#xff0c;专注于分布式数据库代理层(Database Proxy)开发&am…

amoeba mysql_mysql中间件-amoeba

中间件&#xff1a;一种提供在不同技术、不同的软件之间共享资源的程序&#xff0c;更大化了利用了数据库的性能&#xff0c;可以无限扩展(注&#xff1a;真实环境中并非如此) 数据库的中间件&#xff1a; mysql proxy (官方版本)性能低&#xff0c;需要lua 脚本 atlas 性能低&…

Amoeba

1.介绍 Amoeba是mysql代理&#xff0c;增强mysql。类似的产品还有MyCat &#xff08;mysql代理&#xff09; 2.资源&#xff1a;点击打开链接c82k 3.准备&#xff1a;amoeba是基于java的所以必须有jdk 4.上传amoeba 5.解压tar包 6.配置文件 amoeba配置文件两个 dbServer…

Mysql基于Amoeba_读写分离搭架

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

mysql基于Amoeba(变形虫)实现读写分离

一&#xff0c;Amoeba介绍 1、什么是amoeba&#xff1f; ​ Amoeba(变形虫)项目&#xff0c;专注 分布式数据库 proxy 开发。座落与Client、DB Server(s)之间。对客户端透明。具有负载均衡、高可用性、sql过滤、读写分离、可路由相关的query到目标数据库、可并发请求多台数据…

Amoeba:开源的分布式数据库Porxy解决方案

什么是Amoeba? Amoeba(变形虫)项目&#xff0c;该开源框架于2008年 开始发布一款 Amoeba for Mysql软件。这个软件致力于MySQL的分布式数据库前端代理层&#xff0c;它主要在应用层访问MySQL的 时候充当SQL路由功能&#xff0c;专注于分布式数据库代理层&#xff08;Database …

findbugs html报告,利用findBugs插件来扫描代码,并用ant生成报告

最近项目要用findbugs插件来生成报告&#xff0c;总结了一下用法和如何生成报告 1&#xff0c; 把下载的压缩包解压后&#xff0c;把 copy到eclipse的plugin目录中去&#xff1b; 2&#xff0c; 重新启动eclipse 3&#xff0c; 打开eclipse->window->Preferences&#xf…

AS之Findbugs

一 前言 Findbugs是由 National Science Foundation支持的一个用静态分析的方式来寻找Java代码中Bug的项目&#xff0c;它是一个静态分析工具&#xff0c;它检查类或者jar文件&#xff0c;将字节码和一组缺陷模式进行对比以发现可能的问题。有了静态分析工具&#xff0c;就可以…

AndroidStudio中FindBugs的简单使用教程

对于代码质量的检查&#xff0c;一直是一个比较棘手的问题。虽然我们部门有关于java代码的各种规范&#xff0c;领导也多次强调对代码的评审。 但是在实际执行过程中&#xff0c;由于开发人员的水平参差不齐&#xff0c;在开发项目时还有各种其他因素&#xff0c;比如时间紧任…

maven项目集成findbugs详解

文章目录 0、概述一、接入方式二、如何使用方式一、在控制台中执行打包命令方式二、使用IntelliJ IDEA的maven工具&#xff08;其他IDE用户忽略&#xff09; 三、bug详情查看四、忽略指定的包、类、类中的方法步骤一、在pom.xml中 增加配置。步骤二、增加配置文件&#xff0c;用…

Findbugs maven 插件使用

Findbugs maven 插件使用 FindBugs™手册 http://findbugs.sourceforge.net/manual/index.html 0、概述 FindBugs是一个静态分析工具&#xff0c;它将**字节码&#xff08;因此需要先编译&#xff09;**与一组缺陷模式进行对比以发现可能的问题。有了静态分析工具&#xff0c;…

检查代码质量的插件Findbugs使用说明

一、简介 Findbugs是一个静态分析工具&#xff0c;它检查类或者jar文件&#xff0c;将字节码与一组缺陷模式进行对比以发现可能的问题。利用这个工具可以在不实际运行程序的情况下对软件进行分析。可以帮助改进代码质量。Findbugs提供了方便操作的可视化界面&#xff0c;同时也…

Findbugs的使用

转载请注明出处&#xff1a;http://blog.csdn.net/feibendexiaoma/article/details/72821781前言 Findbugs很多人都并不陌生&#xff0c;Eclipse中有插件可以帮助查找代码中隐藏的bug&#xff0c;IDEA中也有这款插件。这个插件可以帮助我们查找隐藏的bug,比较重要的功能就是查找…

android studio findbugs 过滤,Android Studio中使用FindBugs

1.什么是FindBugs 一句话简单理解就是&#xff1a;是一个工具&#xff0c;可以用它自动帮你找出代码中潜在的BUG。当然事实并不一定总是如此&#xff0c;也有很多它找不出来的地方。下面将直接介绍如何在Android Studio中的简单使用。有兴趣的童鞋可以自己去了解了解&#xff0…

FindBugs插件

官网 FindBugs官网&#xff1a;http://findbugs.sourceforge.net/ 插件安装 点击settings---->plugins---->Browse repositories 搜索框输入FindBugs-IDEA并点击右侧Install按钮 安装完毕后重启idea&#xff0c;发现左下角多了一个FindBugs图标 插件使用 在被检查文…

eclipse常用插件之FindBugs

1、简介 FindBugs 是由马里兰大学提供的一款开源 Java静态代码分析工具。FindBugs通过检查类文件或 JAR文件&#xff0c;将字节码与一组缺陷模式进行对比从而发现代码缺陷&#xff0c;完成静态代码分析。FindBugs既提供可视化 UI 界面&#xff0c;同时也可以作为 Eclipse插件使…