java 8實現的一個最簡單的mysql代理服務器

能夠用java8基於vert.x3 快速實現一個最簡單的mysql代理服務器。

什麼是mysql 代理？

mysql代理是介於client端和mysql服務端中間層服務，以下圖所示：

爲何要使用代理？

大部人都知道使用代理的好處，畢竟，隨着互聯網愈來愈普及，互聯網系統愈來愈龐大、複雜，性能要求愈來愈高，爲了讓整個系統具備更好的擴展性、更高的性能、解藕等多種特性，在數據庫層面引入代理層是目前互聯網系統常見的架構設計方案。總的來講，在數據庫層面引入代理會帶來如下好處：

（1）將不一樣類型的請求分發的不一樣的server以此實現讀寫分離、負載均衡。

（2）來自不一樣客戶端的請求分發到不一樣的server實現後端多租戶數據庫服務，固然，相似的原理還能夠實現分庫分表、一個請求寫到多個server或者不一樣的源端如消息隊列。

（3）監控統計客戶端的請求狀況，請求分佈統計、請求類型等，以此來優化數據庫的使用。

總之，能夠實現你想要的諸多功能。

如何用java快速實現一個最簡單的代理呢？

首先，準備開發工具套件，咱們並不會引入過多工具包，僅僅須要：

（1）java8

（2）vert.x 3

若是你是用maven作爲項目管理工具，請將vert.x 3引入：

<dependency>
   <groupId>io.vertx</groupId>
   <artifactId>vertx-core</artifactId>
   <version>3.3.2</version>
</dependency>

完整代碼：

package com.alimm.biz;

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;

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能夠快速構建的各類應用，而且天生分佈式，集羣管理。 另外，實現一個代理服務器遠沒有如此簡單，根據需求的不一樣，複雜度也不一樣，這裏僅僅是展現實現代理的核心代碼，實現了最基本的代理功能，固然了，一切複雜的需求均可以基於上面的代碼進行改造擴展。