<!--    COM串口通信    -->
        <dependency>
            <groupId>com.fazecast</groupId>
            <artifactId>jSerialComm</artifactId>
            <version>2.6.2</version>
        </dependency>
        <!--    hutool工具    -->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.6.5</version>
        </dependency>

import com.fazecast.jSerialComm.SerialPort;
import lombok.Data;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
import java.util.Map;
/**
?* ?用于定義串口通用信息配置
?* */
@Configuration
public class SerialConfig {
? ? /**
? ? ?* ?波特率
? ? ?* */
? ? public static int baudRate = 19200;
? ? /**
? ? ?* 數(shù)據(jù)位
? ? ?*/
? ? public static int dataBits = 8;
? ? /**
? ? ?* 停止位 ( 1停止位 = 1 ?、 1.5停止位 = 2 、2停止位 = 3)
? ? ?* */
? ? public static int stopBits = 1;
? ? /**
? ? ?* 校驗?zāi)Ｊ?( 無校驗 = 0 ?、奇校驗 = 1 、偶校驗 = 2、 標(biāo)記校驗 = 3、 空格校驗 = 4 ?)
? ? ?* */
? ? public static int parity = 1;
? ? /**
? ? ?* ?是否為 Rs485通信
? ? ?* */
? ? public static boolean rs485Mode = true;
? ? /**
? ? ?* ?串口讀寫超時時間（毫秒）
? ? ?* */
? ? public static int timeOut = 300;
? ? /**
? ? ?* 消息模式
? ? ?* 非阻塞模式： #TIMEOUT_NONBLOCKING ? ? ? ? ? 【在該模式下，readBytes(byte[], long)和writeBytes(byte[], long)調(diào)用將立即返回任何可用數(shù)據(jù)?！?
? ? ?* 寫阻塞模式： #TIMEOUT_WRITE_BLOCKING ? ? ? ?【在該模式下，writeBytes(byte[], long)調(diào)用將阻塞，直到所有數(shù)據(jù)字節(jié)都成功寫入輸出串口設(shè)備?！?
? ? ?* 半阻塞讀取模式： #TIMEOUT_READ_SEMI_BLOCKING 【在該模式下，readBytes(byte[], long)調(diào)用將阻塞，直到達(dá)到指定的超時時間或者至少可讀取1個字節(jié)的數(shù)據(jù)?！?
? ? ?* 全阻塞讀取模式：#TIMEOUT_READ_BLOCKING ? ? ? 【在該模式下，readBytes(byte[], long)調(diào)用將阻塞，直到達(dá)到指定的超時時間或者可以返回請求的字節(jié)數(shù)?！?
? ? ?* 掃描器模式：#TIMEOUT_SCANNER ? ? ? ? ? ? ? ?【該模式適用于使用Java的java.util.Scanner類從串口進(jìn)行讀取，會忽略手動指定的超時值以確保與Java規(guī)范的兼容性】
? ? ?* */
? ? public static int messageModel = SerialPort.TIMEOUT_READ_BLOCKING;
? ? /**
? ? ?* ?已打開的COM串口 (重復(fù)打開串口會導(dǎo)致后面打開的無法使用，所以打開一次就要記錄到公共變量存儲)
? ? ?* */
? ? public final static Map<String, SerialPort> portMap = new HashMap<>();
}

