<dependency>
    <groupId>com.fazecast</groupId>
    <artifactId>jSerialComm</artifactId>
    <version>2.10.3</version> <!-- 最新版本 -->
</dependency>

implementation 'com.fazecast:jSerialComm:2.10.3'

import com.fazecast.jSerialComm.SerialPort;
import java.io.BufferedReader;
import java.io.InputStreamReader;

public class SensorSerialReceiver {
    public static void main(String[] args) {
        // 1. 獲取所有可用串口
        SerialPort[] ports = SerialPort.getCommPorts();
        if (ports.length == 0) {
            System.out.println("未找到可用串口！");
            return;
        }

        // 2. 選擇目標串口（根據實際傳感器連接的串口選擇，如 COM3、/dev/ttyUSB0）
        SerialPort targetPort = ports[0]; // 這裏默認選擇第一個，實際需修改
        System.out.println("選擇的串口：" + targetPort.getSystemPortName());

        // 3. 配置串口參數（需與傳感器一致，如波特率、數據位、停止位、校驗位）
        targetPort.setComPortParameters(
            9600,                // 波特率（常見：9600、115200）
            SerialPort.DATABITS_8, // 數據位
            SerialPort.STOPBITS_1, // 停止位
            SerialPort.PARITY_NONE  // 校驗位（無）
        );
        targetPort.setComPortTimeouts(SerialPort.TIMEOUT_READ_SEMI_BLOCKING, 100, 0); // 讀取超時

        // 4. 打開串口
        if (!targetPort.openPort()) {
            System.out.println("串口打開失敗！");
            return;
        }
        System.out.println("串口已打開，等待接收傳感器信號...");

        // 5. 讀取串口數據（傳感器通常按行發送數據，如 "温度:25.5℃\n"）
        try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(targetPort.getInputStream(), "UTF-8")
        )) {
            String line;
            while ((line = reader.readLine()) != null) {
                System.out.println("收到傳感器信號：" + line);
                // 在這裏解析信號（如提取温度、濕度等）
                parseSensorData(line);
            }
        } catch (Exception e) {
            System.err.println("串口讀取異常：" + e.getMessage());
        } finally {
            // 6. 關閉串口（重要！）
            targetPort.closePort();
            System.out.println("串口已關閉");
        }
    }

    // 解析傳感器數據（根據實際信號格式修改）
    private static void parseSensorData(String data) {
        // 示例：假設信號格式為 "温度:25.5,濕度:60.0"
        if (data.contains("温度:") && data.contains("濕度:")) {
            String tempStr = data.split("温度:")[1].split(",")[0];
            String humidityStr = data.split("濕度:")[1];
            try {
                double temperature = Double.parseDouble(tempStr);
                double humidity = Double.parseDouble(humidityStr);
                System.out.println("解析結果：温度=" + temperature + "℃，濕度=" + humidity + "%");
            } catch (NumberFormatException e) {
                System.err.println("數據解析失敗：" + data);
            }
        }
    }
}

import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedReader;
import java.io.InputStreamReader;

public class SensorTcpServer {
    public static void main(String[] args) {
        int port = 8888; // 監聽端口（需與傳感器配置一致）
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("TCP 服務器啓動，監聽端口 " + port + "...");
            while (true) {
                // 等待傳感器連接
                Socket clientSocket = serverSocket.accept();
                System.out.println("傳感器連接成功：" + clientSocket.getInetAddress());

                // 讀取數據
                try (BufferedReader reader = new BufferedReader(
                    new InputStreamReader(clientSocket.getInputStream(), "UTF-8")
                )) {
                    String line;
                    while ((line = reader.readLine()) != null) {
                        System.out.println("收到 TCP 信號：" + line);
                        parseSensorData(line); // 複用上面的解析方法
                    }
                } catch (Exception e) {
                    System.err.println("TCP 連接異常：" + e.getMessage());
                } finally {
                    clientSocket.close();
                    System.out.println("傳感器連接關閉");
                }
            }
        } catch (Exception e) {
            System.err.println("TCP 服務器啓動失敗：" + e.getMessage());
        }
    }

    private static void parseSensorData(String data) {
        // 同場景1的解析邏輯
    }
}

import java.net.DatagramSocket;
import java.net.DatagramPacket;
import java.nio.charset.StandardCharsets;

public class SensorUdpReceiver {
    public static void main(String[] args) {
        int port = 8888; // 監聽端口
        try (DatagramSocket socket = new DatagramSocket(port)) {
            System.out.println("UDP 接收器啓動，監聽端口 " + port + "...");
            byte[] buffer = new byte[1024]; // 緩衝區大小（根據信號長度調整）
            while (true) {
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                socket.receive(packet); // 阻塞等待數據
                String data = new String(packet.getData(), 0, packet.getLength(), StandardCharsets.UTF_8);
                System.out.println("收到 UDP 信號：" + data);
                parseSensorData(data); // 複用解析方法
            }
        } catch (Exception e) {
            System.err.println("UDP 接收器異常：" + e.getMessage());
        }
    }

    private static void parseSensorData(String data) {
        // 同場景1的解析邏輯
    }
}

import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;

public class SensorFileReceiver {
    public static void main(String[] args) {
        String filePath = "sensor_data.txt"; // 傳感器數據文件路徑
        try {
            // 讀取文件所有行
            List<String> lines = Files.readAllLines(Paths.get(filePath), StandardCharsets.UTF_8);
            System.out.println("開始讀取文件：" + filePath);
            for (String line : lines) {
                System.out.println("文件中的信號：" + line);
                parseSensorData(line); // 複用解析方法
            }
        } catch (Exception e) {
            System.err.println("文件讀取異常：" + e.getMessage());
        }
    }

    private static void parseSensorData(String data) {
        // 同場景1的解析邏輯
    }
}