Friday, 14 June 2013

Chatting Program in Java Through Socket

CHAT SERVER PROGRAM

import java.net.*;
import java.io.*;
class ChatServer extends Thread
{
ServerSocket Server;
Socket soc;

ObjectInputStream ois;
ObjectOutputStream oos;

public ChatServer()
{
try
{
ServerSocket Server=new ServerSocket(2001);
}
catch(Exception e)
{}
System.out.println("server standered");
this.start();
}
// listening activity
public void run()
{
try {
soc=Server.accept();
process(soc);
}

catch(Exception e)
{
System.out.println(e);

}

}


public void process(Socket ss)
{
try
{
while(true)
{
ois=new ObjectInputStream(ss.getInputStream());
String st=(String)ois.readObject();
System.out.println("client reply"+st);
InputStreamReader ir=new InputStreamReader(System.in);
BufferedReader br=new BufferedReader (ir);

String data=br.readLine();

oos=new ObjectOutputStream(ss.getOutputStream());
oos.writeObject(data);
}}
catch(Exception e)
{}
}
public static void main(String [] args)
{
new ChatServer();
}
}

CHAT CLIENT PROGRAM

import java.net.*;
import java.io.*;
class ChatClient extends Thread
{
ServerSocket Server;
Socket soc;

ObjectInputStream ois;
ObjectOutputStream oos;

public ChatClient()
{
try
{
soc=new Socket("200.100.1.154",2001);
}
catch(Exception e)
{}
System.out.println("client  standered");
this.start();
}
// listening activity
public void run()
{
try {
soc=Server.accept();
process(soc);
}

catch(Exception e)
{
System.out.println(e);

}

}


public void process(Socket ss)
{
try
{
while(true)
{

InputStreamReader ir=new InputStreamReader(System.in);
BufferedReader br=new BufferedReader (ir);

String data=br.readLine();

oos=new ObjectOutputStream(ss.getOutputStream());
oos.writeObject(data);




ois=new ObjectInputStream(ss.getInputStream());
String st=(String)ois.readObject();
System.out.println("server reply"+st);

}}
catch(Exception e)
{}
}
public static void main(String [] args)
{
new ChatClient();
}
}





No comments:

Post a Comment