-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMS.java
More file actions
125 lines (97 loc) · 5.31 KB
/
MS.java
File metadata and controls
125 lines (97 loc) · 5.31 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
120
121
122
123
124
125
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
class MS {
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();
// Send menu
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...");
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;
}
// 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...");
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);
}
// Close client connection (server keeps running)
}
}