[Java]Serializable序列化Socket傳送範例

2009-07-242019-04-03 yku Java, 程式

java Socket傳送過程中，可利用ObjectInputStream及ObjectOutputStream傳接送物件當做資料，傳送後的資料可以直接取用，省去需要再讀取xml、文字、json等格式的麻煩。

要利用socket傳送首先需先定義一個Object，而Object必需implements java.io.Serializable介面才可以。Serializable可以參考Serializable序列化

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; 
  } 
}

再來建立一個Server，利用ObjectInputStream的ReadObject()把Object讀進來，再把這個Object做想要的處理。

SendServer.java

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(); 
  } 
  
}

最後建立一個socket Client來傳送Object，利用ObjectOutputStream把Data writeObject()出去。

SendClient.java

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(); 
  } 
}

—–Server端回應—–
伺服器已啟動 !
取得連線 : InetAddress = /127.0.0.1
我取得的值:102928

原始碼下載

延伸：

Java 1.4可用Serializable類別Object列表

17 thoughts to “[Java]Serializable序列化Socket傳送範例”

mlianghua表示:

2010-02-2814:59

您好!

当我在不同的package建立client和Server的时候，Datatest 也分别在各自的package创建，比如Datatest1.java, Datatest2.java,
其中两个文件里面都是一样的。运行时出现
Server 端：
java.lang.ClassNotFoundException: com.mlh.Datapackage1
at java.net.URLClassLoader$1.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClassInternal(Unknown Source)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Unknown Source)
at java.io.ObjectInputStream.resolveClass(Unknown Source)
at java.io.ObjectInputStream.readNonProxyDesc(Unknown Source)
at java.io.ObjectInputStream.readClassDesc(Unknown Source)
at java.io.ObjectInputStream.readOrdinaryObject(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at com.google.facebook.s_new.run(s_new.java:34)
at java.lang.Thread.run(Unknown Source)
Client端：
TCPC: Connecting…
TCP C: Sending…
TCP C: Receiving…
TCP S: Error
java.io.EOFException
at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at com.mlh.mlh_client.main(mlh_client.java:44)

为什么出现这种错误？

回覆
1. yku表示:
  
  2010-03-0117:14
  
  java.lang.ClassNotFoundException是指你的class讀取不到
  請問是否可以提供您的目錄結構呢?
  Datapackage1理論上應該要放在./com/mlh月山錄裡的
  
  回覆
自動引用通知: [Java]簡單的Socket Client Server
peter表示:

2011-07-1318:09

您好
我把Client跟server寫在兩個不同的專案
然後DataTest.java我在Client跟Server兩個專案的地方都有加入
這時候運行Client端時會出現
java.lang.ClassNotFoundException: com.client.DataTest
這個錯誤
另外因為我Client是寫在Android上
所以沒辦法將Client跟Server都寫在同一個專案內
請問我該怎樣才能解決這個問題呢?

回覆
1. yku表示:
  
  2011-07-1320:25
  
  這個錯誤是說在你package com.clinet裡的DataTest並不存在
  在幾個專案裡應該沒什麼差別
  
  回覆
  1. peter表示:
    
    2011-07-1321:52
    
    @yku,
    感謝回復
    但是我再com.client下確實有DataTest.java這個檔案
    真是奇怪我是直接在com.client那右鍵新增出個Java檔來當作DataTest
    之後還需要什麼動作嗎? Clent跟DataTest確實是放在同一個package裡
    
    回覆
    1. yku表示:
      
      2011-07-1322:17
      
      還是您把二個專案打包給我看一下嘛?
      直接回覆mail 就可以寄給我了
      
      回覆
    2. yku表示:
      
      2011-07-1323:17
      
      你犯了一個很容易犯的錯
      你在Clinet 傳的object是com.client.DataTest
      而接收的Server是用com.server.DataTest
      是不一樣的Object喔
      請把Server端的package改成package com.client;
      
      回覆
zjs表示:

2012-08-2122:05

感謝教學，回覆的內容對我很有幫助!

回覆
Frizan表示:

2015-01-1317:11

您好，我的情況是，

Client 和 Server 是分開的兩個 Project (Client 是跑在手機， Server 則是跑在電腦)

所以我的 DataTest 必定是不同的 .Class (但Client 和 Server 的DataTest 內容是相同的)，

請問要怎麼處理這個問題呢?

回覆
1. yku表示:
  
  2015-01-1317:31
  
  @Frizan,
  你就讓DataTest在二邊都相同應該就可以了
  ps.因為vm不同，所以不是很確定可不可以
  不過在不同環境下建意你用json或文字格式當傳送介值會比較好
  
  回覆
自動引用通知: [Java]Serializable序列化Socket傳送範例-檔案下載 | 聰明的生活2
菜比八表示:

2015-06-0810:32

版大你好：
如果我需要Server每隔幾秒傳送資料給多個client端，是否不要關閉Server與Client間的連接會比較好，因為一方面是資料的產生時間不同，只有Server知道資料什麼時候產生完畢，所以不太可能利用Client定時連上Server抓取資料，我目前做法是：Server等待Client連線後，將此Socket建立的ObjectOutputStream加入一個ArrayList裡(藉此存放多個Client)，當資料產生完畢後，呼叫一個方法利用foreach去輪詢每一個output物件執行輸出但第一輪Client可以接到資料，第二輪就收不到了，以版大的範例要如何修改呢? 希望版大可以給我一些建議或方向。
謝謝。

回覆
1. yku表示:
  
  2015-06-0814:05
  
  您好
  我不太懂您的意思
  server A要能傳送給clinet B ,那你可以想成那一個clinet其實是server B,所以 clinet A每一段時間就連線server B一次
  
  回覆
  1. 菜比八表示:
    
    2015-06-0814:22
    
    謝謝您的回覆
    我要做的是Server一段時間會產生一批資料，將這批資料包成物件分別傳送到多個Client，目前執行狀況是第一輪能夠正常發送與接收，但第二輪就無法接收到資料，我於傳送前測試是有資料的，但client接收時，是無法接收到資料的。
    謝謝
    
    回覆
    1. yku表示:
      
      2015-06-0814:24
      
      因為連線已經被設定eof掉了，所以等於是中斷了，要重新再連線，你可以考慮clinet定時連線server，check有無需要下載資料
      
      回覆
菜比八表示:

2015-06-0814:41

謝謝您的回覆
本來想說，保持連線狀態，產生資料後就可以直接傳送的，
我再調整看看。
謝謝。

回覆

17 thoughts to “[Java]Serializable序列化Socket傳送範例”

發表迴響取消回覆