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

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傳送範例”

  1. 您好!

    当我在不同的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. java.lang.ClassNotFoundException是指你的class讀取不到
      請問是否可以提供您的目錄結構呢?
      Datapackage1理論上應該要放在./com/mlh月山錄裡的

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

    1. 這個錯誤是說在你package com.clinet裡的DataTest並不存在
      在幾個專案裡應該沒什麼差別

      1. @yku,
        感謝回復
        但是我再com.client下確實有DataTest.java這個檔案
        真是奇怪 我是直接在com.client那右鍵新增出個Java檔來當作DataTest
        之後還需要什麼動作嗎? Clent跟DataTest確實是放在同一個package裡

        1. 還是您把二個專案打包給我看一下嘛?
          直接回覆mail 就可以寄給我了

        2. 你犯了一個很容易犯的錯
          你在Clinet 傳的object是com.client.DataTest
          而接收的Server是用com.server.DataTest
          是不一樣的Object喔
          請把Server端的package改成package com.client;

  3. 您好,我的情況是,

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

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

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

    1. @Frizan,
      你就讓DataTest在二邊都相同應該就可以了
      ps.因為vm不同,所以不是很確定可不可以
      不過在不同環境下建意你用json或文字格式當傳送介值會比較好

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

    1. 您好
      我不太懂您的意思
      server A要能傳送給clinet B ,那你可以想成那一個clinet其實是server B,所以 clinet A每一段時間就連線server B一次

      1. 謝謝您的回覆
        我要做的是Server一段時間會產生一批資料,將這批資料包成物件分別傳送到多個Client,目前執行狀況是第一輪能夠正常發送與接收,但第二輪就無法接收到資料,我於傳送前測試是有資料的,但client接收時,是無法接收到資料的。
        謝謝

        1. 因為連線已經被設定eof掉了,所以等於是中斷了,要重新再連線,你可以考慮clinet定時連線server,check有無需要下載資料

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

發表迴響