Java實(shí)現(xiàn)簡(jiǎn)單串口通信的方法

/**
 * 串口必要參數(shù)接收類
 * @author: LinWenLi
 * @date: 2018年7月21日 下午4:30:40
 */
public class ParamConfig {

 private String serialNumber;// 串口號(hào)
 private int baudRate; // 波特率
 private int checkoutBit; // 校驗(yàn)位
 private int dataBit; // 數(shù)據(jù)位
 private int stopBit; // 停止位
 
 public ParamConfig() {}
 
 /**
 * 構(gòu)造方法
 * @param serialNumber 串口號(hào)
 * @param baudRate 波特率
 * @param checkoutBit 校驗(yàn)位
 * @param dataBit 數(shù)據(jù)位
 * @param stopBit 停止位
 */
 public ParamConfig(String serialNumber, int baudRate, int checkoutBit, int dataBit, int stopBit) {
 this.serialNumber = serialNumber;
 this.baudRate = baudRate;
 this.checkoutBit = checkoutBit;
 this.dataBit = dataBit;
 this.stopBit = stopBit;
 }
 getter()...
 setter()...
}

import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import gnu.io.UnsupportedCommOperationException;

/**
 * 串口參數(shù)的配置 串口一般有如下參數(shù)可以在該串口打開以前進(jìn)行配置： 包括串口號(hào)，波特率，輸入/輸出流控制，數(shù)據(jù)位數(shù)，停止位和奇偶校驗(yàn)。
 */
// 注：串口操作類一定要繼承SerialPortEventListener
public class SerialPortUtils implements SerialPortEventListener {
 // 檢測(cè)系統(tǒng)中可用的通訊端口類
 private CommPortIdentifier commPortId;
 // 枚舉類型
 private Enumeration<CommPortIdentifier> portList;
 // RS232串口
 private SerialPort serialPort;
 // 輸入流
 private InputStream inputStream;
 // 輸出流
 private OutputStream outputStream;
 // 保存串口返回信息
 private String data;
 // 保存串口返回信息十六進(jìn)制
 private String dataHex;/**
 * 初始化串口
 * @author LinWenLi
 * @date 2018年7月21日下午3:44:16
 * @Description: TODO
 * @param: paramConfig 存放串口連接必要參數(shù)的對(duì)象（會(huì)在下方給出類代碼） 
 * @return: void 
 * @throws
 */
 @SuppressWarnings("unchecked")
 public void init(ParamConfig paramConfig) {
 // 獲取系統(tǒng)中所有的通訊端口
 portList = CommPortIdentifier.getPortIdentifiers();
 // 記錄是否含有指定串口
 boolean isExsist = false;
 // 循環(huán)通訊端口
 while (portList.hasMoreElements()) {
  commPortId = portList.nextElement();
  // 判斷是否是串口
  if (commPortId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
  // 比較串口名稱是否是指定串口
  if (paramConfig.getSerialNumber().equals(commPortId.getName())) {
   // 串口存在
   isExsist = true;
   // 打開串口
   try {
   // open:（應(yīng)用程序名【隨意命名】，阻塞時(shí)等待的毫秒數(shù)）
   serialPort = (SerialPort) commPortId.open(Object.class.getSimpleName(), 2000);
   // 設(shè)置串口監(jiān)聽
   serialPort.addEventListener(this);
   // 設(shè)置串口數(shù)據(jù)時(shí)間有效(可監(jiān)聽)
   serialPort.notifyOnDataAvailable(true);
   // 設(shè)置串口通訊參數(shù):波特率，數(shù)據(jù)位，停止位,校驗(yàn)方式
   serialPort.setSerialPortParams(paramConfig.getBaudRate(), paramConfig.getDataBit(),
    paramConfig.getStopBit(), paramConfig.getCheckoutBit());
   } catch (PortInUseException e) {
   throw new CustomException("端口被占用");
   } catch (TooManyListenersException e) {
   throw new CustomException("監(jiān)聽器過(guò)多");
   } catch (UnsupportedCommOperationException e) {
   throw new CustomException("不支持的COMM端口操作異常");
   }
   // 結(jié)束循環(huán)
   break;
  }
  }
 }
 // 若不存在該串口則拋出異常
 if (!isExsist) {
  throw new CustomException("不存在該串口！");
 }
 }

 /**
 * 實(shí)現(xiàn)接口SerialPortEventListener中的方法 讀取從串口中接收的數(shù)據(jù)
 */
 @Override
 public void serialEvent(SerialPortEvent event) {
 switch (event.getEventType()) {
 case SerialPortEvent.BI: // 通訊中斷
 case SerialPortEvent.OE: // 溢位錯(cuò)誤
 case SerialPortEvent.FE: // 幀錯(cuò)誤
 case SerialPortEvent.PE: // 奇偶校驗(yàn)錯(cuò)誤
 case SerialPortEvent.CD: // 載波檢測(cè)
 case SerialPortEvent.CTS: // 清除發(fā)送
 case SerialPortEvent.DSR: // 數(shù)據(jù)設(shè)備準(zhǔn)備好
 case SerialPortEvent.RI: // 響鈴偵測(cè)
 case SerialPortEvent.OUTPUT_BUFFER_EMPTY: // 輸出緩沖區(qū)已清空
  break;
 case SerialPortEvent.DATA_AVAILABLE: // 有數(shù)據(jù)到達(dá)
  // 調(diào)用讀取數(shù)據(jù)的方法
  readComm();
  break;
 default:
  break;
 }
 }

