NP4

one to many chat



mserver.java

import java.io.*;

import java.net.*;

import java.util.*;

class mserver extends Thread

{

static ServerSocket ss;

static Socket cs=null;

static Vector v=new Vector(100);

static PrintWriter pw;

static int id=1;

public static void main(String args[])

{

try

{

ss=new ServerSocket(4000);

InputScan1 is=new InputScan1();

is.start();

while(true)

{

cs=ss.accept();

new ClientThread(cs,id).start();

pw=new PrintWriter(cs.getOutputStream(),true);

v.addElement(pw);

System.out.println("connected to client"+id);

id++;

}

}

catch(Exception e)

{}

}

}

class ClientThread extends mserver

{

Socket cs;

int id;

ClientThread(Socket clientsocket,int i)

{

cs=clientsocket;

id=i;

}

public void run()

{

try

{

BufferedReader in=new BufferedReader(new InputStreamReader(cs.getInputStream()));

String msg=null;

while(true)

{

msg=in.readLine();

System.out.println("client"+id+":"+msg);

if(msg!=null)

{

for(int i=0;i
((PrintWriter)v.elementAt(i)).println("client"+id+":"+msg);

}

}

}

catch(Exception e)

{}

}

}

class InputScan1 extends mserver

{

DataInputStream stdin=new DataInputStream(System.in);

public void run()

{

try

{

while(true)

{

String msg1;

msg1=stdin.readLine();

System.out.println("server:"+msg1);

if(msg1!=null)

{

for(int i=0;i
((PrintWriter)v.elementAt(i)).println("server"+":"+msg1);

}

}

}

catch(Exception e)

{ }

}

}





mclient.java



import java.io.*;

import java.net.*;

public class mclient extends Thread

{

static Socket cs=null;

public static void main(String args[])

{

try

{

cs=new Socket("localhost",4000);

System.out.println("connected to server");

BufferedReader in=new BufferedReader(new InputStreamReader(cs.getInputStream()));

InputScan is=new InputScan();

is.start();

while(true)

{

String msg;

msg=in.readLine();

System.out.println(msg);

}

}

catch(Exception e) { }

}

}



class InputScan extends mclient

{

DataInputStream stdin=new DataInputStream(System.in);

public void run()

{

try

{

PrintWriter out=new PrintWriter(cs.getOutputStream(),true);

while(true)

{

String msg;

msg=stdin.readLine();

out.println(msg);

}

}

catch(Exception e){}

}

}