package com.journaldev.socket;

import com.sun.security.ntlm.Server;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;
import java.net.*;


/**
 * This class implements java Socket server
 * @author pankaj
 *
 */
public class server {
    String message;

   public server(int port) throws IOException, ClassNotFoundException {

        ServerSocket server = new ServerSocket(port);
    //keep listens indefinitely until receives 'exit' call or program terminates
        while(true)

    {
        System.out.println("Waiting for the client request");
        //creating socket and waiting for client connection
        Socket client = server.accept();
        //read from socket to ObjectInputStream object
        ObjectInputStream ois = new ObjectInputStream(client.getInputStream());
        //convert ObjectInputStream object to String
        String message;
        message = (String) ois.readObject();
        System.out.println("Message Received: " + message);
        //create ObjectOutputStream object
        ObjectOutputStream oos = new ObjectOutputStream(client.getOutputStream());
        //write object to Socket
        oos.writeObject("Hi Client " + message);
        //close resources
        ois.close();
        oos.close();
        client.close();
        //terminate the server if client sends exit request
        if (message.equalsIgnoreCase("exit")) break;
    }
        System.out.println("Shutting down Socket server!!");
    //close the ServerSocket object
        server.close();
    }
    public static void main(String args[]) throws IOException, ClassNotFoundException{
        server s =new server(9876);
    }

}