Socket与Object流

java在Client和Servet端进行自定义对象传输时注意要点

1. 必须在客户端和服务端各自创建一个被序列化的相同的类，类中的字段也必须相同，否则有些字段会访问不到
2. 如果被序列化的类的成员变量中包含其他了类的对象，则该类也需要被序列化，否则可能会出现StreamCorropedException异常
3. 每一个Object流对象只能创建一个，切记不能在while循环里面创建类似new ObjectOutputStream(Socket.getOutputStream())的语句，否则会抛出异常。Object流是配套使用的，即如果你在服务端创建了一个输出流，那么你在客户端必须创建一个输入流与之对应起来,这是因为Object流在使用输出流时，会先写入一个header，在使用输入流读取时会先读取header，如果不一致，则会出现异常 invade type code：...。

4. 服务端代码：
   package webTest;
   
   import java.io.ObjectInputStream;
   import java.io.ObjectOutputStream;
   import java.net.ServerSocket;
   import java.net.Socket;
   
   import Public.Message;
   
   public class Server {
   
       public static void main(String[] args) throws Exception {
   
           ServerSocket ssocket  = new ServerSocket(9999);
           
           Socket socket = ssocket.accept();
           while(true){
               ObjectInputStream objIn = new ObjectInputStream(socket.getInputStream());//这个流对象创建的顺序应该和客户端的相反，否则会阻塞，因为ObjectInputStream构造函数是阻塞的。像该代码这样就会阻塞
               ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream());
               
               System.out.println("objOut+"+objOut);
               Message message = new Message();
               message.setAge(18);
               
               objOut.writeObject(message);
               Message message1 = new Message();
               message1 = (Message) objIn.readObject();
               System.out.println("message+" + message1.getAge());
   
   
           }
           
           
           
       }
   
   }
   
   客户端代码：
   package TCP;
   
   
   
   import java.io.ObjectInputStream;
   import java.io.ObjectOutputStream;
   import java.net.Socket;
   
   import Public.Message;
   
   
   
   
   public class client {
   
       public static void main(String[] args  ) throws Exception {
           Socket socket = new Socket("127.0.0.1",9999);
   
           while(true){
               ObjectInputStream objIn= new ObjectInputStream(socket.getInputStream());
               ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream());
               
               Message message1 = new Message();
               message1.setAge(181);
               objOut.writeObject(message1);
               
               System.out.println("objIn+"+objIn);
               Message message = new Message();
               message = (Message) objIn.readObject();
               System.out.println("message+" + message.getAge());
           }
       }
   }
   
   

5. 必须把这两个类分别放在客户端与服务端具有相同包名的包下面，否则出现ClassNotFoundException异常或者ClassCastException异常
6. 如图

1. 1. 

  

 

 

 

 

 

 

 

 

 

客户端代码：

package TCP;

 

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

import Public.Message;

 


public class client {

public static void main(String[] args ) throws Exception {
Socket socket = new Socket("127.0.0.1",9999);

ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream());

ObjectInputStream objIn = new ObjectInputStream(socket.getInputStream());

//    objOut.writeObject("客户端来消息了");

Message message = new Message();
message.setAge(18);

objOut.writeObject(message);


}

}

　　

服务端代码：

　　

package webTest;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import Public.Message;

public class Server {

public static void main(String[] args) throws Exception {

ServerSocket ssocket = new ServerSocket(9999);

Socket socket = ssocket.accept();

ObjectInputStream objIn = new ObjectInputStream(socket.getInputStream());

ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream());

objOut.writeObject("服务端来消息了");

Message message = new Message();
message = (Message) objIn.readObject();
System.out.println("message+"+message.getAge());


String str = (String)objIn.readObject();

System.out.println("str+"+str);



}

}

消息类：

package Public;

import java.io.Serializable;

public class Message implements Serializable{
/**
* 
*/
private static final long serialVersionUID = 8625279621236358825L;//服务端与客户端必须完全一致

private Postion pos;//该类在服务端与客户端都必须存在且完全一致
private int age;

public int getAge() {
return age;
}

public void setAge(int age) {
this.age = age;
}

}