FilesExpand file tree

main

/

UserThread.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

74 lines (62 loc) · 2.2 KB

main

/

UserThread.java

Copy path

Top

File metadata and controls

• Code
• Blame

74 lines (62 loc) · 2.2 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

import java.io.*;

import java.net.Socket;

/*

This thread handles connection for each connected client, so the server can handle

multiple clients at the same time.

*/

public class UserThread extends Thread {

private Socket socket;

private ChatServer server;

private PrintWriter writer;

public UserThread(Socket socket, ChatServer server) {

this.socket = socket;

this.server = server;

}

public void run() {

try {

InputStream input = socket.getInputStream();

BufferedReader reader = new BufferedReader(new InputStreamReader(input));

OutputStream output = socket.getOutputStream();

writer = new PrintWriter(output, true);

printUsers();

String userName = reader.readLine();

server.addUserName(userName);

String serverMessage = "New user connected: " + userName;

server.broadcast(serverMessage, this);

//sends message to all connected clients

String clientMessage;

do {

clientMessage = reader.readLine();

serverMessage = "[" + userName + "]: " + clientMessage;

server.broadcast(serverMessage, this);

} while (!clientMessage.equals("bye"));

server.removeUser(userName, this);

socket.close();

serverMessage = userName + " has quit.";

server.broadcast(serverMessage, this);

} catch (IOException ex) {

System.out.println("Error in UserThread: " + ex.getMessage());

ex.printStackTrace();

/*

This is often useful for debugging purposes, as it allows you to see

the sequence of method calls that led to the exception being thrown.

*/

}

}

/*

Sends a list of online users to the newly connected user.

*/

void printUsers() {

if (server.hasUsers()) {

writer.println("Connected users: " + server.getUserNames());

} else {

writer.println("No users connected");

}

}

/*

Sends a message to the client.

*/

void sendMessage(String message) {

writer.println(message);

}

}