Server programs are rarely implemented as non-threaded applications, even though that is how you implemented your previous server application. Servers would not be able to provide the necessary throughput unless they used threading to allow for I/O to occur concurrently with servicing client requests. For this Assignment, you will modify your finger server program from Week 6 to use threads.
Modify your finger server program to use threads. The server should activate a new thread to process each incoming client request, thus allowing client requests to be processed concurrently.
FingerServer.java:
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class FingerServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(79);
System.out.println(“The Finger Server is now ready!”);
while (true) { Socket socket = serverSocket.accept();
System.out.println(“Accepted an echo request”);
System.out.println(“… local socket address ” + socket.getLocalSocketAddress());
System.out.println(“… remote socket address ” + socket.getRemoteSocketAddress());
BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter output = new PrintWriter(socket.getOutputStream());
String line; while (true) { line = input.readLine(); if (line == null) break;
System.out.println(“Client said: ” + line);
output.write(“Message from server: ” + line);
output.flush(); }
socket.close();
}
}
}
FingerClient.java:
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class FingerClient {
public static void main(String[] args) throws IOException {
int b;
if(args.length < 2) {
System.out.println(“Provide ip address and message through command line”);
return;
} Socket socket = new Socket(args[0], 79);
InputStream input = socket.getInputStream();
OutputStream output = socket.getOutputStream();
System.out.println(“The socket is connected the server.”);
System.out.println(“… local socket address is ” + socket.getLocalSocketAddress());
System.out.println(“… remote socket address is ” + socket.getRemoteSocketAddress());
output.write(args[1].getBytes());
socket.shutdownOutput();
while (true) { b = input.read();
if (b == -1) { break; } System.out.print((char) b);
}
System.out.println();
socket.close();
}
}