Javaを使ってIoTハードウェアの人体検知機能を開発する方法

import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.SerialPort;

public class SerialPortConnection {
    public static void main(String[] args) throws Exception {
        CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier("/dev/ttyUSB0");
        if (portIdentifier.isCurrentlyOwned()) {
            System.out.println("Error: Port is currently in use");
        } else {
            CommPort commPort = portIdentifier.open(SerialPortConnection.class.getName(), 2000);
            if (commPort instanceof SerialPort) {
                SerialPort serialPort = (SerialPort) commPort;
                serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
                // TODO: 在这里添加人体检测的代码逻辑
            } else {
                System.out.println("Error: Only serial ports are handled by this example.");
            }
        }
    }
}

import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;

public class HumanDetection implements SerialPortEventListener {
    private SerialPort serialPort;

    public static void main(String[] args) throws Exception {
        HumanDetection humanDetection = new HumanDetection();
        humanDetection.initialize();
    }

    public void initialize() throws Exception {
        CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier("/dev/ttyUSB0");
        if (portIdentifier.isCurrentlyOwned()) {
            System.out.println("Error: Port is currently in use");
        } else {
            CommPort commPort = portIdentifier.open(HumanDetection.class.getName(), 2000);
            if (commPort instanceof SerialPort) {
                serialPort = (SerialPort) commPort;
                serialPort.addEventListener(this);
                serialPort.notifyOnDataAvailable(true);

                serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
            } else {
                System.out.println("Error: Only serial ports are handled by this example.");
            }
        }
    }

    public void serialEvent(SerialPortEvent event) {
        if (event.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
            try {
                BufferedReader reader = new BufferedReader(new InputStreamReader(serialPort.getInputStream()));
                String line = reader.readLine();
                if (line.equals("1")) {
                    // 人体检测到
                    System.out.println("Human detected!");
                } else {
                    // 人体未检测到
                    System.out.println("No human detected.");
                }
            } catch (Exception e) {
                System.err.println(e.toString());
            }
        }
    }
}

System.out.println("Human detected!");