-
Notifications
You must be signed in to change notification settings - Fork 100
Expand file tree
/
Copy pathServerConsole.java
More file actions
105 lines (92 loc) · 3.02 KB
/
ServerConsole.java
File metadata and controls
105 lines (92 loc) · 3.02 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
import java.io.*;
import common.*;
public class ServerConsole implements ChatIF
{
//Class variables *************************************************
private EchoServer server;
//Constructors ****************************************************
/**
* Constructs an instance of the ClientConsole UI.
*
* @param port The port to connect on.
*/
public ServerConsole(EchoServer server){
this.server = server;
}
//Instance methods ************************************************
/**
* This method waits for input from the console. Once it is
* received, it sends it to the client's message handler.
*/
public void accept()
{
try
{
BufferedReader fromConsole =
new BufferedReader(new InputStreamReader(System.in));
String message;
while (true)
{
message = fromConsole.readLine();
if(message.charAt(0)==('#')){
if(message.equals("#quit")){
System.out.println("server quit");
server.close();
}
else if(message.equals("#setport")){
if (server.isListening()){
System.out.println("The serveris already connected.");
}
else{
String[] cmd = message.split(" ");
try
{
server.setPort(Integer.parseInt(cmd[1]));
}
catch(NumberFormatException e)
{
System.out.println("invaild input");
}
}
}
else if(message.equals("#stop")){
server.sendToAllClients("server stop listening");
server.stopListening();
}
else if(message.equals("#close")){
server.sendToAllClients("server stop listening and stop connecting");
server.close();
}
else if(message.equals("#start")){
if (server.isListening()){
System.out.println("The serveris already connected.");
}
else{
server.listen();
}
}
else if(message.equals("#getport")){
System.out.println(server.getPort());
}
}
server.sendToAllClients("Server MSG> " + message);
}
}
catch (Exception ex)
{
System.out.println
("Unexpected error while reading from console!");
}
}
/**
* This method overrides the method in the ChatIF interface. It
* displays a message onto the screen.
*
* @param message The string to be displayed.
*/
public void display(String message)
{
System.out.println("> " + message);
}
}
//End of ConsoleChat class