以前寫聊天程序都是用字符串加個標誌就直接發送到服務器,然後轉發了。
現在要求我用對象流直接發送對象,測試了一下,記錄一下。
其實我更傾向用json發送對象的,json說白了也是字符串,等有空了好好研究研究。
主要功能:客戶端給服務器發送個對象,服務器接收到了打印出來。反過來是差不多了,就不寫了。
上面是整體架構。
User類就兩個屬性。
複製代碼代碼如下:
package com.qiantu.bean;
import java.io.Serializable;
public class User implements Serializable {
private static final long serialVersionUID = 1L;
private String name;
private String password;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
服務器端:接收客戶端發送過來的user對象:
複製代碼代碼如下:
package test;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import com.qiantu.bean.User;
public class TestServer {
public void start() {
try {
ServerSocket ss = new ServerSocket(7777);
System.out.println("start to accept...");
Socket socket = ss.accept();
//建立輸入流
ObjectInputStream ois = new ObjectInputStream(
new BufferedInputStream(socket.getInputStream()));
Object obj = ois.readObject();
if (obj != null) {
User user = (User)obj;//把接收到的對象轉化為user
System.out.println("user: " + user.getName());
System.out.println("password: " + user.getPassword());
}
ois.close();
socket.close();
ss.close();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new TestServer().start();
}
}
客戶端:給服務器端發送user對象:
複製代碼代碼如下:
package client;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import com.qiantu.bean.User;
public class TestClient {
public static void main(String[] args) {
new TestClient().start();
}
public void start() {
try {
Socket socket = new Socket("127.0.0.1", 7777);
//建立輸入流
ObjectOutputStream oos = new ObjectOutputStream(socket
.getOutputStream());
User user = new User();
user.setName("梁國俏");
user.setPassword("123456");
//輸入對象, 一定要flush()
oos.writeObject(user);
oos.flush();
oos.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
運行結果:
要注意的地方:
《1》實體類要實現Serializable類,添加標識serialVersionUID。
《2》發送對象之後要flush();
《3》這個比較重要,搞了我半天不知道哪裡出錯,言來是這個。
服務器端和客戶端兩邊的實體類要一模一樣,類名一樣,包名也要一樣。我就是因為包名不一樣搞了很久。 。 。 。