用Java写一个串口通信程序

你可以参考以下步骤来编写一个串口通信程序：

1. 创建一个CommPortIdentifier对象，以获取串口的端口号。

2. 打开串口，使用CommPortIdentifier的open()方法。

3. 获取串口的输入输出流，使用CommPort的getInputStream()和getOutputStream()方法。

4. 使用InputStreamReader和OutputStreamWriter对象来读写串口数据。

5. 关闭串口，使用CommPort的close()方法。

相关问题

用Java写一个串口通信的代码

好的，下面是一个简单的Java串口通信代码示例：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;
import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.SerialPort;

public class SerialCommunication {
 
    public static void main(String[] args) {
        try {
            CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier("COM1"); // 根据实际串口号修改
            if (portIdentifier.isCurrentlyOwned()) {
                System.out.println("Error: Port is currently in use");
            } else {
                CommPort commPort = portIdentifier.open("SerialCommunication", 2000); // 应用程序名和超时时间
                if (commPort instanceof SerialPort) {
                    SerialPort serialPort = (SerialPort) commPort;
                    serialPort.setSerialPortParams(9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); // 波特率、数据位、停止位、校验位
                    InputStream in = serialPort.getInputStream();
                    OutputStream out = serialPort.getOutputStream();
                    (new Thread(new SerialReader(in))).start();
                    (new Thread(new SerialWriter(out))).start();
                } else {
                    System.out.println("Error: Only serial ports are handled by this example.");
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public static class SerialReader implements Runnable {
 
        InputStream in;
 
        public SerialReader(InputStream in) {
            this.in = in;
        }
 
        public void run() {
            byte[] buffer = new byte[1024];
            int len = -1;
            try {
                while ((len = this.in.read(buffer)) > -1) {
                    System.out.print(new String(buffer, 0, len));
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    public static class SerialWriter implements Runnable {
 
        OutputStream out;
 
        public SerialWriter(OutputStream out) {
            this.out = out;
        }
 
        public void run() {
            try {
                int c = 0;
                while ((c = System.in.read()) > -1) {
                    this.out.write(c);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

这个示例使用了RXTXcomm库，需要先下载并配置。具体的代码注释请参考代码。

用Java写一个基于RXTX串口通信程序：

好的，下面是一个简单的基于RXTX串口通信的Java程序示例：

import gnu.io.*;

import java.io.*;
import java.util.Enumeration;

public class SerialPortCommunication implements SerialPortEventListener {

    private SerialPort serialPort;
    private InputStream inputStream;
    private OutputStream outputStream;
    private static final int TIME_OUT = 2000; // 等待超时时间
    private static final int DATA_RATE = 9600; // 串口数据传输速率

    public void initialize() {
        CommPortIdentifier portId = null;
        Enumeration portEnum = CommPortIdentifier.getPortIdentifiers();

        // 遍历所有可用串口，找到指定的串口
        while (portEnum.hasMoreElements()) {
            CommPortIdentifier currPortId = (CommPortIdentifier) portEnum.nextElement();
            if ("COM3".equals(currPortId.getName())) {
                portId = currPortId;
                break;
            }
        }

        if (portId == null) {
            System.out.println("找不到指定的串口");
            return;
        }

        try {
            // 打开串口，设置参数
            serialPort = (SerialPort) portId.open(this.getClass().getName(), TIME_OUT);
            serialPort.setSerialPortParams(DATA_RATE, SerialPort.DATABITS_8, SerialPort.STOPBITS_1,
                    SerialPort.PARITY_NONE);

            // 获取输入输出流
            inputStream = serialPort.getInputStream();
            outputStream = serialPort.getOutputStream();

            // 添加串口事件监听器
            serialPort.addEventListener(this);
            serialPort.notifyOnDataAvailable(true);
        } catch (PortInUseException | UnsupportedCommOperationException | IOException | TooManyListenersException e) {
            e.printStackTrace();
        }
    }

    // 发送数据
    public void sendData(String data) {
        try {
            outputStream.write(data.getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 读取数据
    public void serialEvent(SerialPortEvent evt) {
        if (evt.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
            try {
                int availableBytes = inputStream.available();
                byte[] bytes = new byte[availableBytes];
                inputStream.read(bytes, 0, availableBytes);
                String data = new String(bytes);
                System.out.println("接收到数据：" + data);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        SerialPortCommunication serialPortCommunication = new SerialPortCommunication();
        serialPortCommunication.initialize();
        serialPortCommunication.sendData("Hello World!");
    }
}

这个程序可以初始化一个串口，设置参数，发送和接收数据。其中，`initialize()` 方法中的 `COM3` 是指定的串口名称，需要根据实际情况修改。在 `main` 方法中，我们初始化了一个 `SerialPortCommunication` 对象，并发送了一个字符串 "Hello World!"。你可以根据自己的需求修改该程序。