package com.socket;

import com.ui.ServerFrame;
import java.io.*;
import java.net.*;

class ServerThread extends Thread {

public SocketServer server = null;
public Socket socket = null;
public int ID = -1;
public String username = "";
public ObjectInputStream streamIn = null;
public ObjectOutputStream streamOut = null;
public ServerFrame ui;

public ServerThread(SocketServer _server, Socket _socket){
super();
   server = _server;
   socket = _socket;
   ID = socket.getPort();
   ui = _server.ui;
}

public void send(Message msg){
   try {
         streamOut.writeObject(msg);
         streamOut.flush();
   }
   catch (IOException ex) {
         System.out.println("Exception [SocketClient : send(...)]");
   }
}

public int getID(){
return ID;
}

@SuppressWarnings("deprecation")
public void run(){
ui.jTextArea1.append("\nServer Thread " + ID + " running.");
   while (true){
try{
            Message msg = (Message) streamIn.readObject();
server.handle(ID, msg);
         }
         catch(Exception ioe){
         System.out.println(ID + " ERROR reading: " + ioe.getMessage());
            server.remove(ID);
            stop();
         }
   }
}

public void open() throws IOException {
   streamOut = new ObjectOutputStream(socket.getOutputStream());
   streamOut.flush();
   streamIn = new ObjectInputStream(socket.getInputStream());
}

public void close() throws IOException {
if (socket != null) socket.close();
   if (streamIn != null) streamIn.close();
   if (streamOut != null) streamOut.close();
}
}

Write an Internet chat application with a server program and a clie...