attic/btcollider
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Removed test client

Browse source
This commit is contained in:
armin 2018-04-28 21:47:03 +02:00
parent bda6330fbb
commit aac8d626e1
2 changed files with 0 additions and 82 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
client/src/client/ClientRunner.java
View file

@ -1,54 +0,0 @@
package client;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class ClientRunner implements Runnable {
long sleep;
private String host;
private Integer port;
private boolean skip;
public ClientRunner(String host, Integer port, long sleep, boolean skip) {
this.sleep = sleep;
this.host = host;
this.port = port;
this.skip = skip;
}
@Override
public void run() {
try {
Socket socket = new Socket(host, port);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
out.println("WRK");
String work = in.readLine();
System.out.println("Sleep: "+sleep+", skip: "+skip+", work: "+work);
socket.close();
if (!skip) {
Thread.sleep(sleep);
socket = new Socket(host, port);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
out.println("RES");
out.println(work);
socket.close();
}
} catch (Exception e) {
System.out.println(e);
}
}
}

28
client/src/client/CommClient.java
View file

@ -1,28 +0,0 @@
package client;
public class CommClient {
private static final String HOST = "localhost";
private static final Integer PORT = 26765;
public static void main(String[] args) throws Exception {
for (int i = 0; i < 5; i++) {
new Thread(new ClientRunner(HOST, PORT, 5000, false)).start();
new Thread(new ClientRunner(HOST, PORT, 15000, false)).start();
new Thread(new ClientRunner(HOST, PORT, 0, true)).start();
new Thread(new ClientRunner(HOST, PORT, 5000, false)).start();
}
Thread.sleep(20000);
System.out.println("******** BATCH 2 ********");
for (int i = 0; i < 5; i++) {
new Thread(new ClientRunner(HOST, PORT, 5000, false)).start();
new Thread(new ClientRunner(HOST, PORT, 5000, false)).start();
new Thread(new ClientRunner(HOST, PORT, 15000, false)).start();
new Thread(new ClientRunner(HOST, PORT, 0, true)).start();
new Thread(new ClientRunner(HOST, PORT, 5000, false)).start();
}
}
}