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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
//CoordinatorCLient.java
package derms.Replica3pkg;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;
import java.io.*;
import java.util.*;
public class CoordinatorClient {
private String coordinatorID;
private String serverName;
private DERMSInterface server;
public CoordinatorClient(String coordinatorID) {
this.coordinatorID = coordinatorID;
this.serverName = coordinatorID.substring(0, 3).toUpperCase();
}
public void connectToServer() {
try {
String endpointURL = "";
switch (serverName) {
case "MTL":
endpointURL = "http://localhost:8080/DERMS/MTL?wsdl";
break;
case "QUE":
endpointURL = "http://localhost:8081/DERMS/QUE?wsdl";
break;
case "SHE":
endpointURL = "http://localhost:8082/DERMS/SHE?wsdl";
break;
default:
System.out.println("Invalid server code in coordinatorID.");
}
URL url = new URL(endpointURL);
QName qname = new QName("http://DERMS.org/", "ServerService");
Service service = Service.create(url, qname);
server = service.getPort(DERMSInterface.class);
System.out.println("Connected to " + serverName + " server.");
} catch (Exception e) {
e.printStackTrace();
}
}
public String requestResource(String resourceID, int duration) {
try {
String response = server.requestResource(coordinatorID, resourceID, duration);
log("requestResource", response);
System.out.println(response);
} catch (Exception e) {
e.printStackTrace();
}
return "OK";
}
public String findResource(String resourceName) {
try {
String response = server.findResource(coordinatorID, resourceName);
log("findResource", response);
System.out.println("Resources you have occupied:\n" + response);
} catch (Exception e) {
e.printStackTrace();
}
return "OK";
}
public String returnResource(String resourceID) {
try {
String response = server.returnResource(coordinatorID, resourceID);
log("returnResource", response);
System.out.println(response);
} catch (Exception e) {
e.printStackTrace();
}
return "OK";
}
public String swapResource(String coordinatorID, String oldResourceID, String oldResourceType, String newResourceID, String newResourceType) {
try {
String response = server.swapResource(coordinatorID, oldResourceID, oldResourceType, newResourceID, newResourceType);
log("swapResource", response);
System.out.println(response);
} catch (Exception e) {
e.printStackTrace();
}
return "OK";
}
private void log(String operation, String response) {
try (FileWriter fw = new FileWriter(coordinatorID + "_log.txt", true);
BufferedWriter bw = new BufferedWriter(fw);
PrintWriter out = new PrintWriter(bw)) {
String logEntry = String.format("%s - Operation: %s, Response: %s", new Date(), operation, response);
out.println(logEntry);
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
Scanner scanner = new Scanner(System.in);
connectToServer();
while (true) {
System.out.println("Coordinator menu:");
System.out.println("1. Request Resource");
System.out.println("2. Find Resource");
System.out.println("3. Return Resource");
System.out.println("4. Swap Resource");
System.out.println("5. Exit");
System.out.print("Enter choice (number): ");
int choice = Integer.parseInt(scanner.nextLine());
switch (choice) {
case 1:
System.out.print("Enter resourceID: ");
String resourceID = scanner.nextLine();
System.out.print("Enter duration: ");
int duration = Integer.parseInt(scanner.nextLine());
requestResource(resourceID, duration);
break;
case 2:
System.out.print("Enter resourceName: ");
String resourceName = scanner.nextLine();
findResource(resourceName);
break;
case 3:
System.out.print("Enter resourceID: ");
resourceID = scanner.nextLine();
returnResource(resourceID);
break;
case 4:
swapResource();
break;
case 5:
System.out.println("Exiting client");
scanner.close();
return;
default:
System.out.println("Invalid input");
}
}
}
public static void main(String[] args) {
Scanner scanner = new Scanner(System.in);
System.out.print("Enter coordinatorID: ");
String coordinatorID = scanner.nextLine();
CoordinatorClient client = new CoordinatorClient(coordinatorID);
client.run();
}
}
|