socket通信联系程序

/**  2005.10.10
*    for study JAVA TCP
*
*/

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

public class TCPReceive
{
   
   public static void main(String[] args)
   {
      System.out.println("Listenering...");
      //
      ServerSocket ss;
      Socket client;
      try
      {
   	 ss = new ServerSocket(20000);  	        	   	  	 
   	 // begain to accept
   	 for(;;)
   	 {
   	    client = ss.accept();
   	    //得到输出流
   	    OutputStream out = client.getOutputStream();
   	    // 得到输入流
   	    InputStream in = client.getInputStream(); 
            byte[] in_buf = new byte[100]; 
            byte[] out_buf = {0X4C,0X58,0X46,
                              0X01,0,0,0,0,0,0X03,0,0,0,0,0,0X01,
                              0X46,0X4A,0X52,
                              0X0D,0X04,
                              0X01,0X02,0X06,0X31,0X30,0X30,0X30,0X32,0X35,
                              0X04,0X02,0X03,0X31,0X33,0X35,
                              0X0C,0X01,0X01,
                              0X05,0X01,0X01
                              };
   	    for(;;)
   	    {	            	         	        	        	      
   	      while(in.read(in_buf) == 0)
   	           try
   	           {
   	           	Thread.sleep(500);
   	           }catch(Exception ec){}
   	           
   	      System.out.println(new String(in_buf));
   	      if(in_buf[0] == 0x00)
   	            break;
  	      try
   	      {
   	          Thread.sleep(1000);
   	      }catch(Exception ec){} 
   	        	              	      
   	      out.write(out_buf, 0, 42); 
   	      for(int i = 0; i < 100; i++)
   	          in_buf[i] = 0x00;
   	    }
   	        
   	    in.close();
   	    out.close();
   	    client.close();
   	  } 
   	}
        catch(IOException e)
   	{
   	    System.err.println(e);
   	} 	 	
   	
   }//end of main()
     	
} //end of class TCPReceive 	


   	

 

/**  2005.10.10
*    for study JAVA TCP
*
*/

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

public class TCPSend
{
   
   public static void main(String[] args)
   {
       // 
       Socket sender;          
       try
       {
       	 SocketAddress  addr = new InetSocketAddress("10.10.6.235", 20000);
       	 do
       	 {
       	    sender = new Socket();
       	    try
       	    {
       	    	sender.connect(addr,5000);
       	    }      	  
       	    catch(IOException ioe){}
       	    System.out.println("connecting...");
       	 }while(sender.isBound() == false);
       	 
       	 // get outputstream
       	 OutputStream out = sender.getOutputStream();
       	 //get inputstream 
    	 InputStream in = sender.getInputStream();
         byte[] in_buf = new byte[10];
       	 for(;;)
       	 {
            if(sending(out) == 0)
                break;      	                         
//           System.out.println("sending over!");           	
         }//end of for
         try
         {
             Thread.sleep(1000);
         }
         catch(Exception ec){}
          
          in.close();                        	  
          out.close();
          sender.close();          
       }
       catch(IOException e)
       {
       	  System.err.println(e);
//        System.out.println("here");
       }
      
//       catch(UnknownHostException e)
//       {
//       	  System.err.println("");
//       }
       //总是报错，找不到主机       

   }
   
   public static int sending(OutputStream out)
   {
      byte[] data = new byte[100];
      
      System.out.println("INPUT:");
      try
      {
      	System.in.read(data);
        if(data[0] == 0x00)
            return(0);
//      String data1 = new String(data);
        try
        {
      //suggest use write(byte[], int, int) instand of write(byte[]), for more information
      //lookup JAVA DOC
           out.write(data, 0, data.length);
        }
        catch(IOException ioe){}
      }
      catch(Exception e){}        

      return(1);
      
   }//end of sending() 

}