java模拟多线程http请求代码分享

发布于 2020-12-12|

复制链接

本篇文章给大家分享了java模拟多线程http请求的相关实例代码，对此有需要的可以跟着测试下。

java模拟http发送请求，第一种是HttpURLConnection发送post请求，第二种是使用httpclient模拟post请求，实例代码：

```java

package test;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import org.apache.http.HttpEntity;

import org.apache.http.NameValuePair;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.util.EntityUtils;

/**java 模拟测试多线程测试http请求

* @author wdh

*

*/

public class ServiceThreadTest implements Runnable{

private String url;

private Map paramStr;

public ServiceThreadTest(String url, Map paramStr) {

super();

this.url = url;

this.paramStr = paramStr;

}

public String getUrl() {

return url;

}

public void setUrl(String url) {

this.url = url;

}

public Map getParamStr() {

return paramStr;

}

public void setParamStr(Map paramStr) {

this.paramStr = paramStr;

}

@Override

public void run() {

// http请求实现方式

CloseableHttpClient httpClient = HttpClients.createDefault();

HttpPost post = new HttpPost(url);

RequestConfig config = RequestConfig.custom().setConnectionRequestTimeout(10000).setConnectTimeout(10000)

.setSocketTimeout(10000).build();

CloseableHttpResponse response = null;

try {

List params = setHttpNameValues(paramStr);

HttpEntity httpentity=new UrlEncodedFormEntity(params,"utf-8");

post.setEntity(httpentity);

post.setConfig(config);

response = httpClient.execute(post);

HttpEntity entity = response.getEntity();

String content = EntityUtils.toString(entity);

System.out.println("content:" + content);

} catch (Exception e) {

e.printStackTrace();

}

}

private List setHttpNameValues(Map paramMap) {

List params = new ArrayList();

for (Entry entry:paramMap.entrySet()){

params.add(new BasicNameValuePair(entry.getKey(),entry.getValue().toString()));

}

return params;

}

public static void main(String[] args) {

//运用java工具类中线程池

ExecutorService pool = Executors.newCachedThreadPool();

for (int i =0;i paramStr = getHttpParamStr();

pool.execute(new ServiceThreadTest(url,paramStr));

}

}

public static Map getHttpParamStr() {

Map param = new HashMap();

param.put("apiversion", 1);

param.put("appversion", "3.6.2");

return param;

}

}

```

#!/usr/bin python2.6

# -*- coding: utf-8 -*-

import threading, datetime, time, httplib

# 初始最大并发数

START_THEAD_COUNT = 200

# 递增并发数

THREAD_INCREASE_STEP = 10

# 域名

DOMAIN = 'www.baidu.com'

# 默认http请求

METHOD = 'get'

# 默认访问的web路径

PATH = '/'

# 请求发送间隔 整数

INTERVAL = 5  # 5秒

'''Factory'''

class biz :

'''Main'''

def run(self) :

start = datetime.datetime.now()

global FAILED_COUNT

FAILED_COUNT = 0

threads = []

# thread instance initialization

for i in range(START_THEAD_COUNT) :

t=threading.Thread(target=self.execute, args=())

threads.append(t)

# activate threads

for i in range(START_THEAD_COUNT) :

threads[i].start()

# wait for all ends

for i in range(START_THEAD_COUNT) :

threads[i].join()

delta = datetime.datetime.now() - start

writeline('INFO', 'Total is \'' + str(START_THEAD_COUNT) + '\' while failed \'' + str(FAILED_COUNT) + '\' in ' + str(delta.seconds) + str(delta.microseconds / 1000) + 'ms.')

return (True, None)

'''Execute http request and get response status'''

def execute(self) :

global FAILED_COUNT

conn = httplib.HTTPConnection(DOMAIN)

conn.request(METHOD, PATH)

r = conn.getresponse()

if r.status not in (200, 302) : FAILED_COUNT = FAILED_COUNT + 1

conn.close()

return (True, None)

'''Log writer'''

def writeline(status, msg) :

line = time.strftime('%Y-%m-%d %X', time.localtime(time.time())) + ' [' + status + '] ' + msg

print line

return (True, line)

if __name__ == '__main__' :

o = biz()

while True :

r, c = o.run()

if not r : writeline('FAILED-', c)

time.sleep(INTERVAL)

# update max threads

START_THEAD_COUNT = START_THEAD_COUNT + THREAD_INCREASE_STEP