import cn.hutool.core.codec.BCD;  
import com.fazecast.jSerialComm.SerialPort;  
import com.tce.station.common.config.SerialConfig;  
import lombok.AllArgsConstructor;  
import lombok.extern.slf4j.Slf4j;  
import org.springframework.stereotype.Service;  
import java.io.InputStream;  
import java.util.Arrays;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
/**  
* 串口服務(wù)類  
* */  
@AllArgsConstructor  
@Slf4j  
@Service  
public class SerialService {  
/**  
* 獲取串口及狀態(tài)  
* */  
public Map<String, Boolean> getPortStatus(){  
        Map<String, Boolean> comStatusMap = new HashMap<>();  
        List<SerialPort> commPorts = Arrays.asList(SerialPort.getCommPorts());  
        commPorts.forEach(port->{  
        comStatusMap.put(port.getSystemPortName(), port.isOpen());  
    });  
    return comStatusMap;  
}  
/**  
* 添加串口連接  
* */  
public void connectSerialPort(String portName){  
    SerialPort commPort = SerialPort.getCommPort(portName);  
    if (commPort.isOpen()){  
        throw new RuntimeException("該串口已被占用");  
    }  
    if (SerialConfig.portMap.containsKey(portName)){  
        throw new RuntimeException("該串口已被占用");  
    }  
    // 打開端口  
    commPort.openPort();  
    if (!commPort.isOpen()){  
        throw new RuntimeException("打開串口失敗");  
    }  
    // 設(shè)置串口參數(shù) (波特率、數(shù)據(jù)位、停止位、校驗?zāi)Ｊ?、是否為Rs485)  
    commPort.setComPortParameters(SerialConfig.baudRate, SerialConfig.dataBits,SerialConfig.stopBits, SerialConfig.stopBits, SerialConfig.rs485Mode);  
    // 設(shè)置串口超時和模式  
    commPort.setComPortTimeouts(SerialConfig.messageModel ,SerialConfig.timeOut, SerialConfig.timeOut);  
    // 添加至串口記錄Map  
    SerialConfig.portMap.put(portName, commPort);  
}  
/**  
* 關(guān)閉串口連接  
* */  
public boolean closeSerialPort(String portName){  
    if (!SerialConfig.portMap.containsKey(portName)){  
        throw new RuntimeException("該串口未啟用");  
    }  
    // 獲取串口  
    SerialPort port = SerialConfig.portMap.get(portName);  
    // 關(guān)閉串口  
    port.closePort();  
    // 需要等待一些時間，否則串口關(guān)閉不完全，會導(dǎo)致無法打開  
    try {  
        Thread.sleep(3000);  
    } catch (InterruptedException e) {  
        throw new RuntimeException(e);  
    }  
    if (port.isOpen()){  
        return false;  
    }else {  
        // 關(guān)閉成功返回  
        return true;  
    }  
}  
/**  
* 串口發(fā)送數(shù)據(jù)  
* */  
public void sendComData(String portName, byte[]sendBytes){  
    if (!SerialConfig.portMap.containsKey(portName)){  
        throw new RuntimeException("該串口未啟用");  
    }  
    // 獲取串口  
    SerialPort port = SerialConfig.portMap.get(portName);  
    // 發(fā)送串口數(shù)據(jù)  
    int i = port.writeBytes(sendBytes, sendBytes.length);  
    if (i == -1){  
        log.error("發(fā)送串口數(shù)據(jù)失敗{}, 數(shù)據(jù)內(nèi)容{}",portName, BCD.bcdToStr(sendBytes));  
        throw new RuntimeException("發(fā)送串口數(shù)據(jù)失敗");  
    }  
}  
/**  
* 串口讀取數(shù)據(jù)  
* */  
public byte[] readComData(String portName){  
    if (!SerialConfig.portMap.containsKey(portName)){  
        throw new RuntimeException("該串口未啟用");  
    }  
    // 獲取串口  
    SerialPort port = SerialConfig.portMap.get(portName);   
    // 讀取串口流  
    InputStream inputStream = port.getInputStream();  
    // 獲取串口返回的流大小  
    int availableBytes = 0;  
    try {  
        availableBytes = inputStream.available();  
    } catch (Exception e) {  
        e.printStackTrace();  
    }  
    // 讀取指定的范圍的數(shù)據(jù)流  
    byte[] readByte = new byte[availableBytes];  
    int bytesRead = 0;  
    try {  
        bytesRead = inputStream.read(readByte);  
    } catch (Exception e) {  
        e.printStackTrace();  
    }  
    return readByte;  
}  
}

// 從數(shù)據(jù)庫或者配置表中讀取設(shè)定要打開的串口
List<String> comList = comService.list();
// 關(guān)閉之前的監(jiān)聽連接(提取所有串口避免重復(fù)關(guān)閉) ?
SerialConfig.portMap.forEach((com,serialPort) ->{ ?
?? ?serialService.closeSerialPort(com); ?
});
// 等待之前的串口發(fā)送和 2倍監(jiān)聽超時，避免還有串口通信線程未關(guān)閉 ?
try { ?
?? ?Thread.sleep((SerialConfig.timeOut + 1) * 2); ?
} catch (InterruptedException e) { ?
?? ?throw new RuntimeException(e); ?
}
// 清空COM口記錄 ?
SerialConfig.portMap.clear();
// 重新連接串口 ?
gunList.forEach(gun->{ ?
?? ?// 如果COM口沒有就打開 ?
?? ?if (!SerialConfig.portMap.containsKey(gun.getCom())){ ?
?? ??? ?// 創(chuàng)建連接 ?
?? ??? ?SerialPort serialPort = serialService.connectSerialPort(gun.getCom()); ?
?? ??? ?// 綁定監(jiān)聽器 ?
?? ??? ?// serialPort.addDataListener(new MessageListener()); ?
?? ?} ??
});

String com = "COM1";
serialService.closeSerialPort(com); 

