tcpserverd.java

培训的时候的代码

package day15;
import java.io.*;
import java.net.*;
import java.util.*;
public class TCPServerD {

	
	public static void main(String[] args) {
		
			ServerSocket ss=null;
			Socket s=null;
			HashSet hs=new HashSet();
//			BufferedReader br=null;
//			PrintStream ps=null;
			try {
				ss=new ServerSocket(8888);
				while(true){
					s=ss.accept();
					hs.add(s);
					new ServerThreadA(s).start();
//					br=new BufferedReader(new InputStreamReader(s.getInputStream()));
//					ps=new PrintStream(s.getOutputStream());
//					while(true){
//					String str=br.readLine();
//					if(str.equals("quit")){
//						System.out.println(s.getInetAddress()+"已经退出");
//						break;
//					}
//					System.out.println(s.getInetAddress()+":");
//					str=str.toUpperCase();
//					
//					ps.println(str);
//					ps.flush();
//					}
				}
					
			} catch (IOException e) {
				
				e.printStackTrace();
			}finally{
//				if(ps!=null)ps.close();
//				if(br!=null)
//					try {
//						br.close();
//					} catch (IOException e1) {
//						
//						e1.printStackTrace();
//					}
				if(s!=null)
					try {
						s.close();
					} catch (IOException e) {
						
						e.printStackTrace();
					}
				if(ss!=null){
					try {
						ss.close();
					} catch (IOException e) {
						
						e.printStackTrace();
					}
				}
			}

		}
		
		
		

	}



	class ServerThreadB extends Thread{
		BufferedReader br=null;
		PrintStream ps=null;
		Socket s;
		HashSet hs;
		public ServerThreadB(Socket s,HashSet hs){
			this.s=s;
			this.hs=hs;
			try {
				br=new BufferedReader(new InputStreamReader(s.getInputStream()));
				ps=new PrintStream(s.getOutputStream());
			} catch (IOException e) {
				
				e.printStackTrace();
			}
		}
		public void run(){
			while(true){
				
				try {
				String	str = br.readLine();
				
				if(str.equals("quit")){
					System.out.println(s.getInetAddress()+"已经退出");
					hs.remove(s);
					s.close();
					break;
				}
				System.out.println(s.getInetAddress()+":"+str);
				for(Object obj:hs){
					Socket socket=(Socket)obj;
					PrintStream ps=new PrintStream(socket.getOutputStream());
					ps.println(s.getInetAddress()+":"+str);
					ps.flush();
				}
				
				
//				str=str.toUpperCase();
				
//				ps.println(str);
//				ps.flush();
	} catch (IOException e) {
					
					e.printStackTrace();
				}
				}
		
		}
	}