引maven

<dependency><groupId>com.github.purejavacomm</groupId><artifactId>purejavacomm</artifactId><version>1.0.2.RELEASE</version>
</dependency>

工具类

package com.fx.client.utils;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.List;
import java.util.TooManyListenersException;import purejavacomm.CommPort;
import purejavacomm.CommPortIdentifier;
import purejavacomm.NoSuchPortException;
import purejavacomm.PortInUseException;
import purejavacomm.SerialPort;
import purejavacomm.SerialPortEventListener;
import purejavacomm.UnsupportedCommOperationException;/*** @name: SerialPortUtil* @author: tuacy.* @date: 2019/6/26.* @version: 1.0* @Description: 串口工具类*/
public class SerialPortUtil {/*** 获得系统可用的端口名称列表(COM0、COM1、COM2等等)** @return List<String>可用端口名称列表*/@SuppressWarnings("unchecked")public static List<String> getSerialPortList() {List<String> systemPorts = new ArrayList<>();//获得系统可用的端口Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers();while (portList.hasMoreElements()) {//获得端口的名字String portName = portList.nextElement().getName();systemPorts.add(portName);}return systemPorts;}/*** 打开串口** @param serialPortName 串口名称* @return SerialPort 串口对象* @throws NoSuchPortException               对应串口不存在* @throws PortInUseException                串口在使用中* @throws UnsupportedCommOperationException 不支持操作操作*/public static SerialPort openSerialPort(String serialPortName)throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {SerialPortParameter parameter = new SerialPortParameter(serialPortName);return openSerialPort(parameter);}/*** 打开串口** @param serialPortName 串口名称* @param baudRate       波特率* @return SerialPort 串口对象* @throws NoSuchPortException               对应串口不存在* @throws PortInUseException                串口在使用中* @throws UnsupportedCommOperationException 不支持操作操作*/public static SerialPort openSerialPort(String serialPortName, int baudRate)throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {SerialPortParameter parameter = new SerialPortParameter(serialPortName, baudRate);return openSerialPort(parameter);}/*** 打开串口** @param serialPortName 串口名称* @param baudRate       波特率* @param timeout        串口打开超时时间* @return SerialPort 串口对象* @throws NoSuchPortException               对应串口不存在* @throws PortInUseException                串口在使用中* @throws UnsupportedCommOperationException 不支持操作操作*/public static SerialPort openSerialPort(String serialPortName, int baudRate, int timeout)throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {SerialPortParameter parameter = new SerialPortParameter(serialPortName, baudRate);return openSerialPort(parameter, timeout);}/*** 打开串口** @param parameter 串口参数* @return SerialPort 串口对象* @throws NoSuchPortException               对应串口不存在* @throws PortInUseException                串口在使用中* @throws UnsupportedCommOperationException 不支持操作操作*/public static SerialPort openSerialPort(SerialPortParameter parameter)throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {return openSerialPort(parameter, 2000);}/*** 打开串口** @param parameter 串口参数* @param timeout   串口打开超时时间* @return SerialPort串口对象* @throws NoSuchPortException               对应串口不存在* @throws PortInUseException                串口在使用中* @throws UnsupportedCommOperationException 不支持操作操作*/public static SerialPort openSerialPort(SerialPortParameter parameter, int timeout)throws NoSuchPortException, PortInUseException, UnsupportedCommOperationException {//通过端口名称得到端口CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(parameter.getSerialPortName());//打开端口，（自定义名字，打开超时时间）CommPort commPort = portIdentifier.open(parameter.getSerialPortName(), timeout);//判断是不是串口if (commPort instanceof SerialPort) {SerialPort serialPort = (SerialPort) commPort;//设置串口参数（波特率，数据位8，停止位1，校验位无）serialPort.setSerialPortParams(parameter.getBaudRate(), parameter.getDataBits(), parameter.getStopBits(), parameter.getParity());System.out.println("开启串口成功，串口名称：" + parameter.getSerialPortName());return serialPort;} else {//是其他类型的端口throw new NoSuchPortException();}}/*** 关闭串口** @param serialPort 要关闭的串口对象*/public static void closeSerialPort(SerialPort serialPort) {if (serialPort != null) {serialPort.removeEventListener();serialPort.close();System.out.println("关闭了串口：" + serialPort.getName());}}/*** 向串口发送数据** @param serialPort 串口对象* @param data       发送的数据* @throws IOException */public static void sendData(SerialPort serialPort, byte[] data) throws IOException {OutputStream os = null;try {//获得串口的输出流os = serialPort.getOutputStream();os.write(data);os.flush();//serialPort.} catch (IOException e) {throw e;} finally {try {if (os != null) {os.close();}} catch (IOException e) {e.printStackTrace();}}}/*** 从串口读取数据** @param serialPort 要读取的串口* @return 读取的数据* @throws IOException */public static byte[] readData(SerialPort serialPort) throws IOException {InputStream is = null;byte[] bytes = null;try {//获得串口的输入流is = serialPort.getInputStream();//获得数据长度int bufflenth = is.available();while (bufflenth != 0) {//初始化byte数组bytes = new byte[bufflenth];is.read(bytes);bufflenth = is.available();}} catch (IOException e) {throw e;} finally {try {if (is != null) {is.close();}} catch (IOException e) {e.printStackTrace();}}return bytes;}/*** 给串口设置监听** @param serialPort serialPort 要读取的串口* @param listener   SerialPortEventListener监听对象* @throws TooManyListenersException 监听对象太多* SerialPortUtil.setListenerToSerialPort(serialPort, event -> {//数据通知if (event.getEventType() == SerialPortEvent.DATA_AVAILABLE) {byte[] bytes = SerialPortUtil.readData(serialPort);System.out.println("收到的数据长度：" + bytes.length);System.out.println("收到的数据：" +new String(bytes));}*/public static void setListenerToSerialPort(SerialPort serialPort, SerialPortEventListener listener) throws TooManyListenersException {//给串口添加事件监听serialPort.addEventListener(listener);//串口有数据监听serialPort.notifyOnDataAvailable(true);//中断事件监听serialPort.notifyOnBreakInterrupt(true);}}

调用

SerialPortUtil.openSerialPort( 端口 getSerialPortList().get(0));SerialPortUtil.setListenerToSerialPort(serialPort, event -> {// 数据通知if (event.getEventType() == SerialPortEvent.DATA_AVAILABLE) {byte[] bytes;try {bytes = SerialPortUtil.readData(serialPort);baseTestService.readMsg(bytes);} catch (IOException e) {e.printStackTrace();}}});