Java Socket实战之一：单线程通信(Java Socket编程实战（一）：单线程通信详解)

原创

ithorizon 7个月前 (10-19) 阅读数 10 #后端开发

Java Socket编程实战（一）：单线程通信详解

一、引言

在计算机网络编程中，Socket 是一种常用的通信行为。Java 提供了充足的网络编程API，让开发者能够方便地实现网络通信。本文将详细介绍怎样使用 Java Socket 实现单线程通信，帮助读者掌握 Java Socket 编程的基本方法。

二、Socket 简介

Socket 是一种抽象层，它允许应用程序发送和接收数据，通过网络的连接。在网络通信过程中，Socket 被用作端点。在 Java 中，Socket 编程首要涉及到以下几个类：

Socket：用于实现客户端的通信。

ServerSocket：用于实现服务端的通信。

InputStream：用于读取数据。

OutputStream：用于发送数据。

三、单线程通信原理

单线程通信是指客户端与服务器端通过一个线程进行数据交换。客户端发送请求，服务器端接收请求并处理，然后返回响应。以下是单线程通信的基本流程：

客户端创建 Socket，连接到服务器。

服务器端创建 ServerSocket，等待客户端连接。

客户端发送请求。

服务器端接收请求，处理请求。

服务器端发送响应。

客户端接收响应，断开连接。

四、实现单线程通信

下面将通过一个易懂的示例来演示怎样使用 Java Socket 实现单线程通信。

4.1 服务器端代码


public class Server {
    public static void main(String[] args) {
        try {
            // 创建 ServerSocket，监听 12345 端口
            ServerSocket serverSocket = new ServerSocket(12345);
            System.out.println("服务器端已启动，等待客户端连接...");
            // 获取客户端连接
            Socket socket = serverSocket.accept();
            System.out.println("客户端已连接：" + socket.getInetAddress().getHostAddress());
            // 获取输入流
            InputStream inputStream = socket.getInputStream();
            // 获取输出流
            OutputStream outputStream = socket.getOutputStream();
            // 读取客户端发送的数据
            byte[] buffer = new byte[1024];
            int len = inputStream.read(buffer);
            String clientData = new String(buffer, 0, len);
            System.out.println("客户端发送的数据：" + clientData);
            // 发送响应数据
            String responseData = "服务器端响应：" + clientData;
            outputStream.write(responseData.getBytes());
            // 关闭资源
            inputStream.close();
            outputStream.close();
            socket.close();
            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

4.2 客户端代码


public class Client {
    public static void main(String[] args) {
        try {
            // 创建 Socket，连接到服务器
            Socket socket = new Socket("localhost", 12345);
            System.out.println("客户端已连接到服务器端...");
            // 获取输入流
            InputStream inputStream = socket.getInputStream();
            // 获取输出流
            OutputStream outputStream = socket.getOutputStream();
            // 发送请求数据
            String requestData = "Hello, Server!";
            outputStream.write(requestData.getBytes());
            // 读取服务器端响应数据
            byte[] buffer = new byte[1024];
            int len = inputStream.read(buffer);
            String responseData = new String(buffer, 0, len);
            System.out.println("服务器端响应：" + responseData);
            // 关闭资源
            inputStream.close();
            outputStream.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}