Notes

package assignment2;
import java.io.*;

import java.net.*;

import java.util.*;



class Connection

{

public Socket s;

public PrintWriter o;

public BufferedReader i;

public boolean alive = false;

public int id;

public static int count = 0;

}



public class servertcp

{

ServerSocket serverSocket = null;

static public List<TCPChatServerThreadTask2> task = new ArrayList<TCPChatServerThreadTask2>();



class TCPChatServerThreadTask2 extends Thread

{

Connection c;



public TCPChatServerThreadTask2 (ServerSocket serverSocket) throws IOException

{

c = new Connection ();



c.s = serverSocket.accept ();

c.o = new PrintWriter (c.s.getOutputStream (), true);

c.i = new BufferedReader (new InputStreamReader (c.s.getInputStream ()));

c.alive = true;

c.id = ++ c.count;



System.out.println (c.s.getInetAddress () + ":" + c.s.getPort () + " Connected");



this.start ();

}



public void run ()

{

String fromClient;



try

{

do

{

fromClient = c.i.readLine ();



if (fromClient == null) break; // c.alive = false;



System.out.println (c.s.getInetAddress () + ":" + c.s.getPort () + "> " + fromClient);

System.out.println ("Connections: " + task.size() + " ActiveThreads: " + activeCount ());

for (int i = 0; i < task.size(); i ++)

{

task.get(i).c.o.println (c.s.getInetAddress () + ":" + c.s.getPort () + "> " + fromClient);

System.out.println ("To=" + task.get(i).c.s.getInetAddress() + ":" + task.get(i).c.s.getPort() + " id=" +c.id + " activecount=" + activeCount () + " message="" + c.s.getInetAddress () + ":" + c.s.getPort () + "> " + fromClient + """);

}

}

while (fromClient != "quit");



System.out.println (c.s.getInetAddress () + ":" + c.s.getPort () + " Disconnected");



c.o.close ();

c.i.close ();

c.s.close ();

c.alive = false;

task.remove(c.id - 1);

}

catch (IOException e)

{

System.out.println ("IOEXCEPTION!!!!!");

}

}

}



public servertcp () throws IOException

{

serverSocket = new ServerSocket (4455);



System.out.println ("Server: Listening on port 4455");



while (true)

{

task.add (new TCPChatServerThreadTask2 (serverSocket));

}

}



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

{

servertcp e = new servertcp ();

}

}