Peer.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Peer {
    private static ServerSocket server;
    private static Socket clientSocket;
    private static Socket serverAccept;
    private static BufferedReader input;
    private static PrintStream output;
    private static ExecutorService pool = Executors.newFixedThreadPool(2);
    private static Scanner scan = new Scanner(System.in);

    public static void main(String[] args) throws IOException,NumberFormatException {

        System.out.print("Input your Port Number: ");
        String port_str = scan.nextLine();
        int port_int = Integer.parseInt(port_str);

        PeerClientThread peerClient = new PeerClientThread();
        pool.execute(peerClient);
        //System.out.println("TESTING 1,2,3");


        server = new ServerSocket(port_int);

        while(true) {
            serverAccept = server.accept();
            PeerServerThread peerServer = new PeerServerThread(serverAccept,server.getLocalPort());
            pool.execute(peerServer);
        }

    }
    /*
    public void run() {
        try {
            clientSocket = new Socket("localhost",9999);

            output = new PrintStream(clientSocket.getOutputStream());
            //output.println("Hello Server");

            input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            System.out.println(input.readLine());
            while(clientSocket.isConnected()) {

            }
        }
        catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    } */
}