基于TCP通信实现信号切换的服务端与客户端示例（附带详细代码）

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

public class TCPServer {

    // 处理信号切换逻辑的方法
    private static void handleSignalSwitch(String message) {
        if ("1".equals(message)) {
            System.out.println("切换信号：收到指令 1");
            // 在这里添加切换信号的具体逻辑
        } else {
            System.out.println("未识别的消息: " + message);
        }
    }
    
    // 启动服务器的方法
    public static void startServer(String host, int port) {
        ServerSocket serverSocket = null;
        try {
            // 创建服务器套接字
            serverSocket = new ServerSocket();
            serverSocket.bind(new InetSocketAddress(host, port));
            System.out.println("TCP服务器正在监听 " + host + ":" + port);
    
            while (true) {
                // 等待客户端连接
                Socket clientSocket = serverSocket.accept();
                System.out.println("客户端已连接: " + clientSocket.getRemoteSocketAddress());
    
                // 处理客户端消息
                BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                String message = reader.readLine(); // 读取消息
                if (message != null) {
                    System.out.println("收到消息: " + message);
                    handleSignalSwitch(message);
                }
    
                // 关闭客户端连接
                clientSocket.close();
            }
        } catch (IOException e) {
            System.err.println("服务器发生错误: " + e.getMessage());
        } finally {
            if (serverSocket != null) {
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    System.err.println("关闭服务器时发生错误: " + e.getMessage());
                }
            }
        }
    }
    
    public static void main(String[] args) {
        // 指定IP和端口
        String host = "192.168.1.1";
        int port = 8000;
    
        // 启动服务器
        startServer(host, port);
    }
}

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

public class TCPClient {
    public static void main(String[] args) {
        String host = "192.168.1.1";
        int port = 8000;
        try (Socket socket = new Socket(host, port);
             PrintWriter writer = new PrintWriter(socket.getOutputStream(), true)) {
            writer.println("1"); // 发送消息
            System.out.println("消息已发送: 1");
        } catch (IOException e) {
            System.err.println("客户端发生错误: " + e.getMessage());
        }
    }
}