serverprogram.java

运用socket编程

import java.io.*;
import java.net.*;
public class serverProgram
{
	public static final int serverPort=9999;
    public static void main(String args[])	
    { 
        serverProgram ser=new serverProgram();
        ser.start();
    }
    void  start()
    {
       try
       {
       	   ServerSocket s=new ServerSocket(serverPort);
       	   System.out.println("start:"+s);
       	   Socket incoming=s.accept();
       	   System.out.println("data has connected:"+incoming);
       	   BufferedReader in=new BufferedReader(new InputStreamReader(incoming.getInputStream()));
       	   PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter((incoming.getOutputStream()))),true);
           int i=0;
           String temp[]=new String[4];
           while(true)
           {	
	          String line=in.readLine();
	           if(line==null)   
	              break;
	            else
	            {
	                if(line.equals("quit"))	
	                   {
	                        System.out.println("quit!");
	                    	break;
	                    }
	                 else
	                 {
	                        temp[i++]=line;
	                         System.out.println("cline says:"+temp[i-1]);
	                        out.println(temp[i-1]);
	                        if(i>=3)
	                         {
	                             if(temp[0].equals("+"))
							     {
							         System.out.println(new Count().add(temp));
	                                 out.println(new Count().add(temp));   
							     }
							     else if(temp[0].equals("-"))
							     {
							         System.out.println(new Count().sub(temp));
	                                 out.println(new Count().sub(temp));  
	                             }
							     else if(temp[0].equals("/"))
							     {
							         System.out.println(new Count().div(temp));
	                                 out.println(new Count().div(temp));  
	                             }
							     else if (temp[0].equals("*"))
							     {
							         System.out.println(new Count().mul(temp));
	                                 out.println(new Count().mul(temp));  
	                             }
							     else 
							         out.println("program is error!");
	                         }
	                 }
	           
	           }
	      }
         incoming.close();
       } 
       catch(IOException e)
       {
       	  System.out.println("outPrint error"+e.getMessage());
       }	
    }
    
}
class Count
{
   double add(String a[])
       {
          double aa,bb,sum;
           sum=0;
           aa=Double.valueOf(a[1])	;
           bb=Double.valueOf(a[2]);
           sum=aa+bb;
           return sum;
       }
     double sub(String a[])
       {
          double aa,bb,sum;
           sum=0;
           aa=Double.valueOf(a[1])	;
           bb=Double.valueOf(a[2]);
           sum=aa-bb;
           return sum;
       }
     double div(String a[])
       {
          double aa,bb,sum;
           sum=0;
           aa=Double.valueOf(a[1])	;
           bb=Double.valueOf(a[2]);
           sum=aa/bb;
           return sum;
       }
  double mul(String a[])
       {
          double aa,bb,sum;
           sum=0;
           aa=Double.valueOf(a[1])	;
           bb=Double.valueOf(a[2]);
           sum=aa*bb;
           return sum;
       }
}