 /**
 * 讀取串口返回信息
 * @author LinWenLi
 * @date 2018年7月21日下午3:43:04
 * @return: void 
 */
 public void readComm() {
 try {
  inputStream = serialPort.getInputStream();
  // 通過(guò)輸入流對(duì)象的available方法獲取數(shù)組字節(jié)長(zhǎng)度
  byte[] readBuffer = new byte[inputStream.available()];
  // 從線路上讀取數(shù)據(jù)流
  int len = 0;
  while ((len = inputStream.read(readBuffer)) != -1) {　　　　　　　　　// 直接獲取到的數(shù)據(jù)
  data = new String(readBuffer, 0, len).trim();　　　　　　　　　// 轉(zhuǎn)為十六進(jìn)制數(shù)據(jù)
  dataHex = bytesToHexString(readBuffer);
  System.out.println("data:" + data);
  System.out.println("dataHex:" + dataHex);// 讀取后置空流對(duì)象
  inputStream.close();
  inputStream = null;
  break;
  }
 } catch (IOException e) {
  throw new CustomException("讀取串口數(shù)據(jù)時(shí)發(fā)生IO異常");
 }
 }

 /**
 * 發(fā)送信息到串口
 * @author LinWenLi
 * @date 2018年7月21日下午3:45:22
 * @param: data 
 * @return: void 
 * @throws
 */
 public void sendComm(String data) {
 byte[] writerBuffer = null;
 try {
  writerBuffer = hexToByteArray(data);
 } catch (NumberFormatException e) {
  throw new CustomException("命令格式錯(cuò)誤！");
 }
 try {
  outputStream = serialPort.getOutputStream();
  outputStream.write(writerBuffer);
  outputStream.flush();
 } catch (NullPointerException e) {
  throw new CustomException("找不到串口。");
 } catch (IOException e) {
  throw new CustomException("發(fā)送信息到串口時(shí)發(fā)生IO異常");
 }
 }

 /**
 * 關(guān)閉串口
 * @author LinWenLi
 * @date 2018年7月21日下午3:45:43
 * @Description: 關(guān)閉串口
 * @param: 
 * @return: void 
 * @throws
 */
 public void closeSerialPort() {
 if (serialPort != null) {
  serialPort.notifyOnDataAvailable(false);
  serialPort.removeEventListener();
  if (inputStream != null) {
  try {
   inputStream.close();
   inputStream = null;
  } catch (IOException e) {
   throw new CustomException("關(guān)閉輸入流時(shí)發(fā)生IO異常");
  }
  }
  if (outputStream != null) {
  try {
   outputStream.close();
   outputStream = null;
  } catch (IOException e) {
   throw new CustomException("關(guān)閉輸出流時(shí)發(fā)生IO異常");
  }
  }
  serialPort.close();
  serialPort = null;
 }
 }

 /**
 * 十六進(jìn)制串口返回值獲取
 */
 public String getDataHex() {
 String result = dataHex;
 // 置空?qǐng)?zhí)行結(jié)果
 dataHex = null;
 // 返回執(zhí)行結(jié)果
 return result;
 }

 /**
 * 串口返回值獲取
 */
 public String getData() {
 String result = data;
 // 置空?qǐng)?zhí)行結(jié)果
 data = null;
 // 返回執(zhí)行結(jié)果
 return result;
 }

 /**
 * Hex字符串轉(zhuǎn)byte
 * @param inHex 待轉(zhuǎn)換的Hex字符串
 * @return 轉(zhuǎn)換后的byte
 */
 public static byte hexToByte(String inHex) {
 return (byte) Integer.parseInt(inHex, 16);
 }

 /**
 * hex字符串轉(zhuǎn)byte數(shù)組
 * @param inHex 待轉(zhuǎn)換的Hex字符串
 * @return 轉(zhuǎn)換后的byte數(shù)組結(jié)果
 */
 public static byte[] hexToByteArray(String inHex) {
 int hexlen = inHex.length();
 byte[] result;
 if (hexlen % 2 == 1) {
  // 奇數(shù)
  hexlen++;
  result = new byte[(hexlen / 2)];
  inHex = "0" + inHex;
 } else {
  // 偶數(shù)
  result = new byte[(hexlen / 2)];
 }
 int j = 0;
 for (int i = 0; i < hexlen; i += 2) {
  result[j] = hexToByte(inHex.substring(i, i + 2));
  j++;
 }
 return result;
 }

 /**
 * 數(shù)組轉(zhuǎn)換成十六進(jìn)制字符串
 * @param byte[]
 * @return HexString
 */
 public static final String bytesToHexString(byte[] bArray) {
 StringBuffer sb = new StringBuffer(bArray.length);
 String sTemp;
 for (int i = 0; i < bArray.length; i++) {
  sTemp = Integer.toHexString(0xFF & bArray[i]);
  if (sTemp.length() < 2)
  sb.append(0);
  sb.append(sTemp.toUpperCase());
 }
 return sb.toString();
 }
}

public static void main(String[] args) {
  // 實(shí)例化串口操作類對(duì)象
  SerialPortUtils serialPort = new SerialPortUtils();
  // 創(chuàng)建串口必要參數(shù)接收類并賦值，賦值串口號(hào)，波特率，校驗(yàn)位，數(shù)據(jù)位，停止位
  ParamConfig paramConfig = new ParamConfig("COM4", 9600, 0, 8, 1);
  // 初始化設(shè)置,打開串口，開始監(jiān)聽讀取串口數(shù)據(jù)
  serialPort.init(paramConfig);
  // 調(diào)用串口操作類的sendComm方法發(fā)送數(shù)據(jù)到串口
  serialPort.sendComm("FEF10A000000000000000AFF");
  // 關(guān)閉串口
  serialPort.closeSerialPort();
 }