java 怎么高并发测试

其实就是用CountDownLatch来使多个线程同时运行，同时发送请求，虽然post的事件不能保证同时，但发post能保证同时（相差0.2毫秒），通过这种方法，测试了redis的setkey，getkey来保证不重复数据的时间阈值在几百纳秒，再短就算redis也无能为力了，所以多线程虽然快，但是没锁，还是不太安全。。

import java.io.BufferedReader

import java.io.File

import java.io.FileInputStream

import java.io.InputStreamReader

import java.io.PrintWriter

import java.net.HttpURLConnection

import java.net.URL

import java.util.HashMap

import java.util.Map

import java.util.concurrent.ExecutorService

import java.util.concurrent.Executors

import java.util.concurrent.Semaphore

public class ConcurrentTest {

private static int thread_num = 200

private static int client_num = 460

private static Map keywordMap = new HashMap()

static {

try {

InputStreamReader isr = new InputStreamReader(new FileInputStream(

new File("clicks.txt")), "GBK")

BufferedReader buffer = new BufferedReader(isr)

String line = ""

while ((line = buffer.readLine()) != null) {

keywordMap.put(line.substring(0, line.lastIndexOf(":")), "")

}

} catch (Exception e) {

e.printStackTrace()

}

}

public static void main(String[] args) {

int size = keywordMap.size()

// TODO Auto-generated method stub

ExecutorService exec = Executors.newCachedThreadPool()

// 50个线程可以同时访问

final Semaphore semp = new Semaphore(thread_num)

// 模拟2000个客户端访问

for (int index = 0 index < client_num index++) {

final int NO = index

Runnable run = new Runnable() {

public void run() {

try {

// 获取许可

semp.acquire()

System.out.println("Thread:" + NO)

String host = "http://10.99.23.42:7001/KMQueryCenter/query.do?"

String para = "method=getQueryResult&pageNum=1&pageSize=5&"

+ "queryKeyWord="

+ getRandomSearchKey(NO)

+ "&questionID=-1&questionIdPath=-1&searchType=1"

+ "&proLine=&proSeries=&proType=" + NO

System.out.println(host + para)

URL url = new URL(host)// 此处填写供测试的url

HttpURLConnection connection = (HttpURLConnection) url

.openConnection()

// connection.setRequestMethod("POST")

// connection.setRequestProperty("Proxy-Connection",

// "Keep-Alive")

connection.setDoOutput(true)

connection.setDoInput(true)

PrintWriter out = new PrintWriter(connection

.getOutputStream())

out.print(para)

out.flush()

out.close()

BufferedReader in = new BufferedReader(

new InputStreamReader(connection

.getInputStream()))

String line = ""

String result = ""

while ((line = in.readLine()) != null) {

result += line

}

// System.out.println(result)

// Thread.sleep((long) (Math.random()) * 1000)

// 释放

System.out.println("第：" + NO + " 个")

semp.release()

} catch (Exception e) {

e.printStackTrace()

}

}

}

exec.execute(run)

}

// 退出线程池

exec.shutdown()

}

private static String getRandomSearchKey(final int no) {

String ret = ""

int size = keywordMap.size()

// int wanna = (int) (Math.random()) * (size - 1)

ret = (keywordMap.entrySet().toArray())[no].toString()

ret = ret.substring(0, ret.lastIndexOf("="))

System.out.println("\t" + ret)

return ret

}

}

---