Vert.x使用Mysql异步驱动

Posted 2021-04-02 法式小奶包

先来点线程理论：

• 传统的jdbc驱动都是同步的，因此会造成线程阻塞

• 根据Java的线程模型设计，用户态线程与内核态线程是1:1,用户态线程阻塞会造成内核态线程阻塞

• cpu在调度线程的时候，一个cpu核心只能同时做一件事情，当线程阻塞越多，cpu的有效计算效率跟着下降，造成大量的线程上下文切换

  
  

在高并发的时候，异步的优势就十分明显了。话说现在去面试，不管百人以下的小厂或者千人以上的大厂，都会来一句百万并发、亿级流量。

注意：异步驱动并不能提高mysql数据库的性能，只是令程序的线程不阻塞，减少线程的开销，提高程序的性能。

Talk is cheap. Show me the code.

关于vertx请参考小弟之前的文章 ，

1.pom文件增加依赖

<dependency> <groupId>io.vertx</groupId> <artifactId>vertx-mysql-client</artifactId> <version>4.0.0</version> </dependency>

2.编写DBUtil.java数据库工具类

package com.hm.util;
import io.vertx.core.Vertx;import io.vertx.mysqlclient.MySQLConnectOptions;import io.vertx.mysqlclient.MySQLPool;import io.vertx.sqlclient.PoolOptions;
public class DBUtil { private Vertx vertx; public DBUtil(Vertx vertx) { this.vertx=vertx; } public MySQLPool getConnection(){ MySQLConnectOptions connectOptions = new MySQLConnectOptions() .setPort(3306) .setHost("127.0.0.1") .setDatabase("stu") .setUser("root")                .setPassword("***");
 // Pool options PoolOptions poolOptions = new PoolOptions() .setMaxSize(5); // Create the pooled clien MySQLPool client = MySQLPool.pool(vertx,connectOptions, poolOptions); return client; }}

链式编程就是爽...

3.新建IndexHandler.java(类似springboot的controller)

package com.hm.handler;
import com.hm.util.DBUtil;import io.vertx.core.Handler;import io.vertx.core.Vertx;import io.vertx.ext.web.RoutingContext;import io.vertx.mysqlclient.MySQLPool;import io.vertx.sqlclient.Row;import io.vertx.sqlclient.RowSet;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;
public class IndexHandler implements Handler<RoutingContext> { private Vertx vertx; public IndexHandler(Vertx vertx) { this.vertx=vertx; }
 @Override public void handle(RoutingContext event) { DBUtil dbUtil = new DBUtil(vertx); List<Map<String,Object>> rList=new ArrayList<>(); MySQLPool client = dbUtil.getConnection(); client .query("SELECT * FROM girl_friends") .execute(ar -> { if (ar.succeeded()) { RowSet<Row> result = ar.result(); System.out.println("Got " + result.size() + " rows "); String[] list={"id","NAME","AGE"}; for (Row row : result) { Map<String,Object> map=new HashMap<>(); for (String str : list) { map.put(str,row.getValue(str)); } rList.add(map); } } else { System.out.println("Failure: " + ar.cause().getMessage()); } // Now close the pool client.close(); event.response().end(rList.toString()); }); }
}

4.程序入口main方法

package com.hm;
import com.hm.handler.IndexHandler;import io.vertx.core.Vertx;import io.vertx.core.http.HttpServer;import io.vertx.ext.web.Router;
public class App { public static void main(String[] args) { Vertx vertx = Vertx.vertx(); HttpServer server = vertx.createHttpServer(); Router router = Router.router(vertx);//主路由 //一级路由 router.route("/index").handler(new IndexHandler(vertx)); server.requestHandler(router) .listen(8089); }}