在做過一年多的RXTX操作串口項目有現在把一些平時遇到的問題在這里寫寫：?
RXTX是一個開源包，主要是在COMM開源包中做擴張，以前的COMM包只能在WINDOWS下面對串口或并口做操作，擴充后的RXTX可以在LINUX和MAC下對串口和并口做操作。 ?現在跨平臺：?
在RXTX網站下載JAR包和動態庫?
http://users.frii.com/jarvi/rxtx/download.html?
下載后配置環境?
Windows?
拷貝RXTXcomm.jar 文件到 \jre\lib\ext 目錄下?
拷貝rxtxSerial.dll文件到 \jre\bin目錄下?
Mac OS X (x86 and ppc) (there is an Installer with the source)?
MAC下面我自己沒有配置環境成功，后來找一個MAC下RXTX的安裝把環境配置好的。?
http://www.jdivelog.org/how-to/mac-os-x/下載安裝環境配置文件RXTX_Tiger.pkg?
Linux (only x86, x86_64, ia64 here but more in the ToyBox)?
拷貝RXTXcomm.jar 文件到 /jre/lib/ext 目錄下?
拷貝librxtxSerial.so 文件到 /jre/lib/[machine type] (i386 for instance)目錄下?
并將拷貝文件釋放權限給所有用戶?
Solaris (sparc only so far)?
拷貝RXTXcomm.jar 文件到 /jre/lib/ext 目錄下?
拷貝librxtxSerial.so 文件到 /jre/lib/[machine type]目錄下?
并將拷貝文件釋放權限給所有用戶?
環境搭建好后開始寫代碼實現?


Java代碼 ?


import java.io.*; ?


import java.text.SimpleDateFormat; ?


import java.util.Date; ?


import java.util.TooManyListenersException; ?


import gnu.io.CommPortIdentifier; ?


import gnu.io.NoSuchPortException; ?


import gnu.io.PortInUseException; ?


import gnu.io.SerialPort; ?


import gnu.io.SerialPortEvent; ?


import gnu.io.SerialPortEventListener; ?


public class SerialComm implements SerialPortEventListener, Runnable ?


