Skip to content
Snippets Groups Projects
Commit e8c1a1cc authored by ethanjwilliams's avatar ethanjwilliams
Browse files

Williams - Homework 2

parent 671f8450
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
assignments/src/MV3500Cohort2024JulySeptember/homework2/Williams/HW2Client.java
+ 81
− 39
View file @ e8c1a1cc
package MV3500Cohort2024JulySeptember.homework2.Williams;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
/**
* Client file for HW2.
......@@ -13,45 +16,84 @@ import java.util.Scanner;
public class HW2Client {
/**
* @param args the command line arguments
* Default constructor
*/
public HW2Client() {
}
static String DESTINATION_HOST = "localhost";
static int DESTINATION_PORT = 2317;
static int MAX_LOOP_COUNT = 1;
/**
* @param args command-line arguments
*/
public static void main(String[] args) {
DatagramSocket socket = null;
Scanner scanner = new Scanner(System.in);
try {
socket = new DatagramSocket();
InetAddress serverAddress = InetAddress.getByName("localhost");
byte[] sendData = new byte[1024];
byte[] receiveData = new byte[1024];
System.out.print("Can you solve my riddle??\n");
System.out.print("Try to solve the riddle: I speak without a mouth and hear without ears. I have no body, but I come alive with wind. What am I?\n");
while (true) {
System.out.print("Enter your answer: ");
String answer = scanner.nextLine();
sendData = answer.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, serverAddress, 9876);
socket.send(sendPacket);
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
socket.receive(receivePacket);
String response = new String(receivePacket.getData(), 0, receivePacket.getLength());
System.out.println("Server Said: " + response);
if (response.startsWith("Good")) {
break;
if (args.length > 0) {
DESTINATION_HOST = args[0];
}
if (args.length > 1) {
DESTINATION_PORT = Integer.parseInt(args[1]);
}
if (args.length > 2) {
MAX_LOOP_COUNT = Integer.parseInt(args[2]);
}
System.out.println("=======================================================");
for (int loopCount = 1; loopCount <= MAX_LOOP_COUNT; loopCount++) {
System.out.println(HW2Client.class.getName() + " creating new socket:");
long startTime = System.currentTimeMillis();
Socket socket = null;
BufferedReader br = null;
PrintWriter pw = null;
try {
socket = new Socket(DESTINATION_HOST, DESTINATION_PORT);
InputStream is = socket.getInputStream();
br = new BufferedReader(new InputStreamReader(is));
OutputStream os = socket.getOutputStream();
pw = new PrintWriter(os, true);
String serverMessage = br.readLine();
System.out.println("Server: " + serverMessage);
String clientResponse = "Ethan";
pw.println(clientResponse);
System.out.println("Client: " + clientResponse);
String serverFinalResponse = br.readLine();
long readTime = System.currentTimeMillis();
long timeLength = readTime - startTime;
System.out.println("Server response: " + serverFinalResponse);
System.out.println(HW2Client.class.getName() + ": time msec required for read = " + timeLength);
System.out.println("=======================================================");
} catch (IOException e) {
System.out.println("Problem with " + HW2Client.class.getName() + " networking:");
System.out.println("Error: " + e);
if (e instanceof java.net.BindException) {
System.out.println("*** Be sure to stop any other running instances of programs using this port!");
}
} finally {
try {
if (br != null) {
br.close();
}
if (pw != null) {
pw.close();
}
if (socket != null && !socket.isClosed()) {
socket.close();
}
} catch (IOException e) {
System.out.println("Error closing resources: " + e);
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (scanner != null) {
scanner.close();
}
if (socket != null && !socket.isClosed()) {
socket.close();
}
}
System.out.println(HW2Client.class.getName() + " complete");
}
}
assignments/src/MV3500Cohort2024JulySeptember/homework2/Williams/HW2Server.java
+ 40
− 40
View file @ e8c1a1cc
package MV3500Cohort2024JulySeptember.homework2.Williams;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Server file for HW2.
......@@ -12,50 +13,49 @@ import java.net.InetAddress;
public class HW2Server {
/**
* @param args the command line arguments
* Default constructor
*/
public static void main(String[] args) {
DatagramSocket socket = null;
String riddleAnswer = "echo";
public HW2Server() {
}
/**
* @param args command-line arguments
*/
public static void main(String[] args) {
try {
socket = new DatagramSocket(9876);
byte[] receiveData = new byte[1024];
byte[] sendData = new byte[1024];
int count = 1;
System.out.println("Server has started, waiting for client...");
boolean isRunning = true;
while (isRunning) {
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
socket.receive(receivePacket);
String message = new String(receivePacket.getData(), 0, receivePacket.getLength());
InetAddress clientAddress = receivePacket.getAddress();
int clientPort = receivePacket.getPort();
System.out.println("Client sent: " + message);
String response;
if (message.trim().equalsIgnoreCase(riddleAnswer)) {
response = "Good Job!! You solved the riddle in " + count + " tries!";
isRunning = false;
} else {
response = "Wrong answer. Try again!";
count++;
}
ServerSocket serverSocket = new ServerSocket(2317);
HW2Thread handlerThread;
Socket clientConnection;
int connectionCount = 0;
System.out.println(HW2Server.class.getName() + " ready to accept socket connections...");
while (true) {
clientConnection = serverSocket.accept();
sendData = response.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, clientAddress, clientPort);
socket.send(sendPacket);
connectionCount++;
try {
PrintWriter out = new PrintWriter(clientConnection.getOutputStream(), true);
out.println("I'd like to shake your hand. What's your name?");
} catch (IOException e) {
System.out.println("Error sending initial message to client: " + e);
}
System.out.println("=============================================================");
System.out.println(HW2Server.class.getName() + ".handlerThread created for connection #" + connectionCount + "...");
handlerThread = new HW2Thread(clientConnection);
handlerThread.start();
System.out.println(HW2Server.class.getName() + ".handlerThread is now dispatched and running, using most recent connection...");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (socket != null && !socket.isClosed()) {
socket.close();
} catch (IOException e) {
System.out.println("Problem with " + HW2Server.class.getName() + " networking:");
System.out.println("Error: " + e);
if (e instanceof java.net.BindException) {
System.out.println("*** Be sure to stop any other running instances of programs using this port!");
}
}
System.out.println("=============================================================");
}
}
assignments/src/MV3500Cohort2024JulySeptember/homework2/Williams/HW2Thread.java 0 → 100644
+ 97
− 0
View file @ e8c1a1cc
package MV3500Cohort2024JulySeptember.homework2.Williams;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
/**
*
* @author ethanjwilliams
*/
public class HW2Thread extends Thread {
/**
* The socket connection to a client
*/
private final Socket socket;
private static int connectionCount = 0;
/**
* The thread constructor creates the socket from a ServerSocket, waiting
* for the client to connect, and passes that socket when constructing the
* thread responsible for handling the connection.
*
* @param socket The socket connection handled by this thread
*/
HW2Thread(Socket socket) {
this.socket = socket;
synchronized (HW2Thread.class) {
connectionCount++;
}
}
/**
* Program invocation and execution starts here - but is illegal and
* unwanted, so warn the unsuspecting user!
*
* @param args command-line arguments
*/
public static void main(String[] args) {
System.out.println("*** HW2Thread is not a standalone executable progam.");
System.out.println("*** Please run HW2Server instead... now exiting.");
}
/**
* Handles one connection. We add an artificial slowness to handling the
* connection with a sleep(). This means the client won't see a server
* connection response for ten seconds (default).
*/
@Override
public void run() {
BufferedReader br = null;
PrintStream ps = null;
try {
System.out.println(HW2Thread.class.getName() + " starting to handle a thread...");
InputStream is = socket.getInputStream();
br = new BufferedReader(new InputStreamReader(is));
OutputStream os = socket.getOutputStream();
ps = new PrintStream(os);
String clientResponse = br.readLine();
System.out.println("Received from client: " + clientResponse);
if ("Ethan".equalsIgnoreCase(clientResponse.trim())) {
ps.println("Nice to meet you!");
} else {
ps.println("Say your name again.");
}
ps.flush();
System.out.println(HW2Thread.class.getName() + " finished handling a thread, now exit.");
} catch (IOException e) {
System.out.println("Problem with " + HW2Thread.class.getName() + " networking:");
System.out.println("Error: " + e);
if (e instanceof java.net.BindException) {
System.out.println("*** Be sure to stop any other running instances of programs using this port!");
}
} finally {
try {
if (br != null) {
br.close();
}
if (ps != null) {
ps.close();
}
socket.close();
} catch (IOException e) {
System.out.println("Error closing resources: " + e);
}
}
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment