Guest User

Untitled

a guest
Apr 25th, 2018
60
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.82 KB | None | 0 0
  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import java.io.IOException;
  4. import java.io.OutputStreamWriter;
  5. import java.io.PrintWriter;
  6. import java.net.Socket;
  7. import java.util.Vector;
  8.  
  9. public class ChatHandler extends Thread {
  10. static Vector handlers = new Vector( 10 );
  11. private Socket socket;
  12. private BufferedReader in;
  13. private PrintWriter out;
  14.  
  15. public ChatHandler(Socket socket) throws IOException {
  16. this.socket = socket;
  17. in = new BufferedReader(
  18. new InputStreamReader(socket.getInputStream()));
  19. out = new PrintWriter(
  20. new OutputStreamWriter(socket.getOutputStream()));
  21. }
  22. public void run() {
  23. String line;
  24. synchronized(handlers) {
  25. handlers.addElement(this);
  26. // add() not found in Vector class
  27. }//
  28. try {
  29. System.out.println("Try executed");
  30. System.out.println("WTF?!");
  31. //System.out.println(in.readLine());
  32. line = "NULL";
  33. while(line != "quit") {
  34. System.out.println("Before readLine");
  35. line = in.readLine();
  36. System.out.println("WTF");
  37. //System.out.println("While executed");
  38. for(int i = 0; i < handlers.size(); i++) {
  39. //System.out.println("For executed");
  40. synchronized(handlers) {
  41. ChatHandler handler = (ChatHandler)handlers.elementAt(i);
  42. handler.out.println(line + "\r");
  43. handler.out.flush();
  44. }
  45. }
  46. }
  47. } catch(IOException ioe) {
  48. ioe.printStackTrace();
  49. } finally {
  50. try {
  51. in.close();
  52. out.close();
  53. socket.close();
  54. } catch(IOException ioe) {
  55. } finally {
  56. synchronized(handlers) {
  57. handlers.removeElement(this);
  58. }
  59. }
  60. }
  61. }
  62. }
Add Comment
Please, Sign In to add comment