{ ?


public final static String PORT_OWER = "MonitorApp"; ?


private boolean isOpen; ?


private boolean isStart; ?


private boolean isSave; ?


private boolean isPrint; ?


private Thread readThread; ?


private String portName; ?


private String portAddress; ?


private CommPortIdentifier portId; ?


private SerialPort serialPort; ?


private DataInputStream inputStream; ?


private OutputStream outputStream; ?


private SimpleDateFormat formatter; ?


// prase data with process ?


private String dataProtocol; ?


private Object readWriteLock = new Object(); ?


public SerialComm() { ?


? ? ? ? isOpen = false; ?


? ? ? ? isStart = false; ?


? ? ? ? isSave = true; ?


? ? ? ? isPrint = false; ?


? ? ? ? formatter = new SimpleDateFormat("[yyyy-MM-dd hh:mm:ss,SSS]"); ?


? ? ? ? portName = "COM1"; ?


? ? ? ? portAddress = "LOCAL"; ?


? ? ? ? dataProtocol = "Gooseli"; ?


? ? } ?


public void init(String port, String protocol) throws Exception ?


? ? { ?


? ? ? ? portName = port; ?


? ? ? ? portAddress = portName; ?


? ? ? ? dataProtocol = protocol; ?


? ? ? ? init(); ?


? ? } ?


public void init(String port, String address, String protocol) throws Exception ?


? ? { ?


? ? ? ? portName = port; ?


? ? ? ? portAddress = address; ?


? ? ? ? dataProtocol = protocol; ?


? ? ? ? init(); ?


? ? } ?


public void init() throws IOException, Exception, Exception ?


? ? { ?


if (isOpen) ?


? ? ? ? { ?


? ? ? ? ? ? close(); ?


? ? ? ? } ?


try ?


? ? ? ? { ?


//傳送串口名創建CommPortIdentifier對象服務。 ?


? ? ? ? ? ? portId = CommPortIdentifier.getPortIdentifier(portName); ?


//使用portId對象服務打開串口，并獲得串口對象 ?


? ? ? ? ? ? serialPort = (SerialPort) portId.open(PORT_OWER, 2000); ?


//通過串口對象獲得讀串口流對象 ?


? ? ? ? ? ? inputStream = new DataInputStream(serialPort.getInputStream()); ?


//通過串口對象獲得寫串口流對象 ?


? ? ? ? ? ? outputStream = serialPort.getOutputStream(); ?


? ? ? ? ? ? isOpen = true; ?


? ? ? ? } catch (NoSuchPortException ex) ?


? ? ? ? { ?


throw new Exception(ex.toString()); ?


? ? ? ? } catch (PortInUseException ex) ?


? ? ? ? { ?


throw new Exception(ex.toString()); ?


? ? ? ? } ?


? ? } ?


public void start() throws Exception ?


? ? { ?


if (!isOpen) ?


? ? ? ? { ?


throw new Exception(portName + " has not been opened."); ?


? ? ? ? } ?


try ?


? ? ? ? { ?


//創建對象線程 ?


? ? ? ? ? ? readThread = new Thread(this); ?


? ? ? ? ? ? readThread.start(); ?


//設置串口數據時間有效 ?


? ? ? ? ? ? serialPort.notifyOnDataAvailable(true); ?


//增加監聽 ?


? ? ? ? ? ? serialPort.addEventListener(this); ?


? ? ? ? ? ? isStart = true; ?


? ? ? ? } catch (TooManyListenersException ex) ?


? ? ? ? { ?


throw new Exception(ex.toString()); ?


? ? ? ? } ?


? ? } ?


public void run() ?


? ? { ?


? ? ? ? String at = "at^hcmgr=1\r"; ?


? ? ? ? String strTemp = at + (char) Integer.parseInt("1a", 16) + "z"; ?


? ? ? ? writeComm(strTemp); ?


? ? ? ? isPrint = true; ?


? ? } ?


public void stop() ?


? ? { ?


if (isStart) ?


? ? ? ? { ?


? ? ? ? ? ? serialPort.notifyOnDataAvailable(false); ?


? ? ? ? ? ? serialPort.removeEventListener(); ?


? ? ? ? ? ? isStart = false; ?


? ? ? ? } ?


? ? } ?


public void close() ?


? ? { ?


? ? ? ? stop(); ?


if (isOpen) ?


? ? ? ? { ?


try ?


? ? ? ? ? ? { ?


? ? ? ? ? ? ? ? inputStream.close(); ?


? ? ? ? ? ? ? ? outputStream.close(); ?


? ? ? ? ? ? ? ? serialPort.close(); ?


? ? ? ? ? ? ? ? isOpen = false; ?


? ? ? ? ? ? } catch (IOException ex) ?


? ? ? ? ? ? { ?


? ? ? ? ? ? } ?


? ? ? ? } ?


? ? } ?


//如果串口有數據上報則主動調用此方法 ?


public void serialEvent(SerialPortEvent event) ?


? ? { ?


switch (event.getEventType()) ?


? ? ? ? { ?


case SerialPortEvent.BI: ?


case SerialPortEvent.OE: ?


case SerialPortEvent.FE: ?


case SerialPortEvent.PE: ?


case SerialPortEvent.CD: ?


case SerialPortEvent.CTS: ?


case SerialPortEvent.DSR: ?


case SerialPortEvent.RI: ?


case SerialPortEvent.OUTPUT_BUFFER_EMPTY: ?


break; ?


case SerialPortEvent.DATA_AVAILABLE: ?


? ? ? ? ? ? readComm(); ?


break; ?


default: ?


break; ?


? ? ? ? } ?


? ? } ?


public void readComm() ?


? ? { ?


? ? ? ? StringBuffer readBuffer = new StringBuffer(); ?


? ? ? ? String scannedInput = ""; ?


? ? ? ? Date currentTime = null; ?


? ? ? ? String TimeStamp = ""; ?


int c; ?


char a; ?


try ?


? ? ? ? { ?


? ? ? ? ? ? InputStreamReader fis = new InputStreamReader(inputStream, "utf-8"); ?


while ((c = fis.read()) != -1) ?


? ? ? ? ? ? { ?


? ? ? ? ? ? ? ? readBuffer.append((char) c); ?


? ? ? ? ? ? } ?


? ? ? ? ? ? scannedInput = readBuffer.toString().trim(); ?


? ? ? ? ? ? currentTime = new Date(); ?


? ? ? ? ? ? TimeStamp = formatter.format(currentTime); ?


? ? ? ? } catch (IOException ex) ?


? ? ? ? { ?


? ? ? ? ? ? ex.printStackTrace(); ?


? ? ? ? } catch (Exception ex) ?


? ? ? ? { ?


? ? ? ? ? ? ex.printStackTrace(); ?


? ? ? ? } ?


? ? } ?


public void writeComm(String outString) ?


? ? { ?


synchronized (readWriteLock) ?


? ? ? ? { ?


try ?


? ? ? ? ? ? { ?


? ? ? ? ? ? ? ? outputStream.write(outString.getBytes()); ?


? ? ? ? ? ? } catch (IOException ex) ?


? ? ? ? ? ? { ?


? ? ? ? ? ? } ?


? ? ? ? } ?


? ? } ?


public static void main(String[] args) ?


? ? { ?


? ? ? ? SerialComm serialcomm = new SerialComm(); ?


try ?


? ? ? ? { ?


? ? ? ? ? ? serialcomm.init("COM3", "Air");// windows下測試端口 ?


// serialcomm.init("/dev/ttyUSB0", "Air");//linux下測試端口 ?


? ? ? ? ? ? serialcomm.start(); ?


? ? ? ? } catch (Exception ex) ?


? ? ? ? { ?


? ? ? ? } ?


? ? } ?


}

總結

以上是生活随笔為你收集整理的java开发串口步骤的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。