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
|
public void run()
{
boolean connected = true;
try
{
ObjectInputStream in = new ObjectInputStream(cli.getInputStream());
ObjectOutputStream out = new ObjectOutputStream(cli.getOutputStream());
while(connected)
{
Object obj;
Object obj1;
try
{
obj = in.readObject();
System.out.println("Received Object from: " + cli);
if(obj instanceof User)
{
User u = (User)obj;
if(u.getType().equals("R"))
{
String s = regUser((User)obj);
System.out.println(s);
Message msg = new Message("Hello",s);
obj1 = msg;
out.writeObject(obj1);
Server.getAllUsers();
}
else if (u.getType().equals("L"))
{
String s = log((User)obj);
System.out.println(s);
Message msg = new Message("Hello",s);
obj1 = msg;
out.writeObject(obj1);
Server.getAllUsers();
}
else if(u.getType().equals("LO"))
{
logout((User)obj);
Server.getAllUsers();
}
}
}
catch(Exception e)
{
}
}
} |