server.java

实例精华

import java.io.*;
import java.net.*;

public class Server extends Thread
{
	ServerSocket server;
	
	public Server()
	{
		
		try {
			
			server = new ServerSocket(4000);
			
	    }
	    catch (Exception ex) {
	    	
	    	
	    	System.out.println("can't connect");
	    }
	    
	    System.out.println("服务器开启");
	    
	    this.start();
		
	}
	
	public void run()
	{
		
		try {
			
			while(true)
			{
				
				Socket so = server.accept();
				Service ss = new Service(so);
				
			}
			
			
			
	    }
	    catch (Exception ex) {
	    	
	    	
	    	ex.printStackTrace();
	    }
		
		
	}
	
	class Service extends Thread
	{
		BufferedReader br;
		BufferedReader brr;
		PrintStream ps;
		Socket so;
		String data;
		String keys;
		public Service(Socket so)
		{
			
			this.so=so;
			
			try {
				
				br = new BufferedReader(new InputStreamReader(so.getInputStream()));
				brr = new BufferedReader(new InputStreamReader(System.in));
				ps = new PrintStream(so.getOutputStream());
				
		    }
		    catch (Exception ex) {
		    	
		    	
		    	ex.printStackTrace();
		    }
		    
		    
		    this.start();
			
		}
		
		public void run()
		{
			
			try {
				
				while(true)
				{
					
					data = br.readLine();
					if(data==null)  break;
					System.out.println("Client say:"+data);
					keys = brr.readLine();
					ps.println(keys);
					
				}
				
				
				
		    }
		    catch (Exception ex) {
		    	
		    	
		    	System.out.println("下线了");
		    }
			
			
			try {
				
				so.close();
				
				
		    }
		    catch (Exception ex) {
		    	
		    	
		    	ex.printStackTrace();
		    }
			
			
		}
		
		
		
	}
	
	
	public static void main(String[] args)
	{
		
		  new Server();
		
	}
	
	
	
}