|
1 | 1 | package Client; |
2 | 2 |
|
3 | | -import Server.Interface.*; |
| 3 | +import Server.Interface.IResourceManager; |
4 | 4 | import Server.TCP.IProxyResourceManagerGetter; |
5 | 5 | import Server.TCP.Message; |
6 | 6 | import Server.TCP.AbstractProxyObject; |
7 | 7 | import Server.Common.Trace; |
8 | 8 |
|
9 | | -import java.rmi.registry.LocateRegistry; |
10 | | -import java.rmi.registry.Registry; |
11 | | -import java.rmi.RemoteException; |
12 | | -import java.rmi.NotBoundException; |
13 | | - |
14 | | -import java.util.*; |
15 | 9 | import java.io.*; |
16 | 10 | import java.net.*; |
17 | 11 |
|
18 | | - |
19 | 12 | public class TCPClient extends Client implements IProxyResourceManagerGetter |
20 | 13 | { |
21 | 14 | private static String s_serverHost = "localhost"; |
22 | 15 | private static int s_serverPort = 2005; |
23 | 16 | private static String s_serverName = "MiddlewareServer"; |
24 | 17 |
|
25 | | - //TODO: REPLACE 'ALEX' WITH YOUR GROUP NUMBER TO COMPILE |
26 | 18 | private static String s_tcpPrefix = "group25_"; |
27 | 19 |
|
28 | 20 | public static void main(String args[]) |
@@ -65,35 +57,40 @@ public TCPClient() |
65 | 57 | super(); |
66 | 58 | } |
67 | 59 |
|
| 60 | + @Override |
| 61 | + public void connectServer() { |
| 62 | + // do nothing, not used |
| 63 | + } |
| 64 | + |
68 | 65 | public AbstractProxyObject getProxyResourceManager(String hostname, int port, String boundName) |
69 | 66 | { |
70 | | - Message messageToSend = new Message(); |
71 | | - messageToSend.proxyObjectBoundName = s_tcpPrefix + boundName; |
72 | | - while(true) { |
73 | | - try { |
74 | | - Socket socket = new Socket(hostname, port); |
| 67 | + Message messageToSend = new Message(); |
| 68 | + messageToSend.proxyObjectBoundName = s_tcpPrefix + boundName; |
| 69 | + while(true) { |
| 70 | + try { |
| 71 | + Socket socket = new Socket(hostname, port); |
75 | 72 |
|
76 | | - ObjectOutputStream objectOutput = |
77 | | - new ObjectOutputStream(socket.getOutputStream()); |
78 | | - ObjectInputStream objectInput = |
79 | | - new ObjectInputStream(socket.getInputStream()); |
| 73 | + ObjectOutputStream objectOutput = |
| 74 | + new ObjectOutputStream(socket.getOutputStream()); |
| 75 | + ObjectInputStream objectInput = |
| 76 | + new ObjectInputStream(socket.getInputStream()); |
80 | 77 |
|
81 | | - objectOutput.writeObject(messageToSend); |
82 | | - try { |
83 | | - return (AbstractProxyObject)objectInput.readObject(); |
84 | | - } catch (Exception e) { |
85 | | - Trace.info(s_serverName + ": expected customerRM to be AbstractProxyObject. Cast failed."); |
86 | | - e.printStackTrace(); |
87 | | - System.exit(1); |
88 | | - } |
89 | | - } catch (Exception e) { |
90 | | - Trace.info(s_serverName + " waiting for customer server"); |
91 | | - try { |
92 | | - Thread.sleep(500); |
93 | | - } catch(Exception err) { |
94 | | - Trace.info("TCPMiddlewareResourceManager::getProxyResourceManager -> Thread sleep failed"); |
| 78 | + objectOutput.writeObject(messageToSend); |
| 79 | + try { |
| 80 | + return (AbstractProxyObject)objectInput.readObject(); |
| 81 | + } catch (Exception e) { |
| 82 | + Trace.info(s_serverName + ": expected customerRM to be AbstractProxyObject. Cast failed."); |
| 83 | + e.printStackTrace(); |
| 84 | + System.exit(1); |
| 85 | + } |
| 86 | + } catch (Exception e) { |
| 87 | + Trace.info(s_serverName + " waiting for customer server"); |
| 88 | + try { |
| 89 | + Thread.sleep(500); |
| 90 | + } catch(Exception err) { |
| 91 | + Trace.info("TCPMiddlewareResourceManager::getProxyResourceManager -> Thread sleep failed"); |
| 92 | + } |
| 93 | + } |
95 | 94 | } |
96 | | - } |
97 | | - } |
98 | 95 | } |
99 | 96 | } |
0 commit comments