chatsvr.java

来自「本程序是用JAVA写的」· Java 代码 · 共 85 行

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){}
				}
			}
	
	
	
	
	
	
	}