package com;
import java.net.*;
import java.io.*;



public class EchoServer {
	 private int port=8991;
	    private ServerSocket serverSocket;
	    
	    public EchoServer() throws IOException{
	        serverSocket=new ServerSocket(port);
	        System.out.println("服务器启动");
	        }
	    public String echo(String msg){
	        return "echo:"+msg;
	    }
	    public PrintWriter getWriter(Socket socket)throws IOException{
	        OutputStream socketOut=socket.getOutputStream();
	        return new PrintWriter(socketOut,true);
	    }
	    public BufferedReader getReader(Socket socket)throws IOException{
	        InputStream socketIn=socket.getInputStream();
	        return new BufferedReader(new InputStreamReader(socketIn));
	    }
	    public void service(){
			   String msg = "";
			   DataInputStream in = null;
			   String str_msg[] = null;
		     try{ 	  
		        /*
		         * 多线程处理. 每n_count条启用一个线程
		         */   
		    	 
		    	
		    	  Socket socket=null;
		    	  boolean flag = true;
		          try{
		        	  while(flag)
		        	  {
			              socket=serverSocket.accept();//等待客户端连接
			              System.out.println("接受新的联络:"
			                                      +socket.getInetAddress()+":"
			                                      +socket.getPort());
			               in  = new DataInputStream(socket.getInputStream());
			               //在默认的vm arguments下，byte数组的最大长度是61858764，将近60M。
			               byte b[] = new byte[40960];
			               while(in.read(b)!=-1)
		                  {	
				              msg = new String (b,"GBK");
				              msg = msg.toString().trim();
			                  System.out.println("接收数据....."+msg);
			                  str_msg = msg.split(";");
			                  for(int i=0;i<str_msg.length;i++)
			                  {
			                	  System.out.println("拆分后的数据....."+str_msg[i]);
			                  }
		                  }
		                 
		              }
		          }catch(IOException e){e.printStackTrace();
		          }finally{
		              try{
		                  if(socket!=null)
		                  {
		                      socket.close();
		                  }
		                  if(in!=null)
		                  {
		                	  in.close();
		                  }
		                  
		                  
		                     
		              }catch(IOException e){e.printStackTrace();
		              }
		          }
		      
		     }
		     catch(Exception ex){        	 
		         ex.printStackTrace();
		         
		     }
		}
	 

	    public static void main(String[] args) throws IOException {
	        // TODO Auto-generated method stub
	        new EchoServer().service();
	    }
}