Java Socket程序无法连接多个传感器至服务器问题咨询

看起来你遇到了Java Socket服务器只能处理单个传感器客户端的问题——这几乎肯定是因为你的服务器是单线程实现的：主线程在接受一个客户端连接后，就会一直卡在处理该客户端的逻辑里，没法回到监听状态接受新的连接。下面是具体的解决方案和修复后的代码示例：

问题根源 #

单线程服务器的典型流程是：调用serverSocket.accept() → 处理该客户端请求 → 结束。这种模式下，服务器同一时间只能服务一个客户端，后续的连接请求会被阻塞，直到当前客户端断开。

修复方案：多线程处理每个客户端 #

核心思路是：主线程持续监听新连接，每收到一个新的Socket连接，就启动一个独立的线程来处理该客户端的通信逻辑，这样主线程可以立刻回到监听状态，接受下一个客户端。

修复后的完整代码示例 #

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import sensors.FireAlarmSensor;

public class SensorServer {
    private static final int PORT = 9000;
    // 用ConcurrentHashMap保证多线程环境下的客户端列表线程安全
    private static final Map<String, PrintWriter> fireSensorPrintersList = new ConcurrentHashMap<>();

    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(PORT)) {
            System.out.println("传感器服务器已启动，监听端口：" + PORT);
            
            // 持续循环监听新的客户端连接
            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("新传感器客户端连接：" + clientSocket.getInetAddress());
                
                // 为每个客户端启动独立的处理线程
                new Thread(new SensorClientHandler(clientSocket)).start();
            }
        } catch (IOException e) {
            System.err.println("服务器启动失败：" + e.getMessage());
            e.printStackTrace();
        }
    }

    // 内部类：负责处理单个客户端的全生命周期通信
    private static class SensorClientHandler implements Runnable {
        private final Socket clientSocket;
        private PrintWriter out;
        private BufferedReader in;
        private String sensorId;

        public SensorClientHandler(Socket socket) {
            this.clientSocket = socket;
        }

        @Override
        public void run() {
            try {
                // 初始化IO流
                out = new PrintWriter(clientSocket.getOutputStream(), true);
                in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

                // 假设客户端首先发送传感器唯一标识（可根据你的协议调整）
                sensorId = in.readLine();
                if (sensorId != null && !sensorId.isEmpty()) {
                    fireSensorPrintersList.put(sensorId, out);
                    System.out.println("传感器[" + sensorId + "]已注册");
                }

                // 持续处理客户端发来的传感器数据
                String inputData;
                while ((inputData = in.readLine()) != null) {
                    System.out.println("收到传感器[" + sensorId + "]数据：" + inputData);
                    // 这里可以添加你的业务逻辑，比如调用FireAlarmSensor处理告警、广播数据等
                    // FireAlarmSensor.processData(sensorId, inputData);
                }
            } catch (IOException e) {
                System.err.println("与传感器[" + sensorId + "]通信出错：" + e.getMessage());
                e.printStackTrace();
            } finally {
                // 客户端断开后，清理资源并从列表中移除
                try {
                    in.close();
                    out.close();
                    clientSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                if (sensorId != null) {
                    fireSensorPrintersList.remove(sensorId);
                    System.out.println("传感器[" + sensorId + "]已断开连接");
                }
            }
        }
    }
}

关键注意事项 #

• 线程安全的客户端列表：用ConcurrentHashMap替代普通HashMap，避免多线程同时操作列表时出现并发异常。
• 资源自动清理：在finally块中关闭IO流和Socket，确保客户端断开后资源被正确释放。
• 独立的业务逻辑：把传感器数据的处理逻辑（比如FireAlarmSensor相关操作）放到SensorClientHandler的消息循环里，每个客户端的业务处理互不干扰。

内容的提问来源于stack exchange，提问作者Ravindu Dharmasena