Advertisement
Guest User

SocketThread ChatRelayCode

a guest
Apr 1st, 2012
743
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.11 KB | None | 0 0
  1. import java.net.*;
  2. import java.io.*;
  3. public class SocketThread extends Thread
  4. {
  5.     public PrintWriter out;
  6.     public BufferedReader in;
  7.     public Socket clientSocket;
  8.     boolean m_bRunThread = true;
  9.     //Message string for all.
  10.     public String clientData;
  11.    
  12.     public SocketThread (Socket client)
  13.     {
  14.         clientSocket = client;
  15.     }
  16.    
  17.     public void run()
  18.     {
  19.         try
  20.         {
  21.              PrintWriter out = new PrintWriter(clientSocket.getOutputStream());
  22.              BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
  23.              out.println("                 ########################################");
  24.              out.println("                 #            Welcome to the            #");
  25.              out.println("                 #   NexoGroup Chat Relay Server (CRS)  #");
  26.              out.println("                 #             Version 1.0.0            #");
  27.              out.println("                 ########################################\n\n");
  28.              
  29.         //Time to start some connections and transfer.
  30.         while (m_bRunThread)
  31.         {
  32.             clientData = in.readLine();
  33.             System.out.println("FROM " + clientSocket.getInetAddress() + ": " + clientData);
  34.            
  35.             if (clientData.equalsIgnoreCase("quit"))
  36.             {
  37.                 m_bRunThread = false;
  38.                 System.out.println("Client Disconnected");
  39.             }
  40.             else
  41.             {
  42.                 out.println(clientData);
  43.                 out.print(">");
  44.                 out.flush();
  45.             }
  46.         }
  47.         }
  48.         catch (IOException e) {
  49.         System.err.println("Unable to pair with client");
  50.         }
  51.        
  52.         //Clean up!
  53.         finally
  54.         {
  55.                 try
  56.                 {
  57.                 in.close();
  58.                 out.close();
  59.                 clientSocket.close();
  60.                 }
  61.                 catch (Throwable t)
  62.                 {
  63.                     System.out.printf("Client disconnected.");
  64.                 }
  65.         }
  66.     }
  67. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement