在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Java  Linux  數(shù)據(jù)庫/ JDBC多線程查詢結果匯總

JDBC多線程查詢結果匯總

假設單線程查詢SQL耗時1S,那么開啟兩個線程查詢SQL理想情況下也是1S多點才對,機器是4核,但是目前結果近乎2倍顯然有異;

暫且不考慮從線程池獲取連接,任務線程核心代碼如下:

@Override
public void run() {
    long s = System.currentTimeMillis();
    System.out.println(Thread.currentThread().getName() + "準備執(zhí)行");
    try (Connection connection = DBUtils.openConnection();
         PreparedStatement preparedStatement = connection.prepareStatement(querySql);
         ResultSet resultSet = preparedStatement.executeQuery()) {
        long e = System.currentTimeMillis();
        System.out.println(Thread.currentThread().getName() + "執(zhí)行耗時:" + (e - s));

    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        latch.countDown();
    }
}

目的是分表查詢采用多線程,使用CountDownLatch,結果匯總,提交任務代碼如下:

CountDownLatch countDownLatch = new CountDownLatch(TABLE_SIZE);
ExecutorService executor = Executors.newFixedThreadPool(TABLE_SIZE);
List<String> names = new LinkedList<>();
long s = System.currentTimeMillis();
System.out.println("獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...");

try {
    for (int i = 0; i < TABLE_SIZE; i++) {
        Task task = new Task(countDownLatch, names, PRE_SQL + i);
        executor.execute(task);
    }
    countDownLatch.await();
    executor.shutdownNow();
} catch (InterruptedException e) {
    e.printStackTrace();
}

long e = System.currentTimeMillis();
System.out.println("總耗時:" + (e - s) + "ms");

當指定1個任務時,控制臺輸出:

獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-1準備執(zhí)行
pool-1-thread-1執(zhí)行耗時:708
總耗時:708ms

當指定2個任務時,控制臺輸出:

獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-1準備執(zhí)行
pool-1-thread-2準備執(zhí)行
pool-1-thread-2執(zhí)行耗時:2054
pool-1-thread-1執(zhí)行耗時:2055
總耗時:2057ms

當指定4個任務時,控制臺輸出:

獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-2準備執(zhí)行
pool-1-thread-3準備執(zhí)行
pool-1-thread-1準備執(zhí)行
pool-1-thread-4準備執(zhí)行
pool-1-thread-3執(zhí)行耗時:3189
pool-1-thread-1執(zhí)行耗時:3203
pool-1-thread-2執(zhí)行耗時:3241
pool-1-thread-4執(zhí)行耗時:3245
總耗時:3248ms

在程序運行期間查看mysql,show processlist;

| 136 | root | localhost:50225 | test | Query   |     1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_3 |
| 135 | root | localhost:50224 | test | Query   |     1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_1 |
| 138 | root | localhost:50227 | test | Query   |     1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_0 |
| 137 | root | localhost:50226 | test | Query   |     1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_2 |

然后SQL狀態(tài)就變成了Writing to net,不知道是否正常,對Mysql不是很懂。

我也試過單線程for循環(huán)6次,耗時出入不大。

單條SQL執(zhí)行差不多在1S左右,現(xiàn)在4條SQL同時執(zhí)行,并沒有在1S多就返回結果,而是在3S多同時結束,那么這里的問題到底是什么原因導致的呢?

回答
編輯回答
扯機薄

Writing to net

The server is writing a packet to the network. This state is called Sending to client as of MySQL 5.7.8.

ref: https://dev.mysql.com/doc/ref...

本地select 超過1S,推測你每次select出的數(shù)據(jù)集比較大,本地的packet設置得過小

在Mysql執(zhí)行下

show global variables like "max_allowed_packet"

解決方案:

  1. 降低每次查詢出的結果集
  2. 增大max_allowed_packet
2017年7月5日 17:04
編輯回答
賤人曾

如果瓶頸在帶寬或數(shù)據(jù)庫處理能力,多線程就不能解決這個性能問題

2018年8月21日 20:23
編輯回答
毀了心

貌似和 這個問題 是同一個環(huán)境?
數(shù)據(jù)量太大,網(wǎng)絡帶寬打滿了吧

2017年3月22日 21:03