传送门:http://blog.csdn.net/bluishglc/article/details/7710738#java
请各位参考上面地址.
这种主键生成方式,相对于twritter的生成方式,好处在于,id的值是可以控制的,你想让它生成什么样子的id都可以实现.
这里贴一下测试 程序 ,在我的机器上I7 2720 ,16G.单台mysql,最高达到2800/s.两台mysql并发,最高达到4800/s
受制于cpu的多线程处理能力 ,当用3台,4台mysql测试时,性能并没有任何 提高 ,由此可知,已经达到了cpu多线程的最高处理能力
package mysqlJDBC;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.junit.Test;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidPooledConnection;
public class JdbcTest {
@Test
public void test() throws SQLException {
getConn37();
getConn38();
long begin = System.currentTimeMillis();
int step = 10000;
long total=3061;
for (int i = 0; i < step; i+=2) {
// System.out.println("count i="+i);
new Thread(new Runnable() {
@Override
public void run() {
try {
DruidPooledConnection conn = getConn37();
PreparedStatement ps1 = conn
.prepareStatement("REPLACE INTO Tickets64 (stub) VALUES ('a')");
PreparedStatement ps2 = conn
.prepareStatement("SELECT LAST_INSERT_ID()");
ps1.execute();
ResultSet rs = ps2.executeQuery(); // 执行预处理语句获取查询结果集
while (rs.next()) {
System.out.println(rs.getString(1));
System.out.println(System.currentTimeMillis() - begin);
}
rs.close();
ps1.close();
ps2.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
try {
DruidPooledConnection conn = getConn38();
PreparedStatement ps1 = conn
.prepareStatement("REPLACE INTO Tickets64 (stub) VALUES ('a')");
PreparedStatement ps2 = conn
.prepareStatement("SELECT LAST_INSERT_ID()");
ps1.execute();
ResultSet rs = ps2.executeQuery(); // 执行预处理语句获取查询结果集
while (rs.next()) {
System.out.println(rs.getString(1));
System.out.println(System.currentTimeMillis() - begin);
}
rs.close();
ps1.close();
ps2.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}).start();
}
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("total is " + total);
System.out.println("per fix is " + (step * 1000) / total);
}
private static DruidPooledConnection getConn37() {
DruidPooledConnection conn = null;
try {
conn = DbConnectionFactory.getDataSource37().getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
private static DruidPooledConnection getConn38() {
DruidPooledConnection conn = null;
try {
conn = DbConnectionFactory.getDataSource38().getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}
class DbConnectionFactory{
private DbConnectionFactory(){
}
public static DruidDataSource getDataSource38()
{
return Holder38.druidDataSource;
}
public static DruidDataSource getDataSource37()
{
return Holder37.druidDataSource;
}
static class Holder38{
public static DruidDataSource druidDataSource= Holder38.getConnectionPool();
private static DruidDataSource getConnectionPool(){
DruidDataSource dataSource = new DruidDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUsername("root");
dataSource.setPassword("1qaz2wsx");
dataSource.setUrl("jdbc:mysql://192.168.1.38:3308/idserver");
dataSource.setInitialSize(100);
dataSource.setMinIdle(50);
dataSource.setMaxActive(200);
// 启用监控统计功能 dataSource.setFilters("stat");
dataSource.setPoolPreparedStatements(true);// for mysql
dataSource.setMaxPoolPreparedStatementPerConnectionSize(100);
//配置一个连接在池中最小生存的时间,单位是毫秒
dataSource.setMinEvictableIdleTimeMillis(300000);
return dataSource;
}
}
static class Holder37{
public static DruidDataSource druidDataSource= Holder37.getConnectionPool();
private static DruidDataSource getConnectionPool(){
DruidDataSource dataSource = new DruidDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUsername("root");
dataSource.setPassword("1qaz2wsx");
dataSource.setUrl("jdbc:mysql://192.168.1.37:3308/idserver");
dataSource.setInitialSize(100);
dataSource.setMinIdle(50);
dataSource.setMaxActive(200);
// 启用监控统计功能 dataSource.setFilters("stat");
dataSource.setPoolPreparedStatements(true);// for mysql
dataSource.setMaxPoolPreparedStatementPerConnectionSize(100);
//配置一个连接在池中最小生存的时间,单位是毫秒
dataSource.setMinEvictableIdleTimeMillis(300000);
return dataSource;
}
}
}
分享到:
相关推荐
MySQL 分库分表的实现原理及演示案例,非常不错,可以看看
一个MySQL分库分表php类。当一个表数据记录过大时就会出现性能瓶颈,而一般对应的解决办法是要么做分区表,要么分表,分区表就不说了,分表又分为垂直分割和水平分割,具体区 别请自行搜索。一般而言,分库分表属于...
MySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库分表课件.zipMySQL分库...
这个PPT由浅入深,从很少的用户到千万级别的用户,告诉你为什么要使用分库分表,包括垂直和水平切分,偏入门的理论,代码基本无
php分库分表
MySQL 分库分表的实现原理及演示案例.zip
mysql分库分表,详细介绍了垂直分表、水平分表、垂直分库、水平分库,包括它们的优缺点,解决的问题,有具体案例
MySQL分库分表, word 文档。MYCAT开发使用总结,MYCAT开发使用总结
分享一个MySQL分库分表php类。当一个表数据记录过大时就会出现性能瓶颈,而一般对应的解决办法是要么做分区表,要么分表,分区表就不说了,分表又分为垂直分割和水平分割,具体区 别请自行搜索。一般而言,分库分表...
Mysql分库分表11111111111
java mysql 分库分表详解
本文讲的是mysql大数据分库和分表 php解决方案。 mysql分库分表方案、mysql 分库方案、php实现mysql分库分表、mysql高并发解决方案。
Python+MySQL分表分库实战,适合对MySQL 分库分表感兴趣的读者。
MySQL分库分表无限扩容后的瓶颈及解决方案.docx
分库分表 各种mysql中间件 总结(csdn)————程序
MySQL分库分表篇相关代码
<?... namespace App\Model\Database; class Config { ... * @var string 分库分表后得到的数据库名 ...这是一个非常好用的MySQL分库分表的PHP类,需要的朋友可以下载使用,更多精彩尽在在PHP中文网。
58同城mysql分库分表实践,非常不错的分享文档,适合学习如何扩展MySQL的。
mysql分库分表-shardingmysql
mysql分库分表-atlantic