摘要:用基于快速實現一個最簡單的代理服務器,只需要分鐘時間。監控統計客戶端的請求情況,請求分布統計請求類型等,以此來優化數據庫的使用。
什么是mysql 代理?用java8基于vert.x3 快速實現一個最簡單的mysql代理服務器,只需要5分鐘時間。
mysql代理是介于client端和mysql服務端中間層服務,如下圖所示:
為什么要使用代理?大部人都知道使用代理的好處,畢竟,隨著互聯網越來越普及,互聯網系統越來越龐大、復雜,性能要求越來越高,為了讓整個系統具有更好的擴展性、更高的性能、解藕等多種特性,在數據庫層面引入代理層是目前互聯網系統常見的架構設計方案。總的來說,在數據庫層面引入代理會帶來以下好處:
將不同類型的請求分發的不同的server以此實現讀寫分離、負載均衡。
來自不同客戶端的請求分發到不同的server實現后端多租戶數據庫服務,當然,類似的原理還可以實現分庫分表、一個請求寫到多個server或者不同的源端如消息隊列。
監控統計客戶端的請求情況,請求分布統計、請求類型等,以此來優化數據庫的使用。
總之,可以實現你想要的諸多功能。
如何用java快速實現一個最簡單的代理呢?首先,準備開發工具套件,我們并不會引入過多工具包,僅僅需要:
java8
vert.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可以快速構建的各種應用,并且天生分布式,集群管理。
另外,實現一個代理服務器遠沒有如此簡單,根據需求的不同,復雜度也不同,這里僅僅是展示實現代理的核心代碼,實現了最基本的代理功能,當然了,一切復雜的需求都可以基于上面的代碼進行改造擴展.
作者信息
作者系力譜宿云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
活動預告
報名鏈接:http://t.cn/Rt9ooRw
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/65004.html
摘要:比如分鐘破譯朋友圈測試小游戲文章里用的方法但有些根本就沒有提供網頁端,比如今年火得不行的抖音。所以常用的方式就是通過在電腦上裝一些抓包軟件,將手機上的網絡請求全部顯示出來。總結下,重點是的抓取,關鍵是配置代理證書,難點是對請求的分析。 爬蟲的案例我們已講得太多。不過幾乎都是 網頁爬蟲 。即使有些手機才能訪問的網站,我們也可以通過 Chrome 開發者工具 的 手機模擬 功能來訪問,以便...
摘要:用戶態不能干擾內核態所以指令就有兩種特權指令和非特權指令不同的狀態對應不同的指令。非特權指令所有程序均可直接使用。用戶態常態目態執行非特權指令。 這是我今年從三月份開始,主要的大廠面試經過,有些企業面試的還沒來得及整理,可能有些沒有帶答案就發出來了,還請各位先思考如果是你怎么回答面試官?這篇文章會持續更新,請各位持續關注,希望對你有所幫助! 面試清單 平安產險 飛豬 上汽大通 浩鯨科...
摘要:環境部署第一步,我會按默認的向導創建一個新的虛擬私有云,這個虛擬私有云是為準備的。的應用程序將自己在內運行。所有的主機都可以使用公有的,可如果你是在虛擬私有云上有主機的話,這就有點麻煩了,所以你可以選擇使用私有而非公有。 眾所周知,亞馬遜有EC2容器服務,它是亞馬遜用于運行Docker容器的解決方案。不過我覺得EC2容器服務不怎么好用,所以現在我要在AWS上測試Rancher和Kube...
摘要:環境部署第一步,我會按默認的向導創建一個新的虛擬私有云,這個虛擬私有云是為準備的。的應用程序將自己在內運行。所有的主機都可以使用公有的,可如果你是在虛擬私有云上有主機的話,這就有點麻煩了,所以你可以選擇使用私有而非公有。 眾所周知,亞馬遜有EC2容器服務,它是亞馬遜用于運行Docker容器的解決方案。不過我覺得EC2容器服務不怎么好用,所以現在我要在AWS上測試Rancher和Kube...
閱讀 1223·2021-11-25 09:43
閱讀 1336·2021-09-26 09:55
閱讀 2330·2021-09-10 11:20
閱讀 3365·2019-08-30 15:55
閱讀 1441·2019-08-29 13:58
閱讀 1163·2019-08-29 12:36
閱讀 2337·2019-08-29 11:18
閱讀 3406·2019-08-26 11:47