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

Posted 2023-01-11 特立独行的猫a

前言

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)-爱码网