Java串口通信,串口读写卡工具介绍

简介: Java串口通信,串口读写卡工具介绍

前言


Java串口通信,串口读写卡工具介绍。这里介绍下自己做的一个java版串口读写卡工具。


RXTXcomm.jar这个串口库很赞!32位或者64位系统都能用。之前一直使用的是sun提供的comm.jar,且用他做了个读写卡测卡工具,结果只有32位系统下能用。


后来我发现了RXTX,且接口和comm.jar提供的几乎一模一样,只是包名不一样。这样我的工具不用大改,直接重新打包下就能用啦。建议使用java做串口通信的优先推荐使用RXTX这个包。


工具介绍


调试一个卡片消费,咋样最快?咋样效率最高?敲代码编译下载然后再反复的测试吗?当然是得有利器了。这里我使用一个自己制作的工具来完整卡片的读写和消费验证。这个工具使用了java的串口通信。


工具截图,工具源码下载地址:


java串口读写卡工具-Java代码类资源-CSDN下载



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博客


Java串口编程学习1-环境配置(64位Win7)-爱码网

相关文章
|
3月前
|
数据采集 编解码 Java
解锁Hutool魔法箱:Java开发者不可错过的神奇工具集
解锁Hutool魔法箱:Java开发者不可错过的神奇工具集
63 0
|
3月前
|
缓存 监控 Java
线程池的魔法:Java 开发者必备的并发工具
线程池的魔法:Java 开发者必备的并发工具
47 0
|
2月前
|
Java
java中日期处理的一些工具方法
java中日期处理的一些工具方法
18 1
|
2天前
|
算法 安全 Java
性能工具之 JMeter 自定义 Java Sampler 支持国密 SM2 算法
【4月更文挑战第28天】性能工具之 JMeter 自定义 Java Sampler 支持国密 SM2 算法
14 1
性能工具之 JMeter 自定义 Java Sampler 支持国密 SM2 算法
|
3天前
|
Arthas 监控 IDE
去哪儿网开源的一个对应用透明,无侵入的Java应用诊断工具
今天 V 哥给大家带来一款开源工具Bistoury,Bistoury 是去哪儿网开源的一个对应用透明,无侵入的java应用诊断工具,用于提升开发人员的诊断效率和能力。
|
4天前
|
Java
Java快读写法
Java快读写法
9 3
|
24天前
|
IDE Java 开发工具
Lombok 详解:简化 Java 开发的神奇工具
Lombok 是一款 Java 工具,通过注解自动处理如 getter/setter、toString、equals 和 hashCode 等常见代码,减少样板代码。安装 Lombok 需要在 IDE(如 IntelliJ IDEA)中添加插件,并在 Maven 或 Gradle 项目中配置依赖。常用注解包括 @Getter/@Setter 生成访问器,@ToString 生成对象描述,@EqualsAndHashCode 生成比较方法,@NoArgsConstructor/@AllArgsConstructor 生成构造器,@Data 综合应用这些注解。
112 9
|
1月前
|
监控 Java
Java项目jar性能监控工具CPU内存等
Java项目jar性能监控工具CPU内存等
12 0
|
2月前
|
XML 缓存 Java
Java程序读写性能提升和数据一致性的总结
Java程序读写性能提升和数据一致性的总结
11 1