sperformance.java

Socket JAVA 测试客户端,用于压力测试时的数据发送.

import java.net.*;
import java.io.*;

public class SPerformance extends Thread {

  public final static String STR_ADDRESS = "127.0.0.1";

  public static void main(String args[]) {
    int i = 0;
    int iLength = 100;
    for (i = 0; i < iLength; i++) {
      SPerformance sClient = new SPerformance();
      sClient.start();
    }
  }

  public void run() {
    Socket socket = null;
    InputStream is = null;
    OutputStream os = null;
    String strOut = "  CCBE  6123456";
    String strIn = "";
    int i = 0;
    int iLength = 100;
    try {
      for (i = 0; i < iLength; i++) {
        socket = new Socket(STR_ADDRESS, 3333);
        os = socket.getOutputStream();
        is = socket.getInputStream();
        os.write(strOut.getBytes());
        os.flush();
        InputStreamReader isr = new InputStreamReader(is);
        BufferedReader br = new BufferedReader(isr);
        strIn = br.readLine();
        System.out.println(strIn);
        if (i  == 3) {
          sleep(Math.round(Math.random() * 1000));
        }
      }
    }
    catch (Exception e) {
      System.out.println("1--\n" + e);
    }
    finally {
      try {
        if (is != null) {
          is.close();
        }
        if (os != null) {
          os.close();
        }
        if (socket != null) {
          socket.close();
        }
      }
      catch (Exception e) {
        System.out.println(e);
      }
    }

  }
}