Java 模拟并发访问

类:NetUtils.java

import java.io.DataInputStream;      
import java.io.DataOutputStream;          
import java.net.HttpURLConnection;      
import java.net.URL;          
import java.util.Map; 
import java.util.Properties;

public class NetUtils
{
	
	public static final String CHARACTER_ENCODING = "UTF-8";      
  public static final String PATH_SIGN = "/";      
  public static final String METHOD_POST = "POST";      
  public static final String METHOD_GET = "GET";      
  public static final String CONTENT_TYPE = "Content-Type";      
   
  /**    
   * 以POST方式向指定地址发送数据包请求,并取得返回的数据包    
   *     
   * @param urlString    
   * @param requestData    
   * @return 返回数据包    
   * @throws Exception    
   */     
  public static byte[] requestPost(String urlString, byte[] requestData)      
          throws Exception
  {      
      Properties requestProperties = new Properties();      
      requestProperties.setProperty(CONTENT_TYPE,      
              "application/octet-stream; charset=utf-8");      
   
      return requestPost(urlString, requestData, requestProperties);      
  }      

  /**    
   * 以POST方式向指定地址发送数据包请求,并取得返回的数据包    
   *     
   * @param urlString    
   * @param requestData    
   * @param requestProperties    
   * @return 返回数据包    
   * @throws Exception    
   */     
  public static byte[] requestPost(String urlString, byte[] requestData,      
          Properties requestProperties) throws Exception
  {
      byte[] responseData = null;      
      HttpURLConnection con = null;      
   
      try {      
          URL url = new URL(urlString);      
          con = (HttpURLConnection) url.openConnection();      
          //设置请求属性
          if ((requestProperties != null) && (requestProperties.size() > 0))
          {      
              for (Map.Entry<Object, Object> entry : requestProperties.entrySet())
              {      
                  String key = String.valueOf(entry.getKey());      
                  String value = String.valueOf(entry.getValue());      
                  con.setRequestProperty(key, value);      
              }      
          }      
   
          con.setRequestMethod(METHOD_POST); // 置为POST方法      
   
          con.setDoInput(true); // 开启输入流      
          con.setDoOutput(true); // 开启输出流      
   
          // 如果请求数据不为空，输出该数据。      
          if (requestData != null)
          {      
              DataOutputStream dos = new DataOutputStream(con.getOutputStream());      
              dos.write(requestData);
              dos.flush();      
              dos.close();      
          }      
   
          int length = con.getContentLength();      
          // 如果回复消息长度不为-1，读取该消息。      
          if (length != -1)
          {      
              DataInputStream dis = new DataInputStream(con.getInputStream());      
              responseData = new byte[length];      
              dis.readFully(responseData);      
              dis.close();      
          }      
      }
      catch (Exception e)
      {      
          throw e;      
      }
      finally
      {      
          if (con != null)
          {      
              con.disconnect();      
              con = null;      
          }      
      }      
      return responseData;      
  }      

}

评论

5 楼 icezx 2013-08-15  

alvin198761 写道

icezx 写道

alvin198761 写道

线程的执行时间不一样的吧，通过循环执行的，是并发？？

并发和执行时间不一致有毛关系

我做过大型的并发测试工具，要你教？你知道啥是并发不？

你做过大型并发测试工具,还问楼主这个是不是并发?

4 楼 alvin198761 2013-08-15  

icezx 写道

alvin198761 写道

线程的执行时间不一样的吧，通过循环执行的，是并发？？

并发和执行时间不一致有毛关系

我做过大型的并发测试工具，要你教？你知道啥是并发不？

3 楼 icezx 2013-08-14  

alvin198761 写道

线程的执行时间不一样的吧，通过循环执行的，是并发？？

并发和执行时间不一致有毛关系

2 楼 alvin198761 2012-04-28  

线程的执行时间不一样的吧，通过循环执行的，是并发？？

1 楼 xiangkw 2011-06-28  

Test 类：

import java.io.File;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Properties;
import java.util.Random;


public class MyTest extends Thread
{
	private final static int maxNum = 1000;
	private static String path = "http://10.111.132.85:1080/demo/bb1.jpg";
	private static String folderPath = "D:\\temp\\";
	/**
	 * @param args
	 */
	public static void main(String[] args)
	{
		long start = new Date().getTime(); 

		List<MyTest> list  = new ArrayList<MyTest>();

		//开启 N 个线程
		for(int i = 0;i<maxNum;i++)
		{
			MyTest test = new MyTest();
			test.start();
			list.add(test);
		}
		
		//等待N个线程都执行完成
		for(MyTest test : list)
		{
			try 
			{
				test.join();
			}
			catch (InterruptedException e)
			{
				e.printStackTrace();
			}
		}
		
		//计算出所耗的时间 （毫秒）
		long end = new Date().getTime();
		System.out.println("Time:"+(end-start)+" ms");
	}

	@Override
	public void run()
	{
		Properties requestProperties = new Properties();      
	   
    // 模拟浏览器信息      
    requestProperties.put("User-Agent",      
                    "Mozilla/3.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; TencentTraveler ; .NET CLR 1.1.4322)");      

		try
		{
			//相当于发送请求
			byte[] b = NetUtils.requestPost(path,"XML".getBytes(),requestProperties);
			
			//写文件
			FileOutputStream output = new FileOutputStream(this.initFile());
	    output.write(b);
	    output.close();
	    System.out.println(super.getName());
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}
	
	//生成以随机命名的文件，尽量保证文件名不重复；
	private File initFile()
	{
		String ext = path.substring(path.lastIndexOf("."));
		String randomStr = new Random().nextLong()+"_"+new Random().nextInt();
		String fileName = folderPath+randomStr+ext;
		
		return new File(fileName);
	}
}