Multichat Application

[kaival patel]

This is kaival
i want to communicate one client to other client through my prog.
which coding given below.
This is my server programe which is connect multiple client but not brodcasting to all connected client and even personnel chat.
(This pro. compile by "Ser1" and run "Hand" name)

<font size=2.5>
import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.io.InputStreamReader;
import javax.swing.*;
import java.util.*;
class Ser1{
        int i = 1;
        char ch = 65;
        ServerSocket serverSocket;
        Socket clientSocket;
        Hashtable socketStore;
        PrintWriter printWriter;
        Object obj;
        Ser1(){
                try{
                serverSocket = new ServerSocket(1212);
                
                socketStore = new Hashtable();
                Enumeration socketName;
                
                for( ; ; ){
                clientSocket = serverSocket.accept();
                new Connector(clientSocket, ch).start();
                socketStore.put(clientSocket,new Character(ch));
                System.out.println("Connecting "+i);
                socketName = socketStore.keys();
                while(socketName.hasMoreElements()){
                        obj = socketName.nextElement();
                        System.out.println(obj + "  "+socketStore.get(obj));
                        }
                printWriter = new PrintWriter(clientSocket.getOutputStream(),true);
                printWriter.println();
                i++;
                ch++;
                new Join(clientSocket, ch).start();
                Thread.sleep(1000);
                }
                }
                catch(Exception e){}
        }
}        
class Connector extends Thread{
        Socket clientSocket;
        char ch;
        public Connector(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
                }
        public void run(){
                try{
                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                PrintWriter pr = new PrintWriter(clientSocket.getOutputStream(),true);
                pr.println("Hello ! dear connecter ");
                Thread.sleep(1000);
                }
                catch(Exception e){
                        System.out.println(e);
                }
        }
}

class Join extends Thread{
        Socket clientSocket;
        char ch;
        public Join(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
        }
        public void run(){
                for( ; ; ){
                        try{
                        BufferedReader in1 = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                        System.out.println(in1.readLine());
        
                        System.out.println("Enter messsage for client......");
                        BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));
                        String str1 = br1.readLine();
        
                        PrintWriter pr1 = new PrintWriter(clientSocket.getOutputStream(),true);
                        pr1.println(str1);
                        Thread.sleep(1000);
                        }
                        catch(Exception e){}
                }
        }
}
class Handler{
        public static void main(String args[]){
                Socket s = null;
                Ser1 se = new Ser1();
        }
}

Now here is my client code which is connect to server and communicate with that (here two client code given below. compile and run through same name)

<font size=2.5>
import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.io.InputStreamReader;
import javax.swing.*;
import java.util.*;
class Ser1{
        int i = 1;
        char ch = 65;
        ServerSocket serverSocket;
        Socket clientSocket;
        Hashtable socketStore;
        PrintWriter printWriter;
        Object obj;
        Ser1(){
                try{
                serverSocket = new ServerSocket(1212);
                
                socketStore = new Hashtable();
                Enumeration socketName;
                
                for( ; ; ){
                clientSocket = serverSocket.accept();
                new Connector(clientSocket, ch).start();
                socketStore.put(clientSocket,new Character(ch));
                System.out.println("Connecting "+i);
                socketName = socketStore.keys();
                while(socketName.hasMoreElements()){
                        obj = socketName.nextElement();
                        System.out.println(obj + "  "+socketStore.get(obj));
                        }
                printWriter = new PrintWriter(clientSocket.getOutputStream(),true);
                printWriter.println();
                i++;
                ch++;
                new Join(clientSocket, ch).start();
                Thread.sleep(1000);
                }
                }
                catch(Exception e){}
        }
}        
class Connector extends Thread{
        Socket clientSocket;
        char ch;
        public Connector(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
                }
        public void run(){
                try{
                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                PrintWriter pr = new PrintWriter(clientSocket.getOutputStream(),true);
                pr.println("Hello ! dear connecter ");
                Thread.sleep(1000);
                }
                catch(Exception e){
                        System.out.println(e);
                }
        }
}

