server.java

客户服务机模式会话程序

package test;
import java.io.*;
import java.net.*;
public class Server extends Thread{
	private Socket connectToClient;  //定义套接字对象
	private InputStream socketIn;  //从套接字中读取数据
	private OutputStream socketOut;   //向套接字中输出数据
	//初始化并启动线程
	public Server(Socket socket)throws IOException{
		connectToClient=socket;
		socketIn=socket.getInputStream();
		socketOut=socket.getOutputStream();
		start();
	}
	private PrintWriter getWriter()throws IOException{
	//	 socketOut=socket.getOutputStream();
		 return new PrintWriter(socketOut,true);
	}
	private BufferedReader getReader()throws IOException{
	//	socketIn=socket.getInputStream();
		return new BufferedReader(new InputStreamReader(socketIn));
	}
	public void run(){
		try{
			String msg=null;
			String str=null;
			boolean exit=false;
			BufferedReader stdin =new BufferedReader(new InputStreamReader(System.in));
			BufferedReader br=getReader();
			PrintWriter pw=getWriter();			
			while(!exit)
			{
				do
				{
					msg=br.readLine();
					System.out.println("Received Data:"+msg);
					if(msg.equals("end"))
					{
						pw.write("end");
						exit=true;
						break;
					}
				}while(!msg.equals("")&&msg!=null);
				if(exit)
					break;
				do{
					System.out.print("Forward Data:");
					str=stdin.readLine();
					pw.println(str);
					pw.flush();
					if(str.equals("end")){
						exit=true;
						break;
					}
				}while(!str.equals("")&&str!=null);
			}
			connectToClient.close();
			socketIn.close();
			socketOut.close();
		}catch(IOException e){
			e.printStackTrace();
		}finally{
			try{
				connectToClient.close();
				socketIn.close();
				socketOut.close();	
			}catch(IOException e){
				e.printStackTrace();
			}
		}
	}
}