chat application using socket programming
CLIENT.JAVA
import java.io.*;
import java.net.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Calendar;
public class client {
static String msgFromServer="";
static String msgToServer="";
public static void main(String[] args) throws IOException {
int port=5432;
String address="localhost";
Socket myskt=new Socket(address,port);
PrintStream ps=new PrintStream(myskt.getOutputStream());
BufferedReader br=new BufferedReader(new InputStreamReader(myskt.getInputStream()));
BufferedReader buff=new BufferedReader(new InputStreamReader(System.in));
DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
//Thread
new Thread(){
public void run()
{
try {
while(myskt.isConnected())
{
msgToServer=buff.readLine();
if(msgToServer.compareTo("")!=0)
{
ps.println(msgToServer);
}
msgToServer="";
}
} catch (IOException ex) { }
}
}.start();
//Thread2
new Thread()
{
public void run()
{
try {
while(myskt.isConnected())
{
msgFromServer=br.readLine();
if(msgFromServer.compareTo("")!=0)
{
System.out.println("["+dateFormat.format(Calendar.getInstance().getTime())+"] Server says : "+msgFromServer);
}
msgFromServer="";
}
} catch (IOException ex) { }
}
}.start();
}
}
SERVER.JAVA
import java.io.*;
import java.net.*;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Calendar;
public class server{
static String msgFromClient="";
static String msgToClient="";
public static void main(String[] args) throws IOException {
ServerSocket ss=new ServerSocket(5432);
Socket myskt=ss.accept();
PrintStream ps=new PrintStream(myskt.getOutputStream());
BufferedReader br=new BufferedReader(new InputStreamReader(myskt.getInputStream()));
BufferedReader buff=new BufferedReader(new InputStreamReader(System.in));
DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
new Thread()
{
public void run()
{
try {
while(myskt.isConnected())
{
msgFromClient=br.readLine();
if(msgFromClient.compareTo("")!=0)
{
System.out.println("["+dateFormat.format(Calendar.getInstance().getTime())+"] Client says : "+msgFromClient);
}
msgFromClient="";
}
} catch (IOException ex) { }
}
}.start();
//Thread 2
new Thread()
{
public void run()
{
try{
while(myskt.isConnected())
{
msgToClient=buff.readLine();
if(msgToClient.compareTo("")!=0)
{
ps.println(msgToClient);
}
msgToClient="";
}
} catch (IOException ex) { }
}
}.start();
}
}
Comments
Post a Comment