package untitled1;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;

public class Server {
  private JTextField ft;
  private JTextArea display;
  private ObjectOutputStream output;
  private ObjectInputStream input;
  private ServerSocket server;
  private Socket connection;
  private int Counter=1;

  public Server() {
    super("server");
    Container conainer= getContentPane();
    ft= new JTextField();
    ft.setEnabled(false);
    ft.addActionListener( new ActionListener(){
      public void actionPerformed(ActionEvent event){
        sendData(event.getActionCommand());
      }
    });
    conainer.add(ft,BorderLayout.NORTH);
    display = new JTextArea();
    conainer.add(new JScrollPane(display),BorderLayout.CENTER);
    setSize(300,150);
    setVisible(true);
  }
  public void runSrever(){
    try{
     server = new ServerSocket(5000,100);
     while(true){
       waitForConnection();
       getStreams();
       processConnection();
       closeConncetion();
       ++Counter;
     }
    }
    catch(EOFException eofException){
      System.out.println("Client terminbate conncetion");
    }
    catch(IOException ioException){
     ioException.printStackTrace();
    }
  }
private void waitForConnection() throws IOException{
    display.setText("Waiting for conncetion");
    connection = server.accept();
    display.append("Conncetion    "+  Counter  +"  received  form   "+connection.getInetAddress().getHostName());

  }
  public void getStreams() throws IOException{
    output=new ObjectOutputStream(connection.getOutputStream());
    output.flush();
    input = new ObjectInputStream(connection.getInputStream());
    display.append("\nGot I/O streams");
  }
  public void processConnection() throws IOException{
    String message="SERVER>>>Conncetion succesful";
    output.writeObject(message);
    output.flush();
    do{
      try{
      message=(String)input.readObject();
      display.append("\n"+message);
      display.setCaretPosition(display.getText().length());
      }
      catch(ClassNotFoundException classe){
        display.append("\nUnknown onject type received");
      }
    }while(!message.equals("CLEENT>>>TERMINATE"));
  }
  public void closeConncetion()throws IOException{
    display.append("\nUser termainate connttion");
    ft.setEditable(false);
    output.close();
    input.close();
    connection.close();
  }
  public void sendData(String message){
    try{
      output.writeObject("SERVER>>>"+message);
      output.flush();
      display.append("\nSERVER>>>"+message);

    }
    catch(IOException ioExcetion){
      display.append("\nException writing object");
    }
  }
  public static void main(String args[]){
    Server application = new Server();
    application.setDefaultCloseOPeration(JFrame.EXIT_ON_CLOSE);
    application.runSrever();
  }
}