// network/SimpleClient2.java

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

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

// Visit http://OnJava8.com for more book information.

package network;

import java.net.*;

import java.io.*;

public class SimpleClient2 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 SimpleClient2(InetAddress address) {

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

this.address = address;

threadcount++;

}

@Override

public void run() {

try (

Socket socket =

new Socket(address, ServeOne.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

}

}

}