-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathEchoServer.java
152 lines (128 loc) · 4.03 KB
/
EchoServer.java
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
// This file contains material supporting section 3.7 of the textbook:
// "Object Oriented Software Engineering" and is issued under the open-source
// license found at www.lloseng.com
import java.io.*;
import ocsf.server.*;
/**
* This class overrides some of the methods in the abstract
* superclass in order to give more functionality to the server.
*
* @author Dr Timothy C. Lethbridge
* @author Dr Robert Laganière
* @author François Bélanger
* @author Paul Holden
* @version July 2000
*/
public class EchoServer extends AbstractServer
{
ServerConsole servCon;
boolean alreadyLoggedIn = false;
//Class variables *************************************************
/**
* The default port to listen on.
*/
final public static int DEFAULT_PORT = 5555;
//Constructors ****************************************************
/**
* Constructs an instance of the echo server.
*
* @param port The port number to connect on.
*/
public EchoServer(int port)
{
super(port);
}
//Instance methods ************************************************
/**
* This method handles any messages received from the client.
*
* @param msg The message received from the client.
* @param client The connection from which the message originated.
*/
public void handleMessageFromClient(Object msg, ConnectionToClient client){
String[] message = msg.toString().split(" ");
if(alreadyLoggedIn == true && message[0].equals("#login")){
System.out.println("You have already logged in!");
}
if(message[0].equals("#login")) {
client.setInfo("loginId", message[1]);
alreadyLoggedIn = true;
return;
}
System.out.println("Message received: " + msg + " from " + client.getInfo("loginId") + " : " + client + " ");
this.sendToAllClients(client.getInfo("loginId") + " : " + msg);
}
// méthode qui prend le message de la console d'un serveur
public void handleMessageFromServerUI(String message, ServerConsole serverCon)
{
serverCon.display(message);
super.sendToAllClients(message);
}
/**
* This method overrides the one in the superclass. Called
* when the server starts listening for connections.
*/
protected void serverStarted()
{
System.out.println("Server listening for connections on port " + getPort());
}
/**
* This method overrides the one in the superclass. Called
* when the server stops listening for connections.
*/
protected void serverStopped()
{
System.out.println("Server has stopped listening for connections.");
}
/*
trois méthodes suivantes sont nécéssaires pour afficher
un message sur le EchoServer console qu'un client s'est
déconnecté ou connecté
*/
protected void clientConnected(ConnectionToClient client){
System.out.println("Client has connected");
}
synchronized protected void clientDisconnected(ConnectionToClient client){
System.out.println("Client has disconnected");
}
synchronized protected void clientException(ConnectionToClient client,
Throwable exception) {
clientDisconnected(client);
}
public void quit(){
try{ close(); }
catch(IOException e) {}
System.exit(0);
}
//Class methods ***************************************************
/**
* This method is responsible for the creation of
* the server instance (there is no UI in this phase).
*
* @param args[0] The port number to listen on. Defaults to 5555
* if no argument is entered.
*/
public static void main(String[] args)
{
int port = 0; //Port to listen on
try
{
port = Integer.parseInt(args[0]); //Get port from command line
}
catch(Throwable t)
{
port = DEFAULT_PORT; //Set port to 5555
}
EchoServer sv = new EchoServer(port);
ServerConsole serverCon = new ServerConsole(port);
try
{
serverCon.accept();
}
catch (Exception ex)
{
System.out.println("ERROR - Could not listen for clients!");
}
}
}
//End of EchoServer class