51 lines
1.4 KiB
Java
51 lines
1.4 KiB
Java
// 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
|
|
}
|
|
}
|
|
}
|