Java实现单线程聊天室：Socket通信基础教程

咖啡半糖

发布时间：2026-10-13 | 4人浏览过

原创

本文基于Java语言，演示如何通过Socket API实现一个基础的单线程聊天室。主要包含服务端启动监听、客户端连接建立以及双向数据流的收发逻辑，附带完整可运行的服务端和客户端代码。

一、Socket编程基本原理

在Java中，java.net.Socket类代表套接字，是服务器与客户端建立TCP连接的机制。TCP是一种双向通信协议，连接建立后，双方通过I/O流进行数据传输。

TCP连接建立的典型步骤如下：

服务端实例化ServerSocket对象，绑定特定端口以准备通信。
服务端调用accept()方法阻塞等待，直到有客户端请求连接。
客户端创建Socket对象，指定服务器地址和端口号发起连接请求。
一旦连接成功，服务端accept()返回一个新的Socket实例，用于与该客户端单独通信。

每个Socket都关联输入流和输出流。客户端的输出流对应服务端的输入流，反之亦然。通过读写这些流，即可完成消息的传递。

二、单线程聊天室实现思路

实现单线程聊天室的核心在于理清服务器端与客户端的操作流程：

服务器端 (ServerSocket)：创建ServerSocket并绑定端口 → 调用accept()等待并接收客户端 → 获取连接的Socket → 通过流发送/接收数据 → 关闭资源。
客户端 (Socket)：创建Socket连接服务器IP和端口 → 通过流发送/接收数据 → 关闭资源。

注意：单线程模式下，服务器在处理完一次请求前无法接受其他连接，仅适用于学习Socket基础通信原理。

三、服务端代码详解

服务端主要负责监听端口、接受连接，并处理来自单个客户端的一条消息。

启动服务：创建ServerSocket对象，监听6666端口，并打印启动信息。
等待连接：调用serverSocket.accept()，程序在此处阻塞，直到客户端连接成功。连接成功后，获取客户端的Socket对象。
接收数据：从Socket获取InputStream，使用Scanner包装以按行读取文本消息。
发送数据：获取OutputStream，使用OutputStreamWriter将其转换为字符流，写入回复内容并调用flush()确保数据立即发送。
关闭资源：关闭ServerSocket，结束程序。

package single;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class SingleThreadServer {
    public static void main(String[] args) {
        try {
            // 1. 创建服务端ServerSocket，监听6666端口
            ServerSocket serverSocket = new ServerSocket(6666);
            System.out.println("服务器启动..." + serverSocket.getLocalSocketAddress());

            // 2. 接收客户端连接
            Socket socket = serverSocket.accept(); // 阻塞等待
            System.out.println("接收到客户端连接..." + socket.getRemoteSocketAddress());

            // 3. 接收数据
            InputStream inputStream = socket.getInputStream(); // 获取字节流
            Scanner scanner = new Scanner(inputStream);        // 字节流转字符流
            String message = scanner.nextLine();               // 按行读取
            System.out.println("收到客户端的消息:" + message);

            // 4. 发送数据
            OutputStream outputStream = socket.getOutputStream();
            OutputStreamWriter writer = new OutputStreamWriter(outputStream);
            writer.write("你好,客户端,我很好.\n");
            writer.flush(); // 刷新缓冲区，强制发送

            // 5. 关闭资源
            serverSocket.close();
            System.out.println("服务器关闭");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

四、客户端代码详解

客户端负责主动连接服务器，发送问候语并接收服务器的回复。

发起连接：实例化Socket，指定本地回环地址127.0.0.1和服务端端口6666。
发送数据：获取输出流，包装为字符流后写入消息“你好,服务器.”，并执行flush()。
接收数据：获取输入流，使用Scanner按行读取服务器发回的响应。
关闭资源：连接完成后关闭Socket。

package single;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class SingleThreadClient {
    public static void main(String[] args) {
        try {
            // 1. 创建Socket客户端，连接指定服务器地址和端口号
            Socket socket = new Socket("127.0.0.1", 6666);
            System.out.println("客户端创建..." + socket.getLocalSocketAddress());

            // 2. 发送数据
            OutputStream outputStream = socket.getOutputStream();
            OutputStreamWriter writer = new OutputStreamWriter(outputStream);
            writer.write("你好,服务器.\n");
            writer.flush();

            // 3. 接收数据
            InputStream inputStream = socket.getInputStream();
            Scanner scanner = new Scanner(inputStream);
            String message = scanner.nextLine();
            System.out.println("接收到服务器的消息:" + message);

            // 4. 关闭资源
            socket.close();
            System.out.println("客户端关闭");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}