本文實(shí)例為大家分享了Java使用開(kāi)源Rxtx實(shí)現(xiàn)串口通訊的具體代碼，供大家參考，具體內(nèi)容如下
使用方法：
windows平臺(tái)：
1、把rxtxParallel.dll、rxtxSerial.dll拷貝到：C:/WINDOWS/system32下。
2、如果是在開(kāi)發(fā)的時(shí)候(JDK),需要把RXTXcomm.jar、rxtxParallel.dll、rxtxSerial.dll拷貝到../jre.../lib/ext下；如：D:/Program Files/Java/jre1.6.0_02/lib/ext
3、而且需要把項(xiàng)目1.右鍵->2.Preperties(首選項(xiàng))->3.Java Build Path->4.Libraries->5.展開(kāi)RXTXcomm.jar->6.Native library location:(None)->7.瀏覽External Folder(選擇至該項(xiàng)目的lib文件夾，如：E:/Item/MyItem/WebRoot/WEB-INF/lib).
import gnu.io.*;import java.io.*; import java.util.*; import com.call.dao.*; public class SerialReader extends Observable implements Runnable,SerialPortEventListener { static CommPortIdentifier portId; int delayRead = 100; int numBytes; // buffer中的實(shí)際數(shù)據(jù)字節(jié)數(shù) private static byte[] readBuffer = new byte[1024]; // 4k的buffer空間,緩存串口讀入的數(shù)據(jù) static Enumeration portList; InputStream inputStream; OutputStream outputStream; static SerialPort serialPort; HashMap serialParams; Thread readThread;//本來(lái)是static類(lèi)型的 //端口是否打開(kāi)了 boolean isOpen = false; // 端口讀入數(shù)據(jù)事件觸發(fā)后,等待n毫秒后再讀取,以便讓數(shù)據(jù)一次性讀完 public static final String PARAMS_DELAY = "delay read"; // 延時(shí)等待端口數(shù)據(jù)準(zhǔn)備的時(shí)間 public static final String PARAMS_TIMEOUT = "timeout"; // 超時(shí)時(shí)間 public static final String PARAMS_PORT = "port name"; // 端口名稱(chēng) public static final String PARAMS_DATABITS = "data bits"; // 數(shù)據(jù)位 public static final String PARAMS_STOPBITS = "stop bits"; // 停止位 public static final String PARAMS_PARITY = "parity"; // 奇偶校驗(yàn) public static final String PARAMS_RATE = "rate"; // 波特率 public boolean isOpen(){ return isOpen; } /** * 初始化端口操作的參數(shù). * @throws SerialPortException * * @see */ public SerialReader() { isOpen = false; } public void open(HashMap params) { serialParams = params; if(isOpen){ close(); } try { // 參數(shù)初始化 int timeout = Integer.parseInt( serialParams.get( PARAMS_TIMEOUT ) .toString() ); int rate = Integer.parseInt( serialParams.get( PARAMS_RATE ) .toString() ); int dataBits = Integer.parseInt( serialParams.get( PARAMS_DATABITS ) .toString() ); int stopBits = Integer.parseInt( serialParams.get( PARAMS_STOPBITS ) .toString() ); int parity = Integer.parseInt( serialParams.get( PARAMS_PARITY ) .toString() ); delayRead = Integer.parseInt( serialParams.get( PARAMS_DELAY ) .toString() ); String port = serialParams.get( PARAMS_PORT ).toString(); // 打開(kāi)端口 portId = CommPortIdentifier.getPortIdentifier( port ); serialPort = ( SerialPort ) portId.open( "SerialReader", timeout ); inputStream = serialPort.getInputStream(); serialPort.addEventListener( this ); serialPort.notifyOnDataAvailable( true ); serialPort.setSerialPortParams( rate, dataBits, stopBits, parity ); isOpen = true; } catch ( PortInUseException e ) { // 端口"+serialParams.get( PARAMS_PORT ).toString()+"已經(jīng)被占用"; } catch ( TooManyListenersException e ) { //"端口"+serialParams.get( PARAMS_PORT ).toString()+"監(jiān)聽(tīng)者過(guò)多"; } catch ( UnsupportedCommOperationException e ) { //"端口操作命令不支持"; } catch ( NoSuchPortException e ) { //"端口"+serialParams.get( PARAMS_PORT ).toString()+"不存在"; } catch ( IOException e ) { //"打開(kāi)端口"+serialParams.get( PARAMS_PORT ).toString()+"失敗"; } serialParams.clear(); Thread readThread = new Thread( this ); readThread.start(); } public void run() { try { Thread.sleep(50); } catch ( InterruptedException e ) { } } public void start(){ try { outputStream = serialPort.getOutputStream(); } catch (IOException e) {} try{ readThread = new Thread(this); readThread.start(); } catch (Exception e) { } } //start() end public void run(String message) { try { Thread.sleep(4); } catch (InterruptedException e) { } try { if(message!=null&&message.length()!=0) { System.out.println("run message:"+message); outputStream.write(message.getBytes()); } } catch (IOException e) {} } public void close() { if (isOpen) { try { serialPort.notifyOnDataAvailable(false); serialPort.removeEventListener(); inputStream.close(); serialPort.close(); isOpen = false; } catch (IOException ex) { //"關(guān)閉串口失敗"; } } } public void serialEvent( SerialPortEvent event ) { try { Thread.sleep( delayRead ); } catch ( InterruptedException e ) { e.printStackTrace(); } switch ( event.getEventType() ) { case SerialPortEvent.BI: // 10 case SerialPortEvent.OE: // 7 case SerialPortEvent.FE: // 9 case SerialPortEvent.PE: // 8 case SerialPortEvent.CD: // 6 case SerialPortEvent.CTS: // 3 case SerialPortEvent.DSR: // 4 case SerialPortEvent.RI: // 5 case SerialPortEvent.OUTPUT_BUFFER_EMPTY: // 2 break; case SerialPortEvent.DATA_AVAILABLE: // 1 try { // 多次讀取,將所有數(shù)據(jù)讀入 while (inputStream.available() > 0) { numBytes = inputStream.read(readBuffer); } //打印接收到的字節(jié)數(shù)據(jù)的ASCII碼 for(int i=0;i<numBytes;i++){ // System.out.println("msg[" + numBytes + "]: [" +readBuffer[i] + "]:"+(char)readBuffer[i]); }// numBytes = inputStream.read( readBuffer ); changeMessage( readBuffer, numBytes ); } catch ( IOException e ) { e.printStackTrace(); } break; } } // 通過(guò)observer pattern將收到的數(shù)據(jù)發(fā)送給observer // 將buffer中的空字節(jié)刪除后再發(fā)送更新消息,通知觀察者 public void changeMessage( byte[] message, int length ) { setChanged(); byte[] temp = new byte[length]; System.arraycopy( message, 0, temp, 0, length ); notifyObservers( temp ); } static void listPorts() { Enumeration portEnum = CommPortIdentifier.getPortIdentifiers(); while ( portEnum.hasMoreElements() ) { CommPortIdentifier portIdentifier = ( CommPortIdentifier ) portEnum .nextElement(); } } public void openSerialPort(String message) { HashMap<String, Comparable> params = new HashMap<String, Comparable>(); otherDAO odao=new otherDAO(); String port=odao.selectNumberById(15); String rate = "9600"; String dataBit = ""+SerialPort.DATABITS_8; String stopBit = ""+SerialPort.STOPBITS_1; String parity = ""+SerialPort.PARITY_NONE; int parityInt = SerialPort.PARITY_NONE; params.put( SerialReader.PARAMS_PORT, port ); // 端口名稱(chēng) params.put( SerialReader.PARAMS_RATE, rate ); // 波特率 params.put( SerialReader.PARAMS_DATABITS,dataBit ); // 數(shù)據(jù)位 params.put( SerialReader.PARAMS_STOPBITS, stopBit ); // 停止位 params.put( SerialReader.PARAMS_PARITY, parityInt ); // 無(wú)奇偶校驗(yàn) params.put( SerialReader.PARAMS_TIMEOUT, 100 ); // 設(shè)備超時(shí)時(shí)間 1秒 params.put( SerialReader.PARAMS_DELAY, 100 ); // 端口數(shù)據(jù)準(zhǔn)備時(shí)間 1秒 try { open(params);//打開(kāi)串口 LoginFrame cf=new LoginFrame(); addObserver(cf); if(message!=null&&message.length()!=0) { String str=""; for(int i=0;i<10;i++) { str+=message; } start(); run(str); } } catch (Exception e) { } } static String getPortTypeName( int portType ) { switch ( portType ) { case CommPortIdentifier.PORT_I2C: return "I2C"; case CommPortIdentifier.PORT_PARALLEL: return "Parallel"; case CommPortIdentifier.PORT_RAW: return "Raw"; case CommPortIdentifier.PORT_RS485: return "RS485"; case CommPortIdentifier.PORT_SERIAL: return "Serial"; default: return "unknown type"; } } public HashSet<CommPortIdentifier> getAvailableSerialPorts()//本來(lái)static { HashSet<CommPortIdentifier> h = new HashSet<CommPortIdentifier>(); Enumeration thePorts = CommPortIdentifier.getPortIdentifiers(); while ( thePorts.hasMoreElements() ) { CommPortIdentifier com = ( CommPortIdentifier ) thePorts .nextElement(); switch ( com.getPortType() ) { case CommPortIdentifier.PORT_SERIAL: try { CommPort thePort = com.open( "CommUtil", 50 ); thePort.close(); h.add( com ); } catch ( PortInUseException e ) { System.out.println( "Port, " + com.getName() + ", is in use." ); } catch ( Exception e ) { System.out.println( "Failed to open port " + com.getName() + e ); } } } return h; }} //ASCII表//-------------------------------------------------------------// ASCII Characters // //Dec Hex Char Code Dec Hex Char// //0 0 NUL 64 40 @//1 1 SOH 65 41 A//2 2 STX 66 42 B//3 3 ETX 67 43 C//4 4 EOT 68 44 D//5 5 ENQ 69 45 E//6 6 ACK 70 46 F//7 7 BEL 71 47 G//8 8 BS 72 48 H//9 9 HT 73 49 I//10 0A LF 74 4A J//11 0B VT 75 4B K//12 0C FF 76 4C L//13 0D CR 77 4D M//14 0E SO 78 4E N//15 0F SI 79 4F O//16 10 SLE 80 50 P//17 11 CS1 81 51 Q//18 12 DC2 82 52 R//19 13 DC3 83 53 S//20 14 DC4 84 54 T//21 15 NAK 85 55 U//22 16 SYN 86 56 V//23 17 ETB 87 57 W//24 18 CAN 88 58 X//25 19 EM 89 59 Y//26 1A SIB 90 5A Z//27 1B ESC 91 5B [// 92 5C ///28 1C FS 93 5D ]//29 1D GS 94 5E ^//30 1E RS 95 5F _//31 1F US 96 60 `//32 20 (space) 97 61 a//33 21 ! 98 62 b//34 22 " // 99 63 c//35 23 # 100 64 d//36 24 $ //37 25 % 101 65 e//38 26 & 102 66 f//39 27 ' 103 67 g//40 28 ( 104 68 h//41 29 ) 105 69 i//42 2A * 106 6A j//43 2B + 107 6B k//44 2C , 108 6C l//45 2D - 109 6D m//46 2E . 110 6E n//47 2F / 111 6F o//48 30 0 112 70 p//49 31 1 113 72 q//50 32 2 114 72 r//51 33 3 115 73 s//52 34 4 116 74 t//53 35 5 117 75 u//54 36 6 118 76 v//55 37 7 119 77 w//56 38 8 120 78 x//57 39 9 121 79 y//58 3A : 122 7A z//59 3B ; 123 7B {//60 3C < 124 7C |//61 3D = 125 7D }//62 3E > 126 7E ~//63 3F ? 127 7F 以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持VeVb武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
