Java串口读卡器工具通信之RXTX

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() +"rn");
                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){
		}
	}
}