Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.net.*;
- import java.io.*;
- public class SocketThread extends Thread
- {
- public PrintWriter out;
- public BufferedReader in;
- public Socket clientSocket;
- boolean m_bRunThread = true;
- //Message string for all.
- public String clientData;
- public SocketThread (Socket client)
- {
- clientSocket = client;
- }
- public void run()
- {
- try
- {
- PrintWriter out = new PrintWriter(clientSocket.getOutputStream());
- BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
- out.println(" ########################################");
- out.println(" # Welcome to the #");
- out.println(" # NexoGroup Chat Relay Server (CRS) #");
- out.println(" # Version 1.0.0 #");
- out.println(" ########################################\n\n");
- //Time to start some connections and transfer.
- while (m_bRunThread)
- {
- clientData = in.readLine();
- System.out.println("FROM " + clientSocket.getInetAddress() + ": " + clientData);
- if (clientData.equalsIgnoreCase("quit"))
- {
- m_bRunThread = false;
- System.out.println("Client Disconnected");
- }
- else
- {
- out.println(clientData);
- out.print(">");
- out.flush();
- }
- }
- }
- catch (IOException e) {
- System.err.println("Unable to pair with client");
- }
- //Clean up!
- finally
- {
- try
- {
- in.close();
- out.close();
- clientSocket.close();
- }
- catch (Throwable t)
- {
- System.out.printf("Client disconnected.");
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement