1、程序启动代码分析:
Proxy 是单例模式的代理启动类,调用CommunicationThread类
public static void main(String[] args){
Proxy.getInstance().run();
}
CommunicationThread解析
CommunicationThread是个多线程类,用于front前段和back后端连接的桥梁,读取front前端的消息,发送给back后端,然后把back后端的返回结果,通过front写给前端工具(navcat or 应用程序),整个连接过程分四步走:
/**
Phase 1: From server to client. Send handshake packet.
Phase 2: From client to server. Send auth packet.
Phase 3: From server to client. send OK/ERROR packet.
Start communication.
*/
估计开源项目Mycat也是在此基础上面发展起来的
二、启动测试:
启动需要修改Backend中的后端数据库IP地址和端口号,以及前端连接对外的响应端口,根据个人需要,你也可以不修改前端端口,默认是50001,但是后端必须改。
public class Backend {
private static final int SERVER_PORT = 3306;
private static final String host = "127.0.0.1";
}
运行结果:
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:1:
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:3:SHOW VARIABLES LIKE 'lower_case_%'
SERVER:
-----------------------------------------------
Variable_nameValue
lower_case_file_systemON
lower_case_table_names1
-----------------------------------------------
CLIENT:3:SHOW VARIABLES LIKE 'profiling'
SERVER:
-----------------------------------------------
Variable_nameValue
profilingOFF
-----------------------------------------------
CLIENT:3:SHOW DATABASES
SERVER:
-----------------------------------------------
Database
information_schema
db1
db2
db3
mysql
performance_schema
test
-----------------------------------------------
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:2:db1
SERVER:OK affectedRows:0 message:null
CLIENT:3:SELECT @@character_set_database, @@collation_database
SERVER:
-----------------------------------------------
@@character_set_database@@collation_database
utf8utf8_general_ci
-----------------------------------------------
CLIENT:3:SHOW FULL TABLES WHERE Table_type != 'VIEW'
SERVER:
-----------------------------------------------
Tables_in_db1Table_type
studentBASE TABLE
t_areaBASE TABLE
t_gaojsBASE TABLE
t_userBASE TABLE
-----------------------------------------------
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:2:db1
SERVER:OK affectedRows:0 message:null
CLIENT:3:SHOW CREATE TABLE `student`
SERVER:
-----------------------------------------------
TableCreate Table
studentCREATE TABLE `student` (
`NO` char(20) NOT NULL DEFAULT '',
`name` varchar(20) DEFAULT NULL,
PRIMARY KEY (`NO`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8
-----------------------------------------------
CLIENT:3:SELECT * FROM `student` LIMIT 0, 1000
SERVER:
-----------------------------------------------
NOname
2012001gaojs
2012002gaojingsong
-----------------------------------------------
CLIENT:3:SHOW COLUMNS FROM `db1`.`student`
SERVER:
-----------------------------------------------
FieldTypeNullKeyDefaultExtra
NOchar(20)NOPRI
namevarchar(20)YES
-----------------------------------------------
CLIENT:1:
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:2:db1
SERVER:OK affectedRows:0 message:null
CLIENT:3:SHOW CREATE TABLE `t_area`
SERVER:
-----------------------------------------------
TableCreate Table
t_areaCREATE TABLE `t_area` (
`id` int(11) NOT NULL,
`t_name` varchar(20) DEFAULT NULL,
`_mycat_op_time` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8
-----------------------------------------------
CLIENT:3:SELECT * FROM `t_area` LIMIT 0, 1000
SERVER:
-----------------------------------------------
idt_name_mycat_op_time
1北京2017-02-02 10:30:46
-----------------------------------------------
CLIENT:3:SHOW COLUMNS FROM `db1`.`t_area`
SERVER:
-----------------------------------------------
FieldTypeNullKeyDefaultExtra
idint(11)NOPRI
t_namevarchar(20)YES
_mycat_op_timetimestampYESon update CURRENT_TIMESTAMP
-----------------------------------------------
CLIENT:1:
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:2:db1
SERVER:OK affectedRows:0 message:null
CLIENT:3:SHOW CREATE TABLE `t_gaojs`
SERVER:
-----------------------------------------------
TableCreate Table
t_gaojsCREATE TABLE `t_gaojs` (
`uuid` int(11) NOT NULL AUTO_INCREMENT,
`id` int(11) DEFAULT NULL,
`address` varchar(20) DEFAULT NULL,
PRIMARY KEY (`uuid`),
KEY `index_name` (`id`),
KEY `index_address` (`address`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8
-----------------------------------------------
CLIENT:3:SELECT * FROM `t_gaojs` LIMIT 0, 1000
SERVER:
-----------------------------------------------
uuididaddress
13中国3
26中国6
39中国9
-----------------------------------------------
CLIENT:3:SHOW COLUMNS FROM `db1`.`t_gaojs`
SERVER:
-----------------------------------------------
FieldTypeNullKeyDefaultExtra
uuidint(11)NOPRIauto_increment
idint(11)YESMUL
addressvarchar(20)YESMUL
-----------------------------------------------
CLIENT:1:
Get a connection.
SERVER:5.5.47
CLIENT:root
SERVER: OK
CLIENT:3:SET NAMES utf8
SERVER:OK affectedRows:0 message:null
CLIENT:2:db1
SERVER:OK affectedRows:0 message:null
CLIENT:3:SHOW CREATE TABLE `t_user`
SERVER:
-----------------------------------------------
TableCreate Table
t_userCREATE TABLE `t_user` (
`id` int(11) NOT NULL DEFAULT '0',
`userName` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8
-----------------------------------------------
CLIENT:3:SELECT * FROM `t_user` LIMIT 0, 1000
SERVER:
-----------------------------------------------
iduserName
10test_mycat
2gaojingsong
-----------------------------------------------
CLIENT:3:SHOW COLUMNS FROM `db1`.`t_user`
SERVER:
-----------------------------------------------
FieldTypeNullKeyDefaultExtra
idint(11)NOPRI0
userNamevarchar(100)YES
-----------------------------------------------
CLIENT:1:
相关推荐
4. **监控与日志**:MySQL Proxy 允许在代理层进行数据通信的监控和日志记录,这对于性能分析、故障排查和安全审计非常有用。 5. **安全性**:MySQL Proxy 可以在客户端和服务器之间添加额外的安全层,例如对本地...
1. **透明代理**:MySQL Proxy 可以悄无声息地插入到客户端和服务器之间,对应用程序来说是完全透明的,无需修改现有代码即可使用。 2. **性能监控**:通过代理,我们可以收集关于查询执行时间、连接频率等信息,...
MySQL Proxy是一款轻量级的中间件,它能够监控、分析或修改在客户端和MySQL服务器之间传输的数据流。通过这个代理,你可以实现负载均衡、故障切换、SQL审计、性能监控等功能,对数据库进行更精细的管理。MySQL Proxy...
MySQL Proxy 是一个处于 Client 端和 MySQL server 端之间的简单程序,它可以监测、分析或改变它们的通信。它使用灵活,没有限制,常见的用途包括:负载平衡,故障、查询分析,查询过滤和修改等等。MySQL Proxy 就是...
5. **运行与测试**:启动 MySQL Proxy 服务,客户端应用程序连接到代理服务器的端口,而不是直接连接到主库或从库。在测试读写分离时,需确保有多个客户端连接,因为代理会在达到最小连接数阈值后才开始执行读写分离...
2. **插件式架构**:通过 Lua 脚本,MySQL Proxy 允许用户在数据流经代理时执行自定义操作,比如记录查询日志、分析性能、执行复杂的数据转换等。 3. **动态配置**:代理可以在运行时重新加载 Lua 脚本,这意味着...
MySQL Proxy是一款开源的轻量级中间件,它允许在MySQL服务器和客户端应用程序之间设置代理,以便于监控、负载均衡和数据过滤。通过使用MySQL Proxy,你可以实现对数据库访问的精细控制,提高系统的可扩展性和可靠性...
MySQL Proxy是一个轻量级的程序,它位于MySQL客户端和服务器之间,具有监控、分析甚至修改两者之间通信的能力。其核心特性之一是读写分离,这能有效提高数据库系统的性能和可扩展性,通过将事务性操作(写操作)路由...
- 启动代理服务器,客户端应用程序将连接到代理而非直接连接到MySQL服务器。 - 利用调试视图查看SQL语句,可能需要设置一些过滤规则或开启特定的日志级别。 5. **实际应用**: - **性能优化**:通过记录和分析...
当Mysql启动的时候会依次读取这几个文件,最终的配置以最后被读到的为准。 安装MySQL会产生5个用户,3个root用户,2个匿名用户。 root@127.0.0.1,root@localhost,root@hostname @localhost,@hostname 可以使用...
04-mysql主从通过mysql-proxy程序实现读写分离.doc 老男孩linux测试读写分离php网站源代码.zip 第十二部 MySQL高可用工具heartbeat实战(33节) 01-heartbeat介绍与作用.avi 02-Heartbeat的工作原理与服务切换...
3. 配置服务:设置MySQL作为系统服务启动,以便在每次计算机启动时自动运行。 4. 测试连接:安装完成后,使用命令行或MySQL Workbench测试数据库连接,确保安装成功。 选择稳定MySQL版本时,需要注意以下几个要点:...
通过以上分析,可以看出MySQL 5.6参考手册是一份全面且详尽的文档,不仅覆盖了MySQL的核心功能,还提供了丰富的工具和指南来帮助用户更好地理解和使用MySQL数据库系统。无论是对于开发人员还是系统管理员来说,这份...
- **运行**:启动MySQL Proxy后,所有的数据库连接都将通过这个代理进行,它会自动根据预设规则将读操作路由到从库,写操作路由到主库。 2. **mysqlnd_ms**: mysqlnd_ms是MySQL Native Driver的一个扩展,它允许...
MySQL因其高效、可靠和易于管理的特点,在Web应用程序中尤其受到青睐。"MySQL-master.zip"这个压缩包很可能包含了关于MySQL学习和实践的各种资源。 首先,我们可以从“MySQL-master”这个目录名推测,这可能是一个...