欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

mysql代理服务器(云数据库和普通数据库)

程序员文章站 2023-12-29 07:59:52
用java8基于vert.x3 快速实现一个最简单的mysql代理服务器,只需要5分钟时间。什么是mysql 代理?mysql代理是介于client端和mysql服务端中间层服务,如下图所示:这里写图...

用java8基于vert.x3 快速实现一个最简单的mysql代理服务器,只需要5分钟时间。

mysql代理服务器(云数据库和普通数据库)

什么是mysql 代理?

mysql代理是介于client端和mysql服务端中间层服务,如下图所示:

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可以快速构建的各种应用,并且天生分布式,集群管理。

另外,实现一个代理服务器远没有如此简单,根据需求的不同,复杂度也不同,这里仅仅是展示实现代理的核心代码,实现了最基本的代理功能,当然了,一切复杂的需求都可以基于上面的代码进行改造扩展。

mysql代理服务器(云数据库和普通数据库)

上一篇:

下一篇: