飘零的代码 piao2010 ’s blog

 
package com;
 
import   java.io.*; 
 
import   java.util.*; 
 
import   javax.comm.*; 
 
public   class   SimpleRead   implements   Runnable,   SerialPortEventListener   { 
 
        static   CommPortIdentifier   portId; 
 
        static   Enumeration   portList; 
 
        InputStream   inputStream; 
 
        OutputStream   outputStream; 
 
        SerialPort   serialPort; 
 
        Thread   readThread; 
 
        public   static void main(String[] args) { 
 
      portList = CommPortIdentifier.getPortIdentifiers(); 
 
      while (portList.hasMoreElements()) { 
 
        portId = (CommPortIdentifier) portList.nextElement(); 
 
        if (portId.getPortType()==CommPortIdentifier.PORT_SERIAL) { 
 
            if (portId.getName().equals( "COM4")) { 
 
              SimpleRead reader = new SimpleRead(); 
 
            } 
 
        } 
 
      } 
 
    } 
 
    public SimpleRead() { 
 
      try {//打开串口COM1 
 
        serialPort = (SerialPort) portId.open( "SimpleReadApp ", 2000); 
 
      } catch (PortInUseException e) {} 
 
      try {//获得输入输出流 
 
        inputStream = serialPort.getInputStream(); 
 
        outputStream = serialPort.getOutputStream(); 
 
      } catch (IOException e) {} 
 
try {//为串口添加监听器 
 
        serialPort.addEventListener(this); 
 
} catch (TooManyListenersException e) {} 
 
      serialPort.notifyOnDataAvailable(true); 
 
      try {//配置串口 
 
        serialPort.setSerialPortParams(9600,//波特率9600bps 
 
            SerialPort.DATABITS_7,//7位数据位 
 
            SerialPort.STOPBITS_1,//1位停止位 
 
            SerialPort.PARITY_EVEN);//偶校验 
 
      } catch (UnsupportedCommOperationException e) {} 
 
      readThread = new Thread(this);//新建一线程 
 
      readThread.start();//启动线程 
 
    } 
 
    public void run() { 
 
      try { 
 
        Thread.sleep(1); 
 
      } catch (InterruptedException e) {} 
 
    } 
 
    public void serialEvent(SerialPortEvent event) { 
 
      switch(event.getEventType()) { 
 
      case SerialPortEvent.BI: 
 
      case SerialPortEvent.OE: 
 
      case SerialPortEvent.FE: 
 
      case SerialPortEvent.PE: 
 
      case SerialPortEvent.CD: 
 
      case SerialPortEvent.CTS: 
 
      case SerialPortEvent.DSR: 
 
      case SerialPortEvent.RI: 
 
      case SerialPortEvent.OUTPUT_BUFFER_EMPTY: 
 
        break; 
 
      case SerialPortEvent.DATA_AVAILABLE://如果有数据到达 
 
        byte[] readBuffer = new byte[200]; 
 
        try { 
 
            while (inputStream.available() > 0) { 
 
//读取一个字节到readBuffer 
 
              int numBytes = inputStream.read(readBuffer); 
 
            } 
 
            System.out.print(new String(readBuffer)); 
 
        } catch (IOException e) {} 
 
        break; 
 
      } 
 
    } 
 
}

 
package com;
 
import java.io.*;
 
import java.text.SimpleDateFormat;
 
import java.util.Date;
 
import javax.comm.*;
 
import javax.sql.rowset.serial.SerialException;
 
 
 
public class Read {
 
public static void main(String[] args) {
 
 
 
CommPortIdentifier portId = null;
 
try {
 
portId = CommPortIdentifier.getPortIdentifier("COM4");
 
} catch (NoSuchPortException e1) {
 
System.out.println("串口不存在！");
 
e1.printStackTrace();
 
}
 
try {
 
SerialPort  sPort = (SerialPort) portId.open("串口读取程序", 60);
 
try {
 
sPort.setSerialPortParams(9600,SerialPort.DATABITS_7, SerialPort.STOPBITS_1,SerialPort.PARITY_EVEN);
 
}
 
//波特率9600bps,7位数据位,1停止位 ,偶校验 
 
catch   (UnsupportedCommOperationException   e)   {} 
 
 
//用于对串口写数据
 
//用于从串口读数据
 
InputStream is = null;
 
try {
 
is = new BufferedInputStream(sPort.getInputStream());
 
} catch (IOException e) {
 
System.out.println("读取串口失败！");
 
e.printStackTrace();
 
}
 
int PacketLength = 40;// PacketLength为缓冲数组长度
 
int newData;
 
 
 
while (true) {
 
char[] msgPack = new char[PacketLength];
 
for(int i = 0; i < PacketLength; i++){
 
try {
 
if( (newData = is.read()) != -1){
 
if ( newData == 10 )
 
break;
 
msgPack[i] = (char)newData;
 
System.out.println(msgPack[i]);
 
}
 
} catch (IOException e) {
 
// TODO Auto-generated catch block
 
e.printStackTrace();
 
}
 
}
 
String string =  String.valueOf(msgPack).trim();
 
String[] dataArray = string.split(",");
 
 
 
 for(int i=0;i<dataArray.length;i++)
 
 {
 
  System.out.print(i+":"+dataArray[i]+"n");
 
 }
 
  }
 
}catch (PortInUseException e) {
 
           try {
 
throw new SerialException(e.getMessage());
 
           	} catch (SerialException e1) {
 
           	 System.out.println("串口被占用！");
 
           	 e1.printStackTrace();
 
           	 }
 
       	}
 
}
 
}