`
gaojingsong
  • 浏览: 1201824 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
文章分类
社区版块
存档分类
最新评论

【非常优秀的MySQLProxy程序启动分析】

阅读更多

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:

 

  • 大小: 100.5 KB
  • 大小: 84.3 KB
0
0
分享到:
评论

相关推荐

    mysql proxy

    4. **监控与日志**:MySQL Proxy 允许在代理层进行数据通信的监控和日志记录,这对于性能分析、故障排查和安全审计非常有用。 5. **安全性**:MySQL Proxy 可以在客户端和服务器之间添加额外的安全层,例如对本地...

    mysql-proxy-0.8.5-windows-x86-32bit

    1. **透明代理**:MySQL Proxy 可以悄无声息地插入到客户端和服务器之间,对应用程序来说是完全透明的,无需修改现有代码即可使用。 2. **性能监控**:通过代理,我们可以收集关于查询执行时间、连接频率等信息,...

    windows++mysql-proxy全部数据包

    MySQL Proxy是一款轻量级的中间件,它能够监控、分析或修改在客户端和MySQL服务器之间传输的数据流。通过这个代理,你可以实现负载均衡、故障切换、SQL审计、性能监控等功能,对数据库进行更精细的管理。MySQL Proxy...

    Mysql Proxy 实现mysql读写分离.pdf

    MySQL Proxy 是一个处于 Client 端和 MySQL server 端之间的简单程序,它可以监测、分析或改变它们的通信。它使用灵活,没有限制,常见的用途包括:负载平衡,故障、查询分析,查询过滤和修改等等。MySQL Proxy 就是...

    MysqlProxy实现mysql读写分离[整理].pdf

    5. **运行与测试**:启动 MySQL Proxy 服务,客户端应用程序连接到代理服务器的端口,而不是直接连接到主库或从库。在测试读写分离时,需确保有多个客户端连接,因为代理会在达到最小连接数阈值后才开始执行读写分离...

    mysql-proxy安装部署.docx

    2. **插件式架构**:通过 Lua 脚本,MySQL Proxy 允许用户在数据流经代理时执行自定义操作,比如记录查询日志、分析性能、执行复杂的数据转换等。 3. **动态配置**:代理可以在运行时重新加载 Lua 脚本,这意味着...

    mysql-proxy

    MySQL Proxy是一款开源的轻量级中间件,它允许在MySQL服务器和客户端应用程序之间设置代理,以便于监控、负载均衡和数据过滤。通过使用MySQL Proxy,你可以实现对数据库访问的精细控制,提高系统的可扩展性和可靠性...

    Ubuntu10下如何搭建MySQL Proxy读写分离探讨

    MySQL Proxy是一个轻量级的程序,它位于MySQL客户端和服务器之间,具有监控、分析甚至修改两者之间通信的能力。其核心特性之一是读写分离,这能有效提高数据库系统的性能和可扩展性,通过将事务性操作(写操作)路由...

    mysql-proxy:GolangMySQL代理调试SQL

    - 启动代理服务器,客户端应用程序将连接到代理而非直接连接到MySQL服务器。 - 利用调试视图查看SQL语句,可能需要设置一些过滤规则或开启特定的日志级别。 5. **实际应用**: - **性能优化**:通过记录和分析...

    Mysql学习笔记

    当Mysql启动的时候会依次读取这几个文件,最终的配置以最后被读到的为准。 安装MySQL会产生5个用户,3个root用户,2个匿名用户。 root@127.0.0.1,root@localhost,root@hostname @localhost,@hostname 可以使用...

    2017最新老男孩MySQL高级专业DBA实战课程全套【清晰不加密】,看完教程月入40万没毛病

    04-mysql主从通过mysql-proxy程序实现读写分离.doc 老男孩linux测试读写分离php网站源代码.zip 第十二部 MySQL高可用工具heartbeat实战(33节) 01-heartbeat介绍与作用.avi 02-Heartbeat的工作原理与服务切换...

    mysql安装图解 mysql图文安装教程(详细说明)

    3. 配置服务:设置MySQL作为系统服务启动,以便在每次计算机启动时自动运行。 4. 测试连接:安装完成后,使用命令行或MySQL Workbench测试数据库连接,确保安装成功。 选择稳定MySQL版本时,需要注意以下几个要点:...

    mysql_refman-5.6-en.a4.pdf

    通过以上分析,可以看出MySQL 5.6参考手册是一份全面且详尽的文档,不仅覆盖了MySQL的核心功能,还提供了丰富的工具和指南来帮助用户更好地理解和使用MySQL数据库系统。无论是对于开发人员还是系统管理员来说,这份...

    MySQL的使用中实现读写分离的教程

    - **运行**:启动MySQL Proxy后,所有的数据库连接都将通过这个代理进行,它会自动根据预设规则将读操作路由到从库,写操作路由到主库。 2. **mysqlnd_ms**: mysqlnd_ms是MySQL Native Driver的一个扩展,它允许...

    MySQL-master.zip

    MySQL因其高效、可靠和易于管理的特点,在Web应用程序中尤其受到青睐。"MySQL-master.zip"这个压缩包很可能包含了关于MySQL学习和实践的各种资源。 首先,我们可以从“MySQL-master”这个目录名推测,这可能是一个...

Global site tag (gtag.js) - Google Analytics