/**  
* 周期性向串口發(fā)送數(shù)據(jù)  
* */  
@Scheduled(fixedRate = 1500L)  
public void send{  
    // 因為是阻塞是監(jiān)聽線程，所以使用線程處理  
    Thread thread = new Thread(() -> {  
        try {  
            SerialConfig.portMap.forEach((com,serialPort)->{  
                // 等待0.1秒  
                try {  
                    Thread.sleep(100);  
                }catch (Exception e){  
                    e.printStackTrace();  
                }  
                // 調(diào)用業(yè)務(wù)邏輯獲取需要推送的數(shù)據(jù)
                byte[] sendBytes = getPushData(com);
                // 發(fā)送串口數(shù)據(jù)  
                serialService.sendComData(com, sendBytes);  
                log.info("向串口發(fā)送 {}",gun.getGunNum(), com, BCD.bcdToStr(sendBytes));  
            });  
        }catch (ConcurrentModificationException e){  
            log.info("COM口配置發(fā)生變化,等待配置生效");  
        }  
    });
    // 開啟發(fā)送線程  
    thread.start();  
}

/**  
* 周期性讀取串口數(shù)據(jù)  
* */  
@Scheduled(fixedRate = 1000L)  
public void readComData() {  
    // 遍歷監(jiān)聽  
    SerialConfig.portMap.forEach((com,serialPort)->{  
        // 因為是阻塞是監(jiān)聽線程，所以使用線程處理,否則某個讀取失敗，會阻塞整個程序  
        Thread thread = new Thread(() -> {  
            byte[] readByte = serialService.readComData(com);  
            // 有數(shù)據(jù)才執(zhí)行
            if (readByte.length > 1) {  
            try {  
                log.info("收到串口數(shù)據(jù): {}", BCD.bcdToStr(readByte));  
                // 調(diào)用串口響應(yīng)業(yè)務(wù)操作  
                comOperationByData(comResult,BCD.strToBcd(res), com);  
            }catch (Exception e){  
                e.printStackTrace();  
            }  
        });  
        // 開啟線程
        thread.start();  
    }

@Slf4j ?
public class MessageListener implements SerialPortDataListener { ?
@Autowired ?
ICommandService commandService; ?
/** ?
* 監(jiān)聽事件設(shè)置 ?
* */ ?
@Override ?
public int getListeningEvents() { ?
?? ?// 持續(xù)返回數(shù)據(jù)流模式 ?
?? ?return SerialPort.LISTENING_EVENT_DATA_AVAILABLE; ?
?? ?// 收到數(shù)據(jù)立即返回 ?
?? ?// return SerialPort.LISTENING_EVENT_DATA_RECEIVED; ?
} ?
/** ?
* 收到數(shù)據(jù)監(jiān)聽回調(diào) ?
* */ ?
@Override ?
public void serialEvent(SerialPortEvent event) { ?
?? ?// 因為是阻塞是監(jiān)聽線程，所以使用線程處理 ?
?? ?Thread thread = new Thread(() -> { ?
?? ??? ?// 讀取串口流 ?
?? ??? ?InputStream inputStream = event.getSerialPort().getInputStream(); ?
?? ??? ?// 獲取串口返回的流大小 ?
?? ??? ?int availableBytes = 0; ?
?? ??? ?try { ?
?? ??? ??? ?availableBytes = inputStream.available(); ?
?? ??? ?} catch (Exception e) { ?
?? ??? ??? ?e.printStackTrace(); ?
?? ??? ?} ?
?? ??? ?// 讀取指定的范圍的數(shù)據(jù)流 ?
?? ??? ?byte[] readByte = new byte[availableBytes]; ?
?? ??? ?int bytesRead = 0; ?
?? ??? ?try { ?
?? ??? ??? ?bytesRead = inputStream.read(readByte); ?
?? ??? ?} catch (Exception e) { ?
?? ??? ??? ?e.printStackTrace(); ?
?? ??? ?} ?
?? ??? ?try { ?
?? ??? ??? ?inputStream.close(); ?
?? ??? ?} catch (IOException e) { ?
?? ??? ??? ?throw new RuntimeException("關(guān)閉串口流失敗"+e.getMessage()); ?
?? ??? ?} ?
?? ??? ?// 有數(shù)據(jù)才執(zhí)行
?? ??? ?if (readByte.length > 1) { ?
?? ??? ??? ?try { ?
?? ??? ??? ??? ?log.info("收到串口數(shù)據(jù): {}", BCD.bcdToStr(readByte)); ?
?? ??? ??? ??? ?// 調(diào)用串口響應(yīng)業(yè)務(wù)操作 ?
?? ??? ??? ??? ?comOperationByData(comResult,BCD.strToBcd(res), com); ?
?? ??? ??? ?}catch (Exception e){ ?
?? ??? ??? ??? ?e.printStackTrace(); ?
?? ??? ??? ?}?
?? ??? ?}?
?? ?}); ?
// 開啟線程
thread.start(); ?
} ?
}

// 創(chuàng)建連接  
SerialPort serialPort = serialService.connectSerialPort(gun.getCom());  
// 綁定監(jiān)聽器  
serialPort.addDataListener(new MessageListener());