/*
class JoinPersonel extends Thread{
        ServerSocket serverSocket = new ServerSocket(add,1212);
        char ch;
        public Join(ServerSocket serverSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
        }
        public void run(){
                        for( ; ; ){
                        try{
                        System.out.println("Hello world");
                        }
                        catch(Exception e){
                        System.out.println("While continue the client "+e);
                        }
                        }
        }
}
*/
class Join extends Thread{
        Socket clientSocket;
        char ch;
        public Join(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
        }
        public void run(){
                for( ; ; ){
                        try{
                        BufferedReader in1 = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                        System.out.println(in1.readLine());
        
                        System.out.println("Enter messsage for client......");
                        BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));
                        String str1 = br1.readLine();
        
                        PrintWriter pr1 = new PrintWriter(clientSocket.getOutputStream(),true);
                        pr1.println(str1);
                        Thread.sleep(1000);
                        }
                        catch(Exception e){}
                }
        }
}
class Handler{
        public static void main(String args[]){
                Socket s = null;
                Ser1 se = new Ser1();
        }
}

now this is second client code

<font size=2.5>
import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.io.InputStreamReader;
import javax.swing.*;
import java.util.*;
class Ser1{
        int i = 1;
        char ch = 65;
        ServerSocket serverSocket;
        Socket clientSocket;
        Hashtable socketStore;
        PrintWriter printWriter;
        Object obj;
        Ser1(){
                try{
                serverSocket = new ServerSocket(1212);
                
                socketStore = new Hashtable();
                Enumeration socketName;
                
                for( ; ; ){
                clientSocket = serverSocket.accept();
                new Connector(clientSocket, ch).start();
                socketStore.put(clientSocket,new Character(ch));
                System.out.println("Connecting "+i);
                socketName = socketStore.keys();
                while(socketName.hasMoreElements()){
                        obj = socketName.nextElement();
                        System.out.println(obj + "  "+socketStore.get(obj));
                        }
                printWriter = new PrintWriter(clientSocket.getOutputStream(),true);
                printWriter.println();
                i++;
                ch++;
                new Join(clientSocket, ch).start();
                Thread.sleep(1000);
                }
                }
                catch(Exception e){}
        }
}        
class Connector extends Thread{
        Socket clientSocket;
        char ch;
        public Connector(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
                }
        public void run(){
                try{
                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                PrintWriter pr = new PrintWriter(clientSocket.getOutputStream(),true);
                pr.println("Hello ! dear connecter ");
                Thread.sleep(1000);
                }
                catch(Exception e){
                        System.out.println(e);
                }
        }
}

/*
class JoinPersonel extends Thread{
        ServerSocket serverSocket = new ServerSocket(add,1212);
        char ch;
        public Join(ServerSocket serverSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
        }
        public void run(){
                        for( ; ; ){
                        try{
                        System.out.println("Hello world");
                        }
                        catch(Exception e){
                        System.out.println("While continue the client "+e);
                        }
                        }
        }
}
*/
class Join extends Thread{
        Socket clientSocket;
        char ch;
        public Join(Socket clientSocket, char ch){
                this.clientSocket = clientSocket;
                this.ch = ch;
        }
        public void run(){
                for( ; ; ){
                        try{
                        BufferedReader in1 = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                        System.out.println(in1.readLine());
        
                        System.out.println("Enter messsage for client......");
                        BufferedReader br1 = new BufferedReader(new InputStreamReader(System.in));
                        String str1 = br1.readLine();
        
                        PrintWriter pr1 = new PrintWriter(clientSocket.getOutputStream(),true);
                        pr1.println(str1);
                        Thread.sleep(1000);
                        }
                        catch(Exception e){}
                }
        }
}
class Handler{
        public static void main(String args[]){
                Socket s = null;
                Ser1 se = new Ser1();
        }
}

This application for Local Area Networking
Thanks a lots.
kaival
(baroda)
(edited by Cindy to format code)

[This message has been edited by Cindy Glass (edited August 08, 2001).]