本文向大家介绍了简单的mysql连接池，用于app服务端比较合适，分享给大家供大家参考，具体内容如下
/**
* 连接池类
*/
package com.junones.test;
import java.sql.connection;
import java.sql.sqlexception;
import java.util.hashmap;
import java.util.map;
import java.util.map.entry;
import com.mysql.jdbc.jdbc2.optional.mysqldatasource;
public class mysqlpool {
private static volatile mysqlpool pool;
private mysqldatasource ds;
private mapmap;
private string url = "jdbc:mysql://localhost:3306/test";
private string username = "root";
private string password = "root1234";
private int initpoolsize = 10;
private int maxpoolsize = 200;
private int waittime = 100;
private mysqlpool() {
init();
}
public static mysqlpool getinstance() {
if (pool == null) {
synchronized (mysqlpool.class) {
if(pool == null) {
pool = new mysqlpool();
}
}
}
return pool;
}
private void init() {
try {
ds = new mysqldatasource();
ds.seturl(url);
ds.setuser(username);
ds.setpassword(password);
ds.setcachecallablestmts(true);
ds.setconnecttimeout(1000);
ds.setlogintimeout(2000);
ds.setuseunicode(true);
ds.setencoding("utf-8");
ds.setzerodatetimebehavior("converttonull");
ds.setmaxreconnects(5);
ds.setautoreconnect(true);
map = new hashmap();
for (int i = 0; i < initpoolsize; i++) {
map.put(getnewconnection(), true);
}
} catch (exception e) {
e.printstacktrace();
}
}
public connection getnewconnection() {
try {
return ds.getconnection();
} catch (sqlexception e) {
e.printstacktrace();
}
return null;
}
public synchronized connection getconnection() {
connection conn = null;
try {
for (entryentry : map.entryset()) {
if (entry.getvalue()) {
conn = entry.getkey();
map.put(conn, false);
break;
}
}
if (conn == null) {
if (map.size() < maxpoolsize) {
conn = getnewconnection();
map.put(conn, false);
} else {
wait(waittime);
conn = getconnection();
}
}
} catch (exception e) {
e.printstacktrace();
}
return conn;
}
public void releaseconnection(connection conn) {
if (conn == null) {
return;
}
try {
if(map.containskey(conn)) {
if (conn.isclosed()) {
map.remove(conn);
} else {
if(!conn.getautocommit()) {
conn.setautocommit(true);
}
map.put(conn, true);
}
} else {
conn.close();
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
/**
* 测试类
*/
package com.junones.test;
import java.sql.connection;
import java.sql.resultset;
import java.sql.sqlexception;
import java.sql.statement;
public class testmysqlpool {
private static volatile int a;
private synchronized static void incr() {
a++;
}
public static void main(string[] args) throws interruptedexception {
int times = 10000;
long start = system.currenttimemillis();
for (int i = 0; i < times; i++) {
new thread(new runnable() {
@override
public void run() {
mysqlpool pool = mysqlpool.getinstance();
connection conn = pool.getconnection();
statement stmt = null;
resultset rs = null;
try {
stmt = conn.createstatement();
rs = stmt.executequery("select id, name from t_test");
while (rs.next()) {
system.out.println(rs.getint(1) + ", "
+ rs.getstring(2));
}
} catch (sqlexception e) {
e.printstacktrace();
} finally {
incr();
if (rs != null) {
try {
rs.close();
} catch (sqlexception e) {
e.printstacktrace();
}
}
if (stmt != null) {
try {
stmt.close();
} catch (sqlexception e) {
}
}
pool.releaseconnection(conn);
}
}
}).start();
}
while (true) {
if (a == times) {
system.out.println("finished, time:"
+ (system.currenttimemillis() - start));
break;
}
thread.sleep(100);
}
}
}
测试结果：1万个并发，5秒完成。
以上就是用于app服务端的mysql连接池（支持高并发）_mysql的内容。