Java Socket实战之三：传输对象(Java Socket编程实战（三）：对象传输详解)

原创

ithorizon 6个月前 (10-21) 阅读数 22 #后端开发

Java Socket编程实战（三）：对象传输详解

一、概述

在Java Socket编程中，除了基本的文本数据传输，我们还需要学会怎样传输纷乱的对象。本文将详细介绍怎样使用Java Socket进行对象传输，包括对象的序列化和反序列化过程，以及具体的实现方法。

二、序列化和反序列化

在Java中，对象传输涉及到序列化和反序列化。序列化是将对象状态变成可存储或可传输的形式的过程，通常以字节流的形式存储；反序列化则是将字节流还原为对象的过程。

三、实现对象传输的步骤

以下是实现Java Socket对象传输的基本步骤：

3.1 创建一个可序列化的Java类

为了让对象能够在网络中传输，首先需要创建一个可序列化的Java类。这可以通过实现java.io.Serializable接口来实现。


import java.io.Serializable;
public class Person implements Serializable {
    private static final long serialVersionUID = 1L;
    
    private String name;
    private int age;
    
    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }
    
    public String getName() {
        return name;
    }
    
    public int getAge() {
        return age;
    }
}

3.2 创建Socket服务端

在服务端，我们需要创建一个ServerSocket来监听客户端的连接请求，并接收客户端发送的对象。


import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(12345)) {
            System.out.println("Server is listening on port 12345");
            try (Socket socket = serverSocket.accept()) {
                System.out.println("Client connected");
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
                Person person = (Person) ois.readObject();
                System.out.println("Received: " + person.getName() + ", " + person.getAge());
            }
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}

3.3 创建Socket客户端

在客户端，我们需要创建一个Socket连接到服务端，并发送序列化后的对象。


import java.io.*;
import java.net.Socket;
public class Client {
    public static void main(String[] args) {
        try (Socket socket = new Socket("localhost", 12345)) {
            System.out.println("Connected to server");
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            Person person = new Person("Alice", 30);
            oos.writeObject(person);
            System.out.println("Sent: " + person.getName() + ", " + person.getAge());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}