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

用java8快速实现基于vert.x3的最简单的mysql代理服务器只需要5分钟。

什么是mysql代理？

mysql代理是客户端和mysql服务器端之间中间层服务，如下图所示:

在这里写一个图片说明

为什么要使用代理？

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

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

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

首先，为开发工具包做准备，我们不会介绍太多工具包，只需要:

java8vert.x 3

如果你是用maven做项目管理工具，请介绍一下vert.x 3:

io.vertx vertx-core 3.3.2

代码实现:

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;import io.vertx.core.net.NetServer;import io.vertx.core.net.NetSocket;/** * @author sneaky * @since 1.0.0 */public class MysqlProxyServer { private static final Logger logger = LoggerFactory.getLogger(MysqlProxyServer.class); public static void main(String[] args) { Vertx.vertx().deployVerticle(new MysqlProxyServerVerticle()); } public static class MysqlProxyServerVerticle extends AbstractVerticle { private final int port = 3306; private final String mysqlHost = "10.10.0.6"; @Override public void start() throws Exception { NetServer netServer = vertx.createNetServer();//创建代理服务器 NetClient netClient = vertx.createNetClient();//创建连接mysql客户端 netServer.connectHandler(socket -> netClient.connect(port, mysqlHost, result -> { //响应来自客户端的连接请求，成功之后，在建立一个与目标mysql服务器的连接 if (result.succeeded()) { //与目标mysql服务器成功连接连接之后，创造一个MysqlProxyConnection对象,并执行代理方法 new MysqlProxyConnection(socket, result.result()).proxy(); } else { logger.error(result.cause().getMessage(), result.cause()); socket.close(); } })).listen(port, listenResult -> {//代理服务器的监听端口 if (listenResult.succeeded()) { //成功启动代理服务器 logger.info("Mysql proxy server start up."); } else { //启动代理服务器失败 logger.error("Mysql proxy exit. because: " + listenResult.cause().getMessage(), listenResult.cause()); System.exit(1); } }); } } public static class MysqlProxyConnection { private final NetSocket clientSocket; private final NetSocket serverSocket; public MysqlProxyConnection(NetSocket clientSocket, NetSocket serverSocket) { this.clientSocket = clientSocket; this.serverSocket = serverSocket; } private void proxy() { //当代理与mysql服务器连接关闭时，关闭client与代理的连接 serverSocket.closeHandler(v -> clientSocket.close()); //反之亦然 clientSocket.closeHandler(v -> serverSocket.close()); //不管那端的连接出现异常时，关闭两端的连接 serverSocket.exceptionHandler(e -> { logger.error(e.getMessage(), e); close(); }); clientSocket.exceptionHandler(e -> { logger.error(e.getMessage(), e); close(); }); //当收到来自客户端的数据包时，转发给mysql目标服务器 clientSocket.handler(buffer -> serverSocket.write(buffer)); //当收到来自mysql目标服务器的数据包时，转发给客户端 serverSocket.handler(buffer -> clientSocket.write(buffer)); } private void close() { clientSocket.close(); serverSocket.close(); } }}

测试一下

try { Class.forName(name);//指定连接类型 Connection conn = DriverManager.getConnection(url, user, password);//url为代理服务器的地址 PreparedStatement pst = conn.prepareStatement("select * from test;");//准备执行语句 ResultSet resultSet = pst.executeQuery(); while (resultSet.next()) { System.out.println(resultSet.getLong(1) + ": " + resultSet.getString(2)); }} catch (Exception e) { e.printStackTrace();}

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

写在最后

Vert.x是一个基于jvm、事件驱动、异步IO和响应式编程的工具套件。netty4用于底层网络通信，是一个优秀的java开发框架(当然严格来说是工具套件)。vert.x可以用来快速构建各种应用，而且是集群自然分布和管理的。

另外，一个代理服务器的实现远不是简单的，根据不同的需求，复杂度是不同的。这里只展示实现代理的核心代码，实现最基本的代理功能。当然，所有复杂的需求都可以基于上述代码进行修改和扩展。