工作过程中，经常需要和卡片打交道，如何快速的读写卡，提高些工作效率呢？业余时间，搞了个读写卡测试工具，
通过串口操作读卡器。我把车载机改造为串口的读卡器，配合这个工具就可以使用了。如果有网友想使用这个工具，得自己
做个下位机读卡器了。指令是透传的，监控发出来的指令就可以做个下位机。可在我的资源中下载使用（通过工具打包成exe了，若运行不起来注意java的环境配置）。我的qq534117529
先附个截图：
1.准备工作：
首先到SUN官网下载一个zip包：javacomm20-win32.zip
其中重要的有这几个文件：
win32com.dll
comm.jar
javax.comm.properties
2.按照说明配置好环境,如下：
将win32com.dll复制到<JDK>\bin目录下；将comm.jar复制到<JDK>\lib；把 javax.comm.properties也同样拷贝到<JDK>\lib目录下。然而在真正运行使用串口包的时候，仅作这些是不够的。因 为通常当运行“java MyApp”的时候，是由JRE下的虚拟机启动MyApp的。而我们只复制上述文件到JDK相应目录下，所以应用程序将会提示找不到串口。解决这个问题的 方法很简单，我们只须将上面提到的文件放到JRE相应的目录下就可以了
到这一个可以java 串口开发环境就搭建完成了。
串口读写代码
CommPortIdentifier portID = CommPortIdentifier.getPortIdentifier(com);//1，先拿到Identifier //其中com是String类型的，传入的是串口名com="COM1"; SerialPort port = (SerialPort)portID.open("MyComm", 100000000);//2,打开串口 //"MyComm"是串口名，100000000是串口过期时间（ms）。 port.setSerialPortParams(rate, databits,stopbit, parity);//3，设置串口属性 //rate 波特率（默认9600），databits载波位（默认8），stopbit停止位（默认1），parity校验位（默认0无校验） port.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);//4（可选）设置数据流控制模式，默认为无 port.close();//关闭串口
3、串口读入写出流。
OutputStream os=port.getOutputStream();//拿到写出流。写出流就随便写就行。 port.getOutputStream().flush();//写完要记得做一次冲一下缓冲区 InputStream is= port.getInputStream();//拿到读入流。 is.read();//每次读入一个int，这个是个阻塞函数，在无数据的时候会中断。
4、串口读入轮询模式
一种读取的方式是每次做
byte b[]=new byte[1024]; is.read(b);
如果返回的是-1表示无数据。可以中断几毫秒然后再去读。
比较低效的一种读取模式，但是在使用阻塞函数的时候还是很好用的。
5、串口的监听模式
//5.1首先建立监听类 public class CommListener implements SerialPortEventListener //继承自javax.comm.SerialPortEventListener; //实现监听方法public void serialEvent(SerialPortEvent arg0){} 当有新数据进入的时候会被调用，传入javax.comm.SerialPortEvent对象参数。 if (arg0.getEventType()==SerialPortEvent.DATA_AVAILABLE)//如果是有效数据的话就做read { //read(); } //5.2建立好监听类以后要在port上添加。 port.addEventListener(commListener); //其中port是上文打开的串口端口，commListener是上文的监听器实例 port.notifyOnDataAvailable(true);//设置监听模式为当有数据到达时唤醒监听线程。
要想更好的使用串口，最好再对comm.jar的串口包在封装出来一个串口类。
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 javax.comm.CommPortIdentifier; import javax.comm.PortInUseException; import javax.comm.SerialPort; import javax.comm.SerialPortEvent; import javax.comm.SerialPortEventListener; import javax.comm.UnsupportedCommOperationException; /** * @项目名称 :illegalsms * @文件名称 :SerialPort.java * @所在包 :org.serial * @功能描述 : * @创建者 : * @创建日期 : * @修改记录 : */ public class DSerialPort implements Runnable, SerialPortEventListener { private String appName = "串口通讯测试"; private int timeout = 0;//open 端口时的等待时间 private int threadTime = 0; public ArrayList listPort; public String revStr=""; public String revStr1=""; private CommPortIdentifier commPort; private SerialPort serialPort; private InputStream inputStream; private OutputStream outputStream; public DSerialPort() { listPort=new ArrayList(); } /** * @方法名称 :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); } 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]; String readStr=""; String s2 = ""; revStr=""; try { while (inputStream.available() > 0) { inputStream.read(readBuffer); readStr += new String(readBuffer).trim(); } s2 = new String(readBuffer).trim(); revStr=s2; revStr1="接收到端口返回数据(长度为"+readStr.length()+")："+readStr; //log2("接收到端口返回数据(长度为"+readStr.length()+")："+readStr); log2(s2); } catch (IOException e) { } } } @Override public void run() { try{ Thread.sleep(threadTime); serialPort.close(); log(String.format("端口''监听关闭了！", commPort.getName())); }catch(Exception e){ e.printStackTrace(); } } }
