chatsvr.java

java,关于tcp协议的网络连接.[采用c/s模式]

import java.io.*;
import java.net.*;

public class chatSvr
{
     public static void main(String[] str)
     {
         ServerSocket soc;
         Socket svrSoc;
         ObjectOutputStream objOut=null;
         ObjectInputStream objIn=null;
             try{
                 System.out.println("Waiting for client's connecting...");
                 soc=new ServerSocket(6666);
                 svrSoc=soc.accept();
                 System.out.println("The client connected, you can Exit this program by type 'QUIT'");
                
                 objOut=new ObjectOutputStream(svrSoc.getOutputStream());
                 objIn=new ObjectInputStream(svrSoc.getInputStream());
             }catch(Exception e){System.exit(0);}

        
         sendMsgOut send=new sendMsgOut(objOut);
         send.start();
         getMsgFromClient get=new getMsgFromClient(objIn);
         get.start();
     }
}
class sendMsgOut extends Thread
{
     ObjectOutputStream objOut=null;
     public sendMsgOut(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.equals("QUIT"))System.exit(0);
             }catch(Exception e){}
             //System.out.println(strMsg);
         }
     }
    
}
class getMsgFromClient extends Thread
{
     ObjectInputStream objIn;
     public getMsgFromClient(ObjectInputStream in)
     {
         objIn=in;
     }
     public void run()
     {
         String strMsg="";
         while(true)
         {
             try{
             strMsg=(String)objIn.readObject();
             System.out.println("The client said:"+strMsg);
             if (strMsg.equals("QUIT"))System.exit(0);
             }catch(Exception e){}
         }
     }
}