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();
}
}
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