import java.net.*;

import javax.sound.sampled.SourceDataLine;

import java.io.*;

class Server{

ServerSocket server;
Socket socket;

BufferedReader br;
PrintWriter out;

 public Server(){
      try{server = new ServerSocket(7777);
        System.out.println("Server is ready to accept connection");
        System.out.println("waiting...");
        socket=server.accept();
        
        br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

        out = new PrintWriter(socket.getOutputStream());

        startReading();
        startWriting();




 } catch(Exception e ){};}


public void startReading(){
  Runnable r1=()->{
    System.out.println("reader started...");

    try{
    while(true){
        
        String msg = br.readLine();
        if(msg.equals("EXIT")){System.out.println("Client terminated the chatting");
         socket.close();
          break;}

         System.out.println("Client : "+msg);
    
    
        }
    } catch(Exception e){System.out.print("----Connection is Closed----");}
  };

  new Thread(r1).start();
}



public void startWriting(){
  Runnable r2=()->{
    System.out.println("Writer started...");
    
    try{
    while(!socket.isClosed()){

          BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));

             String content=br1.readLine();

             out.println(content);
             out.flush();

             if(content.equals("EXIT")){
                socket.close();
                break;
            }

      }
    } catch(Exception e){System.out.print("----Connection is Closed----");};    
    
  };

  new Thread(r2).start();
}






public static void main(String[] args){
    System.out.println("This is server..going to start server");
    new Server();
}



}