serversocker.java

java课后题的详细答案

//package ServerSocker.Socker;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class serverSocker implements Runnable {

	ServerSocket server = null ;
	Socket clientSocket ;
	boolean flag = true ; //标记是否结束
	Thread c ;
	BufferedReader sin ;
	DataOutputStream sout ;
	public static void main(String[] args){
		new serverSocker().serverStart();
	}
	public void serverStart(){
		try {
			server = new ServerSocket(45678);
			System.out.println("端口号:" + server.getLocalPort());
			while(flag){
				clientSocket = server.accept();
				System.out.println("已经建立连接");
				InputStream is = clientSocket.getInputStream();
				sin = new BufferedReader(new InputStreamReader(is));
				OutputStream os = clientSocket.getOutputStream();
				sout = new DataOutputStream(os);
				c = new Thread(this);
				c.start();
				String aline ;
				while((aline = sin.readLine()) != null){
					System.out.println("客户端对服务端说：" + aline);
					if(aline.equals("byte")){
						flag = false ;
						c.interrupt();
						break ;
					}
				}
				sout.close();
				os.close();
				sin.close();
				is.close();
				clientSocket.close();
				System.exit(0);			
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			System.out.print(e.getMessage());
		}
	}
	public void run() {
		// TODO Auto-generated method stub
		while(true){
			try{
			int ch ;
			while((ch = System.in.read())!= -1){
				sout.write((byte)ch);
				if(ch == '\n'){
					sout.flush();
				}
				}
			}catch(Exception e){
				System.out.print(e.getMessage());
			}
		}
	}
	public void finalize(){
		try{
			server.close();
		}catch(IOException e){
			System.out.print(e.getMessage());
		}
	}

}