再送一波干货，测试2000线程并发下同时查询1000万条数据库表及索引优化

时间：2017-05-05 17:18:29 阅读：225 评论：0 收藏：0 [点我收藏+]

标签：sql语句 root current order 知识 ima from 体验用户

这篇文章的知识点如下:

1.如何自写几十行代码就能模拟测试高并发下访问千万级数据库表

2.比较高并发下（200次/秒,2000次/秒,10000次/秒）数据库的性能

3.比较千万级数据库在查询时加索引与不加索引的巨大差异（说实话，这个测试结果让我自己本人也很惊讶）

针对上篇文章插入的1000万条数据到数据库后，我们进行了高并发下测试（模拟教师输入姓名和密码在1秒内登录数据库），线程类代码如下

package insert;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
 
public class ThreadToMysql extends Thread {
    public String teacherName;
    public String password;
    public ThreadToMysql(String teacherName, String password) {//构造函数传入要查询登录的老师姓名和密码
         
        this.teacherName=teacherName;
        this.password=password;
    }
     
    public void run() {
         String url = "jdbc:mysql://127.0.0.1/teacher"; 
         String name = "com.mysql.jdbc.Driver"; 
         String user = "root"; 
         String password = "123456"; 
        Connection conn = null; 
        try {
            Class.forName(name);
            conn = DriverManager.getConnection(url, user, password);//获取连接 
            conn.setAutoCommit(false);//关闭自动提交，不然conn.commit()运行到这句会报错
        } catch (ClassNotFoundException e1) {
            e1.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        if (conn!=null) {
            Long startTime=System.currentTimeMillis();//开始时间
            String sql="select id from t_teacher where t_name=‘"+teacherName+"‘ and t_password=‘"+password+"‘";//SQL语句
            String id=null;
            try {
                Statement stmt=conn.createStatement();
                ResultSet rs=stmt.executeQuery(sql);//获取结果集
                if (rs.next()) {
                    id=rs.getString("id");
                }
                conn.commit();
                stmt.close();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
                Long end=System.currentTimeMillis();
                System.out.println(currentThread().getName()+"  查询结果:"+id+"   开始时间:"+startTime+"  结束时间:"+end+"  用时:"+(end-startTime)+"ms");
             
             
        } else {
            System.out.println(currentThread().getName()+"数据库连接失败:");
        }
    }
     
}

　　测试类代码如下：

package insert;
 
public class TestThreadToMysql {
 
    public static void main(String[] args) {
        for (int i = 1; i <=2000; i++) {
            String teacherName=String.valueOf(i);
            new ThreadToMysql(teacherName, "123456").start();
     
 
}

一.在没有加索引的情况下测试：

把数据库的最大连接数设置为250：

技术分享

测试代码：

package insert;
 
public class TestThreadToMysql {
 
    public static void main(String[] args) {
        for (int i = 1; i <=200; i++) {
            String teacherName=String.valueOf(i);
            new ThreadToMysql(teacherName, "123456").start();
        }
    }
 
}

　　测试结果：

技术分享

100多秒啊。。。我的天，这用户体验也没准了O(∩_∩)O哈哈~

二.加索引后再次进行高并发下测试：

数据库加索引SQL语句如下：这里我有一个疑问，上个星期我加索引等了半个小时我都没加完索引我就停止了，今天下午居然只用了551秒就加完了索引。。。搞不懂

技术分享

clean下项目代码后再次运行（尽量经常clean下项目去掉缓存，不然结果会有出入）：

技术分享

看到这个结果有没有被惊呆啊？哈哈加了索引由100多秒提升到1~2毫秒，查询速度提示1万多倍，查询性能得到大幅度变态级提升~~~

没加索引之前我查询单个记录都要2秒多

技术分享

用explain查看语句可以知道要扫描全表，性能当然大幅度下降

技术分享

下面我们来挑战2000线程同时并发访问查询数据库。看看结果:

把数据库最大连接数设置为2500

技术分享

测试代码改为2000

package insert;
 
public class TestThreadToMysql {
 
    public static void main(String[] args) {
        for (int i = 1; i <=2000; i++) {
            String teacherName=String.valueOf(i);
            new ThreadToMysql(teacherName, "123456").start();
        }
    }
 
}

　　结果截图：

技术分享

性能没问题，平均几十毫秒，很满意

下面我们来挑战一下1万个线程同时高并发访问，大家可以先想想结果会怎么样，哈哈

设置数据库最大连接数12000

技术分享

测试代码改为10000（再次提示。clean一下项目去掉缓存，这样结果更准确）

package insert;
 
public class TestThreadToMysql {
 
    public static void main(String[] args) {
        for (int i = 1; i <=10000; i++) {
            String teacherName=String.valueOf(i);
            new ThreadToMysql(teacherName, "123456").start();
        }
    }
 
}

　　结果如下（运行后发现电脑有点卡）：

技术分享