mysql代理服务器（云数据库和普通数据库）

用java8基于vert.x3中国最宽瀑布 快速实现一个最简单的mysql代理服务器，只需要5分钟时间。

什么是mysql 代理？

mysql代理是介于client端和mysql服务端中间层服务，如下图所示：

这里写图片描述

为什么要使用代理？

大部人都知道使用代理的好处，毕竟，随着互联网越来越普及，互联网系统越来越庞大、复杂，性能要求越来越高，为了让整个系统具有更好的扩展性、更高的性能、解藕等多种特性，在数据库层面引入代理层是目前互联网系统常见的架构设计方案。总的来说，在数据库层面引入代理会带来以下好处：

将不同类型的请求分发的不同的rver以此实现读写分离、负载均衡。来自不同客户端的请求分发到不同的rver实现后端多租户数据库服务，当然，类似的原理还可以实现分库分表、一个请求写到多个rver50字优美段落或者不同的源端如消息队列。监控统计客户端的请求情况，请求分布统计、请求类型等，以此来优化数据库的使用。总之，可以实现你想要的诸多功能。

如何用java快速实现一个最简单的代理呢？

首先，准备开发工具套件，我们并不会引入过多工具包，仅仅需要：

java8vert.x 3

如果你是用maven做为项目管理工具，请将vert.x 3引入：

<dependency> <groupid>io.vertx</groupid> <artifactid>vertx-core</artifactid> <version>3.3.2</version></dependency>

代码实现：

package com.maxleap.mysqlproxy;import io.vertx.core.abstractverticle;import io.vertx.core.vertx;import io.vertx.core.logging.logger;import io.vertx.core.logging.loggerfactory;import io.vertx.core.net.netclient;i竞折腰mport io.vertx.core.net.netrver;import io.vertx.core.net.netsocket;/** * @author sneaky * @since 1.0.0 */public class mysqlproxyrver { private static final logger logger = loggerfactory.getlogger(mysqlproxyrver.class); public static void main(string[] args) { vertx.vertx().deployverticle(new mysqlproxyrververticle()); } public static class mysqlproxyrververticle extends abstractverticle { private final int port = 3306; private final string mysqlhost = "10.10.0.6"; @override public void start() throws exception { netrver netrver = vertx.createnetrver();//创建代理服务器 netclient netclient = vertx.createnetclient();//创建连接mysql客户端 netrver.connecthandler(socket -> netclient.connect(port, mysqlhost, result -> { //响应来自客户端的连接请求，成功之后，在建立一个与目标mysql服务器的连接 if (result.succeeded()) { //与目标mysql服务器成功连接连接之后，创造一个mysqlproxyconnection对象,并执行代理方法 new mysqlproxyconnection(socket, result.result()).proxy(); } el { logger.error(result.cau().getmessage(), result.cau()); socket.clo(); } })).listen(port, listenresult -> {//代理服务器的监听端口 if (listenresult.succeeded()) { //成功启动代理服务器 logger.info("mysql proxy rver start up."); } el { //启动代理服务器失败 logger.error("mysql proxy exit. becau: " + listenresult.cau().getmessage(), listenresult.cau()); system.exit(1); } }); } } public static class mysqlproxyconnection { private final netsocket clientsocket; private final netsocket rversocket; public mysqlproxyconnection(netsocket clientsocket, netsocket rversocket) { this.clientsocket = clientsocket; this.rversocket = rversocket; } private void proxy() { //当代理与mysql服务器连接关闭时，关闭client与代理的连接 rversocket.clohandler(v -> clientsocket.clo()); //反之亦然 clientsocket.clohandler(v -> rversocket.clo()); //不管那端的连接出现异常时，关闭两端的连接 rversocket.exceptionhandler(e -> { logger.error(e.getmessage(), e); clo(); }); clientsocket.exceptionhandler(e -> { logger.error(e.getmessage(), e); clo(); }); //当收到来自客户端的数据包时，转发给mysql目标服务器 clientsocket.handler(buffer -> rversocket.write(buffer)); //当收到来自mysql目标服务器的数据包时，转发给客户端 rversocket.handler(buffer -> clientsocket.write(buffer)); } private void clo() { clientsocket.clo(); rversocket.clo(); } }}

测试一下

try { class.forname(name);//指定连接类型 connection conn = drivermanager.getconnection(url, ur, password);//url为代理服务器的地址 preparedstatement pst = conn.preparestatement("lect * from test;");//准备执行语句 resultt resultt = pst.executequery(); while (resultt.next()) { system.out.prinon的反义词tln(resultt.getlong(1) + ": " + resultt.getstring(2)); }} catch (exception e) { e.printstacktrace();}

不出意外，一切运行正常，恭喜你，你已经实现了一个最简单的mysql代理服务器。

写在最后

vert.x是基于jvm、事件驱动、异步io、响应式编程工具套件，底层网络通信使用netty4，是一个非常优秀的java开发框架（当然，严格意义上讲是工具套件），使用vert.x可以快速构建的各种应用，并且天生分布式，集委曲求全群管理。

另外，实现一个代理服务器远没有如此简单，根据需求的不同，复杂度也不同，这里仅仅是展示实现代理的核心代码，实现了最基本的代理功能，当然了，一切复杂的需求都可以基于上面的代码进行改造扩展。