-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMS2.java
More file actions
119 lines (100 loc) · 5.44 KB
/
MS2.java
File metadata and controls
119 lines (100 loc) · 5.44 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
class MS2 {
public static void main(String argv[]) throws Exception {
DatagramSocket serverSocket = new DatagramSocket(6789);
System.out.println("UDP Math Server is running on port 6789...");
byte[] receiveBuffer = new byte[1024];
byte[] sendBuffer;
DatagramPacket sendPacket;
while (true) {
DatagramPacket receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
serverSocket.receive(receivePacket);
InetAddress clientAddress = receivePacket.getAddress();
int clientPort = receivePacket.getPort();
while (true) {
// Send menu after receiving initial request
sendBuffer = "Select 1 to add, 2 to subtract, 3 to multiply, 4 to exit.\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
System.out.println("Waiting for client choice...");
receiveBuffer = new byte[1024]; // Clear buffer
receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
serverSocket.receive(receivePacket);
String choiceStr = new String(receivePacket.getData(), 0, receivePacket.getLength());
int choice;
try {
choice = Integer.parseInt(choiceStr);
} catch (NumberFormatException e) {
sendBuffer = "Invalid input. Please enter a number.\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
continue;
}
// Exit condition
if (choice == 4) {
System.out.println("Client exited.");
break; // Instead of terminating, just break out of the inner loop
}
// Check if choice is valid
if (choice < 1 || choice > 3) {
sendBuffer = "Invalid choice. Try again.\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
continue;
}
// Ask for operands
sendBuffer = "Enter operands (separated by space):\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
System.out.println("Waiting for operands...");
receiveBuffer = new byte[1024]; // Clear buffer
receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
serverSocket.receive(receivePacket);
String operandStr = new String(receivePacket.getData(), 0, receivePacket.getLength());
String[] operands = operandStr.split(" ");
if (operands.length < 2) {
sendBuffer = "Error: Enter at least two numbers.\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
continue;
}
double result;
try {
result = Double.parseDouble(operands[0]); // Initialize with first operand
// Process based on operation
switch (choice) {
case 1: // Addition
for (int i = 1; i < operands.length; i++) {
result += Double.parseDouble(operands[i]);
}
break;
case 2: // Subtraction
for (int i = 1; i < operands.length; i++) {
result -= Double.parseDouble(operands[i]);
}
break;
case 3: // Multiplication
for (int i = 1; i < operands.length; i++) {
result *= Double.parseDouble(operands[i]);
}
break;
}
} catch (NumberFormatException e) {
sendBuffer = "Error: Invalid number format.\n".getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
continue;
}
// Send result to client
System.out.println("Computed Result: " + result);
String resultMessage = "Result: " + result;
sendBuffer = resultMessage.getBytes();
sendPacket = new DatagramPacket(sendBuffer, sendBuffer.length, clientAddress, clientPort);
serverSocket.send(sendPacket);
}
}
}
}