前言
Java串口通信,串口读写卡工具介绍。这里介绍下自己做的一个java版串口读写卡工具。
RXTXcomm.jar这个串口库很赞!32位或者64位系统都能用。之前一直使用的是sun提供的comm.jar,且用他做了个读写卡测卡工具,结果只有32位系统下能用。
后来我发现了RXTX,且接口和comm.jar提供的几乎一模一样,只是包名不一样。这样我的工具不用大改,直接重新打包下就能用啦。建议使用java做串口通信的优先推荐使用RXTX这个包。
工具介绍
调试一个卡片消费,咋样最快?咋样效率最高?敲代码编译下载然后再反复的测试吗?当然是得有利器了。这里我使用一个自己制作的工具来完整卡片的读写和消费验证。这个工具使用了java的串口通信。
工具截图,工具源码下载地址:
RXTX库介绍
RXTX是一个提供串口和并口通信的开源java类库,由该项目发布的文件均遵循LGPL协议。
RXTX项目提供了Windows,Linux,Mac os X,Solaris操作系统下的兼容javax.comm串口通讯包API的实现,为其他开发人员在此类系统下开发串口应用提供了相当的方便。
RXTX的使用上与sun提供的comm.jar基本相同,编程时最明显的不同是要包含的包名由javax.comm.*改成了gnu.io.*
RxtxAPI 的核心是抽象的CommPort类(用于描述一个被底层系统支持的端口的抽象类,它包含一些高层的IO控制方法,这些方法对于所有不同的通讯端口来说是通用的)及其两个子类:SerialPort类和ParallePort类。其中,SerialPort类是用于串口通信的类,ParallePort类是用于并行口通信的类。CommPort类还提供了常规的通信模式和方法,例如:getInputStream( )方法和getOutputStream( )方法,专用于与端口上的设备进行通信。
使用也很方便,
RXTX的下载及配置
mfz-rxtx-2.2-20081207-win-x64
下载地址:mfz-rxtx-2.2-20081207-win-x64-Java工具类资源-CSDN下载
java的串口API包:javax.comm在windows下的开法维护已经停止了,RXTX的旧版本支持在javax.comm-win32-2.0基础上的扩展,RXTX新版本支持对javax.comm的覆盖式支持,原来用javax.comm的把所有import javax.comm.*改成import gnu.io.*即可。
支持不同系统的RXTX包下载地址:RXTX for Java
解压后把mfz-rxtx-2.2-20081207-win-x64文件夹下的rxtxSerial.dll放到%JAVA_HOME%\jre\bin和C:\Windows\System32下面。
RXTX的使用
RXTXComm.jar的API文档
首先确定你安装的JDK的位数,安装相应位数的jar包。
将rxtxSerial.dll、rxtxParallel.dll复制到<JAVA_HOME>\jre\bin目录下
将RXTXcomm.jar复制到<JAVA_HOME>\jre\lib\ext目录下
到eclipse中右击项目--->Build Path---> Configure Build Path --> Libraries --> Add External JARs...--->找到<JAVA_HOME>/jre/lib/ext目录下的RXTXcomm.jar--->打开-->OK。
再一款功能强大的串口调试软件,Access Port For Win7。
下载地址:AccessPort下载_AccessPort官方最新版下载【系统工具】-华军软件园
串口操作源码
package javaapplication1; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.Enumeration; import java.util.TooManyListenersException; import java.util.ArrayList; import gnu.io.CommPortIdentifier; import gnu.io.PortInUseException; import gnu.io.SerialPort; import gnu.io.SerialPortEvent; import gnu.io.SerialPortEventListener; import gnu.io.UnsupportedCommOperationException; /** * @项目名称 :illegalsms * @文件名称 :SerialPort.java * @所在包 :org.serial * @功能描述 : * 串口类 * @创建者 : * @创建日期 :2012-9-13 * @修改记录 : */ public class DSerialPort implements Runnable, SerialPortEventListener { private String appName = "串口通讯测试"; private int timeout = 0;//open 端口时的等待时间 private int threadTime = 0; public ArrayList listPort; public StringBuilder recvStr; private CommPortIdentifier commPort; private SerialPort serialPort; private InputStream inputStream; private OutputStream outputStream; public javax.swing.JTextArea jTshow; public javax.swing.JTextArea jTlog; public byte[] recvdata; public DSerialPort() { listPort=new ArrayList(); recvStr=new StringBuilder(); } /** * @方法名称 :listPort * @功能描述 :列出所有可用的串口 * @返回值类型 :void */ @SuppressWarnings("rawtypes") public void listPort(){ CommPortIdentifier cpid; Enumeration en = CommPortIdentifier.getPortIdentifiers(); log("now to list all Port of this PC:" +en); while(en.hasMoreElements()){ cpid = (CommPortIdentifier)en.nextElement(); if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL){ log(cpid.getName() + ", " + cpid.getCurrentOwner()); listPort.add(cpid.getName()); } } } /** * @方法名称 :selectPort * @功能描述 :选择一个端口,比如:COM1 * @返回值类型 :void * @param portName */ @SuppressWarnings("rawtypes") public boolean selectPort(String portName){ this.commPort = null; CommPortIdentifier cpid; Enumeration en = CommPortIdentifier.getPortIdentifiers(); while(en.hasMoreElements()){ cpid = (CommPortIdentifier)en.nextElement(); if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL && cpid.getName().equals(portName)){ this.commPort = cpid; break; } } return openPort(); } /** * @方法名称 :openPort * @功能描述 :打开SerialPort * @返回值类型 :void */ private boolean openPort(){ if(commPort == null) { log(String.format("无法找到名字为'%1$s'的串口!", commPort.getName())); return false; } else{ log("端口选择成功,当前端口:"+commPort.getName()+",现在实例化 SerialPort:"); try{ serialPort = (SerialPort)commPort.open(appName, timeout); log("实例 SerialPort 成功!"); // return true; }catch(PortInUseException e){ log(String.format("端口'%1$s'正在使用中!", commPort.getName())); return false; } try { serialPort.setSerialPortParams(115200, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); //serialPort. } catch(UnsupportedCommOperationException e) { log(String.format("端口'%1$s'参数不合法!", commPort.getName())); return false; } return true; } } /** * @方法名称 :checkPort * @功能描述 :检查端口是否正确连接 * @返回值类型 :void */ private void checkPort(){ if(commPort == null) throw new RuntimeException("没有选择端口,请使用 " + "selectPort(String portName) 方法选择端口"); if(serialPort == null){ throw new RuntimeException("SerialPort 对象无效!"); } } /** * @方法名称 :write * @功能描述 :向端口发送数据,请在调用此方法前 先选择端口,并确定SerialPort正常打开! * @返回值类型 :void * @param message */ public void write(String message) { checkPort(); try{ outputStream = new BufferedOutputStream(serialPort.getOutputStream()); }catch(IOException e){ throw new RuntimeException("获取端口的OutputStream出错:"+e.getMessage()); } try{ outputStream.write(message.getBytes()); log("信息发送成功!"); }catch(IOException e){ throw new RuntimeException("向端口发送信息时出错:"+e.getMessage()); }finally{ try{ outputStream.close(); }catch(Exception e){ } } } /** * @方法名称 :startRead * @功能描述 :开始监听从端口中接收的数据 * @返回值类型 :void * @param time 监听程序的存活时间,单位为秒,0 则是一直监听 */ public void startRead(int time){ checkPort(); try{ inputStream = new BufferedInputStream(serialPort.getInputStream()); }catch(IOException e){ throw new RuntimeException("获取端口的InputStream出错:"+e.getMessage()); } try{ serialPort.addEventListener(this); }catch(TooManyListenersException e){ throw new RuntimeException(e.getMessage()); } serialPort.notifyOnDataAvailable(true); log(String.format("开始监听来自'%1$s'的数据--------------", commPort.getName())); if(time > 0){ this.threadTime = time*1000; Thread t = new Thread(this); t.start(); log(String.format("监听程序将在%1$d秒后关闭。。。。", threadTime)); } } /** * @方法名称 :close * @功能描述 :关闭 SerialPort * @返回值类型 :void */ public void close(){ if(serialPort!=null) { serialPort.close(); serialPort = null; commPort = null; } } /** * * @param msg */ public void log(String msg){ System.out.println(appName+" --> "+msg); } public void log2(String msg){ System.out.println(appName+" --> "+msg); } /** * 数据接收的监听处理函数 */ @Override public void serialEvent(SerialPortEvent arg0) { switch(arg0.getEventType()){ case SerialPortEvent.BI:/*Break interrupt,通讯中断*/ case SerialPortEvent.OE:/*Overrun error,溢位错误*/ case SerialPortEvent.FE:/*Framing error,传帧错误*/ case SerialPortEvent.PE:/*Parity error,校验错误*/ case SerialPortEvent.CD:/*Carrier detect,载波检测*/ case SerialPortEvent.CTS:/*Clear to send,清除发送*/ case SerialPortEvent.DSR:/*Data set ready,数据设备就绪*/ case SerialPortEvent.RI:/*Ring indicator,响铃指示*/ case SerialPortEvent.OUTPUT_BUFFER_EMPTY:/*Output buffer is empty,输出缓冲区清空*/ break; case SerialPortEvent.DATA_AVAILABLE:/*Data available at the serial port,端口有可用数据。读到缓冲数组,输出到终端*/ byte[] readBuffer = new byte[1024]; int readDataLength = 0; String s2 ; try { while (inputStream.available() > 0) { readDataLength=inputStream.read(readBuffer); //readStr += new String(readBuffer).trim(); } // 将真实数据保存到零时数组中 recvdata = new byte[readDataLength]; System.arraycopy(readBuffer, 0, recvdata, 0, readDataLength); s2 = new String(readBuffer).substring(0, readDataLength); jTshow.append(s2.toUpperCase()); jTshow.setCaretPosition(jTshow.getText().length()); recvStr.append(s2); String str; str = ""; for(int i=0;i<readDataLength;i++) { str+= String.format("%02x ",recvdata[i]) ; } jTlog.append("-->接收到端口返回数据(长度为"+readDataLength+"):"+str.toUpperCase() +"\r\n"); jTlog.setCaretPosition(jTlog.getText().length()); log2("接收到端口返回数据(长度为"+readDataLength+"):"+s2); log2(s2); } catch (IOException e) { } } } @Override public void run() { try{ Thread.sleep(threadTime); serialPort.close(); log(String.format("端口''监听关闭了!", commPort.getName())); }catch(Exception e){ } } }
引用
我的小工具,java版串口读写卡测试工具_特立独行的猫a的博客-CSDN博客