如何用java 5分鐘實現一個最簡單的mysql代理伺服器?

NO IMAGE

用java8基於vert.x3 快速實現一個最簡單的mysql代理伺服器,只需要5分鐘時間。

圖片描述

什麼是mysql 代理?

mysql代理是介於client端和mysql服務端中間層服務,如下圖所示:

這裡寫圖片描述

為什麼要使用代理?

大部人都知道使用代理的好處,畢竟,隨著網際網路越來越普及,網際網路系統越來越龐大、複雜,效能要求越來越高,為了讓整個系統具有更好的擴充套件性、更高的效能、解藕等多種特性,在資料庫層面引入代理層是目前網際網路系統常見的架構設計方案。總的來說,在資料庫層面引入代理會帶來以下好處:

將不同型別的請求分發的不同的server以此實現讀寫分離、負載均衡。

來自不同客戶端的請求分發到不同的server實現後端多租戶資料庫服務,當然,類似的原理還可以實現分庫分表、一個請求寫到多個server或者不同的源端如訊息佇列。

監控統計客戶端的請求情況,請求分佈統計、請求型別等,以此來優化資料庫的使用。

總之,可以實現你想要的諸多功能。

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

首先,準備開發工具套件,我們並不會引入過多工具包,僅僅需要:

java8

vert.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;
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可以快速構建的各種應用,並且天生分散式,叢集管理。
另外,實現一個代理伺服器遠沒有如此簡單,根據需求的不同,複雜度也不同,這裡僅僅是展示實現代理的核心程式碼,實現了最基本的代理功能,當然了,一切複雜的需求都可以基於上面的程式碼進行改造擴充套件.


作者資訊
作者系力譜宿雲LeapCloud旗下_Maxleap團隊成員:趙靜【原創】
力譜宿雲首發地址:https://blog.maxleap.cn/archi…

相關文章
次時代Java程式設計(一):Java裡的協程
次時代Java程式設計(一):續 vertx-sync實踐

作者往期佳作
構建BaaS雲資料(CloudData)服務—mongo叢集架構設計

作者往期活動
CloudData-Mongo_微信直播分享
7月酷暑,暢聊Reative工具Vert.x
Vert.x技術活動後續 | Maxleap Vert.x應用實踐總結

對我們的活動感興趣的小夥伴,歡迎關注微信公眾號:MaxLeap_yidongyanfa


活動預告

clipboard.png

報名連結:http://t.cn/Rt9ooRw