import java.io.*;
import java.net.*;
public class chatClient {
public static void main (String[] str)
{
String serverName="";
if (str.length>=1) { serverName=str[0];}
else
{
System.out.println("You must provide a server Name you want to connect to,");
System.out.println("And run your program by input indo
s Prompt Like this:");
System.out.println("java chatClient serverName");
System.exit(0);
}
Socket cltSoc;
ObjectOutputStream objOut = null;
ObjectInputStream objIn = null;
try
{
InetAddress address = InetAddress.getByName(serverName);
cltSoc = new Socket(address,6666);
objOut= new ObjectOutputStream(cltSoc.getOutputStream());
objIn = new ObjectInputStream(cltSoc.getInputStream());
System.out.println("Connected to the server successfully...");
System.out.println("If you want to exit this program, type 'QUIT' !");
}catch (Exception e) { System.exit(0);}
getMsg get = new getMsg(objIn);
get.start();
sendMsg send = new sendMsg(objOut);
send.
start();
}
}
///getMsg
class getMsg extends Thread
{
ObjectInputStream objIn;
public getMsg(ObjectInputStream in)
{ objIn = in;}
public void run(){
String strMsg="";
while(true)
{
try{
strMsg=(String)objIn.readObject();
System.out.println("The server said :"+strMsg);
if (strMsg.equalsIgnoreCase("quit")) System.exit(0);
}catch(Exception e) {}
}
}
}
///sendMsg
class sendMsg extends Thread
{
ObjectOutputStream objOut;
public sendMsg(ObjectOutputStream out)
{ objOut=out;}
public void run()
{
String strMsg="";
while(true)
{
try
{
strMsg=(new BufferedReader(new InputStreamReader(System.in))).readLine();
objOut.writeObject(strMsg);
if (strMsg.equalsIgnoreCase("quit")) System.exit(0);
}catch(Exception e){}
}
}
}