[Java知识库] Socket客户端服务端收发对象

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> Socket客户端服务端收发对象 -> 正文阅读

[Java知识库]Socket客户端服务端收发对象

对象类代码

import lombok.Data;
import lombok.experimental.Accessors;

import java.io.Serializable;
@Data
@Accessors(chain = true)
public class Userinfo implements Serializable {
    private long id;
    private String username;
    private String password;

    public Userinfo() {
    }

    public Userinfo(long id, String username, String password) {
        this.id = id;
        this.username = username;
        this.password = password;
    }
}

服务端代码

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        ServerSocket serverSocket = new ServerSocket(5678);
        Socket socket = serverSocket.accept();
        InputStream inputStream = socket.getInputStream();
        OutputStream outputStream = socket.getOutputStream();
        ObjectInputStream objectInputStream = new ObjectInputStream(inputStream);
        ObjectOutputStream objectOutputStream = new ObjectOutputStream(outputStream);
        for (int i = 0; i < 5; i++) {
            Userinfo userinfo = (Userinfo) objectInputStream.readObject();
            System.out.println("在服务端打印" + (i + 1) + ":" + userinfo.getId() + " " + userinfo.getUsername() + " " + userinfo.getPassword());
            Userinfo userinfo1 = new Userinfo();
            userinfo1.setId(i + 1).setUsername("serverUsername" + (i + 1)).setPassword("serverPassword" + (i + 1));
            objectOutputStream.writeObject(userinfo1);
        }
        objectOutputStream.close();
        objectInputStream.close();
        outputStream.close();
        inputStream.close();
        socket.close();
        serverSocket.close();
    }
}

客户端代码

import java.io.*;
import java.net.Socket;

public class Client {
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        Socket socket = new Socket("localhost", 5678);
        InputStream inputStream = socket.getInputStream();
        OutputStream outputStream = socket.getOutputStream();
        ObjectOutputStream objectOutputStream = new ObjectOutputStream(outputStream);
        ObjectInputStream objectInputStream = new ObjectInputStream(inputStream);
        for (int i = 0; i < 5; i++) {
            Userinfo userinfo1 = new Userinfo();
            userinfo1.setId(i + 1).setUsername("clientUsername" + (i + 1)).setPassword("clientPassword" + (i + 1));
            objectOutputStream.writeObject(userinfo1);
            Userinfo userinfo = (Userinfo) objectInputStream.readObject();
            System.out.println("在客户端打印" + (i + 1) + ":" + userinfo.getId() + " " + userinfo.getUsername() + " " + userinfo.getPassword());
        }
        objectOutputStream.close();
        objectInputStream.close();
        outputStream.close();
        inputStream.close();
        socket.close();
    }
}