Java Socket 客户端实现连续接收服务器消息

环境准备与工具

为了验证客户端的代码，我们需要一个能够模拟发送消息的服务端。这里推荐使用小巧易用的 NetAssist 软件进行调试。



请确保服务端已启动并配置好对应的 IP 地址（如 192.168.3.65）和端口号（如 8080），以便客户端能够成功连接。

核心逻辑分析

实现连续接收消息的关键在于 while(true) 循环结构。在每次循环中：
1. 创建一个新的输入流或复用现有流（本例为简化演示，在循环内实例化，实际生产建议复用）；
2. 检查输入流中是否有可用数据；
3. 若存在数据，则读取缓冲区并进行处理；
4. 若无数据，通常会根据业务需求决定是休眠等待、抛出异常还是尝试重连。

完整代码实现

以下是 Java 客户端的完整示例代码。请注意处理 IOException 以确保程序的健壮性。

import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;

public class Client {
    // 配置服务器地址和端口
    public static final String IP_ADDR = "192.168.3.65";
    public static final int PORT = 8080;

    public static void main(String[] args) throws IOException {
        System.out.println("客户端启动...");
        Socket socket = null;
        try {
            // 建立与服务器的连接
            socket = new Socket(IP_ADDR, PORT);
            
            // 循环接收消息
            while (true) {
                try {
                    // 创建数据输入流
                    DataInputStream input = new DataInputStream(socket.getInputStream());
                    
                    // 检查是否有可用字节
                    byte[] buffer = new byte[input.available()];
                    
                    if (buffer.length != 0) {
                        // 读取缓冲区内容
                        input.read(buffer);
                        
                        // 将字节数组转换为字符串
                        String message = new String(buffer);
                        System.out.println("长度: " + buffer.length);
                        System.out.println("内容: " + message);
                    } else {
                        // 如果没有数据，可以根据需要暂停一下，避免空转
                        Thread.sleep(100); 
                    }
                } catch (Exception e) {
                    System.out.println("客户端接收异常: " + e.getMessage());
                    break; // 发生异常时退出循环，防止无限报错
                }
            }
        } catch (IOException e) {
            System.out.println("连接失败: " + e.getMessage());
        } finally {
            // 注意：资源关闭应放置在合适的位置，此处仅为示例结构
            if (socket != null && !socket.isClosed()) {
                socket.close();
            }
        }
    }
}

运行结果说明

当服务器发送数据时，控制台会打印出接收到的消息长度及具体内容。例如：

客户端启动...
长度: 27
内容: https://www.jb51.net

这表明客户端已成功建立连接，并能正确解析和显示来自服务器的连续消息。

注意事项与优化建议

• 性能优化：上述代码在循环内部重新创建了 DataInputStream。在高并发或高频通信场景下，建议在 Socket 连接建立后，一次性初始化输入/输出流，避免重复创建对象带来的开销。
• 阻塞问题：使用 input.available() 检查数据量是一种非阻塞式的试探方法。如果数据尚未到达但连接未断开，可能返回 0。更标准的做法是直接调用 input.read(buffer)，该方法会阻塞直到有数据写入或流结束。
• 异常处理：务必捕获 IOException。如果服务端突然关闭连接，客户端再次尝试读取时会抛出异常，此时应当跳出循环并清理资源。

以上就是 Java 实现 Socket 连续获取服务器消息的详细内容，更多关于 Java Socket 编程的资料请关注本站其它相关文章！