// network/MultiSimpleClient.java

// (c)2016 MindView LLC: see Copyright.txt

// We make no guarantees that this code is fit for any purpose.

// Visit http://mindviewinc.com/Books/OnJava/ for more book information.

// Testing MultiSimpleServer with multiple clients.

// {ValidateByHand}

package network;

import java.net.*;

import java.io.*;

import onjava.*;

class SimpleClientThread implements Runnable {

private InetAddress address;

private static int counter = 0;

private int id = counter++;

private static int threadcount = 0;

public static int threadCount() {

return threadcount;

}

public SimpleClientThread(InetAddress address) {

System.out.println("Making client " + id);

this.address = address;

threadcount++;

}

@Override

public void run() {

try (

Socket socket =

new Socket(address, MultiSimpleServer.PORT);

BufferedReader in =

new BufferedReader(

new InputStreamReader(

socket.getInputStream()));

PrintWriter out =

new PrintWriter(

new BufferedWriter(

new OutputStreamWriter(

// Enable auto-flush:

socket.getOutputStream())), true)

) {

for (int i = 0; i < 25; i++) {

out.println("Client " + id + ": " + i);

String str = in.readLine();

System.out.println(str);

}

out.println("END");

} catch (IOException ex) {

throw new RuntimeException(ex);

} finally {

threadcount--; // Ending this thread

}

}

}

public class MultiSimpleClient {

static final int MAX_THREADS = 40;

public static void

main(String[] args) throws IOException,

InterruptedException {

new TimedAbort(5); // Terminate after 5 seconds

InetAddress address = InetAddress.getByName(null);

while(true) {

if(SimpleClientThread.threadCount() < MAX_THREADS)

new SimpleClientThread(address);

Thread.sleep(100);

}

}

}