使用RXTX实现串口通讯准备工作
编写Java代码实现串口通讯,使用开源代码RXTX非常方便,下面对环境的配置留下一些痕迹,方便以后查看。
1.下载 rxtx-2.1-7-bins-r2.zip.
2.解压.
3.拷贝 rxtxSerial.dll 到你的 c:/program files/java/jre-version/bin 目录下.
4.拷贝 RXTXcomm.jar 到你的 c:/program files/java/jre-version/lib/ext 目录下.
环境搭建完毕,附上测试代码
package rxtx.test;import gnu.io.CommPortIdentifier;import gnu.io.NoSuchPortException;import gnu.io.PortInUseException;import gnu.io.SerialPort;import gnu.io.SerialPortEvent;import gnu.io.SerialPortEventListener;import gnu.io.UnsupportedCommOperationException;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.util.Enumeration;import java.util.TooManyListenersException;public class CommUtil implements SerialPortEventListener{SerialPort port = null;InputStream input;OutputStream output;CommPortIdentifier cpi;public CommUtil(Enumeration portList, String name){try {cpi=CommPortIdentifier.getPortIdentifier(name.toUpperCase());port=(SerialPort) cpi.open("My"+name, 2000);} catch (PortInUseException e) {System.out.println(e);} catch (NoSuchPortException e) {e.printStackTrace();}try {input=port.getInputStream();output=port.getOutputStream();} catch (IOException e) {e.printStackTrace();}try {port.addEventListener(this);} catch (TooManyListenersException e) {e.printStackTrace();}port.notifyOnDataAvailable(true);try {port.setSerialPortParams(2400, SerialPort.DATABITS_8, // 设置串口读写参数SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);} catch (UnsupportedCommOperationException e) {e.printStackTrace();}}@Overridepublic 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:System.out.println("神马都是浮云");break;case SerialPortEvent.DATA_AVAILABLE:byte[] readBuffer = new byte[20];try {while (input.available() > 0) {System.out.println(input.available());int numBytes = input.read(readBuffer);System.out.println(numBytes);}send("receive");System.out.println(new String(readBuffer).trim());} catch (IOException e) {e.printStackTrace();}break;}}public void send(String content){try {output.write(content.getBytes());} catch (IOException e) {e.printStackTrace();}}public void send(OutputStream os,String content){try {os.write(content.getBytes());} catch (IOException e) {e.printStackTrace();}}public void closePort() {if (port != null) {port.close();}}public static void main(String[] args) {Enumeration en = CommPortIdentifier.getPortIdentifiers(); CommUtil comm = new CommUtil(en, "com3");comm.send("hello");}}