package test; 
 
public class DataTest implements java.io.Serializable { 
  private int x = 0 ; 
  public DataTest() 
  { 
 
  } 
  public void setP(int x) 
  { 
    this.x = x; 
  } 
  public int getP() 
  { 
    return x; 
  } 
}

package test; 
 
import java.net.ServerSocket; 
import java.net.Socket; 
 
 
 
public class SendServer extends java.lang.Thread{ 
 
  private boolean OutServer = false; 
  private ServerSocket server ; 
  private final int ServerPort = 8765; 
 
 
  public SendServer() 
  { 
    try 
    { 
      server = new ServerSocket(ServerPort); 
 
    } 
    catch(java.io.IOException e) 
    { 
      System.out.println("Socket啟動有問題 !" ); 
      System.out.println("IOException :" + e.toString()); 
    } 
  } 
 
 
 
 
 
  public void run() 
  { 
    Socket socket ; 
    java.io.ObjectInputStream in ; 
 
    System.out.println("伺服器已啟動 !"  ); 
    while(!OutServer) 
    { 
      socket = null; 
      try 
      { 
        synchronized(server) 
        { 
          socket = server.accept(); 
        } 
        System.out.println("取得連線 : InetAddress = " + 
socket.getInetAddress()  ); 
        socket.setSoTimeout(15000); 
 
 
        in = new 
java.io.ObjectInputStream(socket.getInputStream()); 
 
        DataTest data = (DataTest)in.readObject(); 
        System.out.println("我取得的值:"+data.getP()); 
        in.close(); 
        in = null ; 
        socket.close(); 
 
 
 
      } 
      catch(java.io.IOException e) 
      { 
        System.out.println("Socket連線有問題 !" ); 
        System.out.println("IOException :" + e.toString()); 
      } 
      catch(java.lang.ClassNotFoundException e) 
      { 
        System.out.println("ClassNotFoundException :" + 
e.toString()); 
      } 
    } 
  } 
 
  public static void main(String args[]) 
  { 
    (new SendServer()).start(); 
  } 
 
}

package test; 
 
import java.net.InetSocketAddress; 
import java.net.Socket; 
import java.io.ObjectOutputStream; 
public class SendClient { 
  private String address = "127.0.0.1"; 
  private int port = 8765; 
  public SendClient() 
  { 
    //準備要傳送的資料 
    DataTest data = new DataTest(); 
      data.setP(102928); 
 
    Socket client = new Socket() ; 
        InetSocketAddress isa = new 
InetSocketAddress(this.address,this.port); 
        try 
        { 
          client.connect(isa,10000); 
          ObjectOutputStream out = new 
ObjectOutputStream(client.getOutputStream()); 
          //送出object 
          out.writeObject(data); 
          out.flush(); 
          out.close(); 
          out = null ; 
          data = null ; 
          client.close(); 
          client = null ; 
 
        } 
        catch(java.io.IOException e) 
        { 
          System.out.println("Socket連線有問題 !" ); 
      System.out.println("IOException :" + e.toString()); 
        } 
  } 
 
  public static void main(String args[]) 
  { 
    new SendClient(); 
  } 
}