client.java

客户服务机模式会话程序

package test;
import java.io.*;
import java.net.*;
public class Client extends Thread{
	private Socket connectToClient;  //定义套接字对象
	private InputStream socketIn;  //从套接字中读取数据
	private OutputStream socketOut;   //向套接字中输出数据
	//初始化并启动线程
	public Client(InetAddress addr,int por,String clientName)throws IOException{
		super(clientName);
		connectToClient=new Socket(addr,por);
		socketIn=connectToClient.getInputStream();
		socketOut=connectToClient.getOutputStream();
		start();
	}
	public void run(){
		try{
			System.out.println(getName());
			System.out.println("输入end，则停止连接。");
			String msg=null;
			String str=null;
			boolean exit=false;
			BufferedReader stdin =new BufferedReader(new InputStreamReader(System.in));
			PrintWriter pw=new PrintWriter(socketOut,true);
			BufferedReader br=new BufferedReader(new InputStreamReader(socketIn));
			while(!exit){
				do{
					System.out.print("Forward Data:");
					str=stdin.readLine();
					pw.println(str);
					pw.flush();
					if(str.equals("end")){
						pw.write("end");
						exit=true;
						break;
					}
				}while(!str.equals("")&&str!=null);
				
				if(exit)
					break;
				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);				
			}
			connectToClient.close();
			socketIn.close();
			socketOut.close();
		}catch(IOException e){
			e.printStackTrace();
		}
	}
}