包含vertx連接mysql數據庫的詞條

本文目錄一覽：

• 1、通過代理在java連接mysql問題，怎麼解決
• 2、如何用java 5分鐘實現一個最簡單的mysql代理服務器
• 3、vertx怎麼上傳圖片到MySQL
• 4、如何用Java快速實現一個最簡單的MySQL代理呢？
• 5、vertx為什麼不火

通過代理在java連接mysql問題，怎麼解決

首先，準備開發工具套件，我們並不會引入過多工具包，僅僅需要： Java8 Vert.x 3 如果你是用Maven做為項目管理工具，請將Vert.x 3引入： io.vertx vertx-core3.3.2 代碼實現： package com.maxleap.mysqlproxy; import io.vertx.core.AbstractVe…

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

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();

}

vertx怎麼上傳圖片到MySQL

兩種辦法：1、以char或varchar類型保存圖片的上傳路徑；2、以blob格式把圖片以二進制保存在數據庫里。建議用第一種至於用不用PDO，全憑喜好，以MySQL完全可以辦到。

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

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

Java8

Vert.x 3

如果你是用Maven做為項目管理工具，請將Vert.x 3引入：

dependency

groupIdio.vertx/groupId

artifactIdvertx-core/artifactIdversion3.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();

}

vertx為什麼不火

國內沒有普及。Vertx發佈於2011年，除了多語言支持，也已經支持了Postgres、MySQL、MongoDB、Redis等常用組件，只在華為的開源框架servicecomb上有用到過，基本上只能看官網和英文網站才有比較深入的介紹，國內還沒有普及，要將vertx用到生產，必定繞不開它的集群部署模式，而它依賴的組件（如hazelcast）的中文介紹更是少得可憐。