Java使用开源Rxtx实现串口通讯

import gnu.io.*;
import java.io.*; 
import java.util.*; 
import com.call.dao.*;
 
 public class SerialReader extends Observable implements Runnable,SerialPortEventListener
 {
 static CommPortIdentifier portId;
 int delayRead = 100;
 int numBytes; // buffer中的实际数据字节数
 private static byte[] readBuffer = new byte[1024]; // 4k的buffer空间,缓存串口读入的数据
 static Enumeration portList;
 InputStream inputStream;
 OutputStream outputStream;
 static SerialPort serialPort;
 HashMap serialParams;
 Thread readThread;//本来是static类型的
 //端口是否打开了
 boolean isOpen = false;
 // 端口读入数据事件触发后,等待n毫秒后再读取,以便让数据一次性读完
 public static final String PARAMS_DELAY = "delay read"; // 延时等待端口数据准备的时间
 public static final String PARAMS_TIMEOUT = "timeout"; // 超时时间
 public static final String PARAMS_PORT = "port name"; // 端口名称
 public static final String PARAMS_DATABITS = "data bits"; // 数据位
 public static final String PARAMS_STOPBITS = "stop bits"; // 停止位
 public static final String PARAMS_PARITY = "parity"; // 奇偶校验
 public static final String PARAMS_RATE = "rate"; // 波特率
 
 public boolean isOpen(){
  return isOpen;
 }
 /**
  * 初始化端口操作的参数.
  * @throws SerialPortException 
  * 
  * @see
  */
 public SerialReader()
 {
  isOpen = false;
 }
 
 public void open(HashMap params) 
 { 
  serialParams = params;
  if(isOpen){
  close();
  }
  try
  {
   // 参数初始化
   int timeout = Integer.parseInt( serialParams.get( PARAMS_TIMEOUT )
    .toString() );
   int rate = Integer.parseInt( serialParams.get( PARAMS_RATE )
    .toString() );
   int dataBits = Integer.parseInt( serialParams.get( PARAMS_DATABITS )
    .toString() );
   int stopBits = Integer.parseInt( serialParams.get( PARAMS_STOPBITS )
    .toString() );
   int parity = Integer.parseInt( serialParams.get( PARAMS_PARITY )
    .toString() );
   delayRead = Integer.parseInt( serialParams.get( PARAMS_DELAY )
    .toString() );
   String port = serialParams.get( PARAMS_PORT ).toString();
   // 打开端口
   portId = CommPortIdentifier.getPortIdentifier( port );
   serialPort = ( SerialPort ) portId.open( "SerialReader", timeout );
   inputStream = serialPort.getInputStream();
   serialPort.addEventListener( this );
   serialPort.notifyOnDataAvailable( true );
   serialPort.setSerialPortParams( rate, dataBits, stopBits, parity );
   
   isOpen = true;
  }
  catch ( PortInUseException e )
  {
   // 端口"+serialParams.get( PARAMS_PORT ).toString()+"已经被占用";
  }
  catch ( TooManyListenersException e )
  {
   //"端口"+serialParams.get( PARAMS_PORT ).toString()+"监听者过多";
  }
  catch ( UnsupportedCommOperationException e )
  {
   //"端口操作命令不支持";
  }
  catch ( NoSuchPortException e )
  {
   //"端口"+serialParams.get( PARAMS_PORT ).toString()+"不存在";
  }
  catch ( IOException e )
  {
   //"打开端口"+serialParams.get( PARAMS_PORT ).toString()+"失败";
  }
  serialParams.clear();
  Thread readThread = new Thread( this );
  readThread.start();
 }
 
  
 public void run()
 {
  try
  {
   Thread.sleep(50);
  }
  catch ( InterruptedException e )
  {
  }
 } 
 public void start(){
  try { 
  outputStream = serialPort.getOutputStream();
   } 
 catch (IOException e) {}
 try{ 
  readThread = new Thread(this);
  readThread.start();
 } 
 catch (Exception e) { }
 } //start() end
 
 
 public void run(String message) {
 try { 
  Thread.sleep(4); 
   } 
  catch (InterruptedException e) { } 
  try {
  if(message!=null&&message.length()!=0)
  { 
  System.out.println("run message:"+message);
   outputStream.write(message.getBytes());
  }
 } catch (IOException e) {}
 } 
 
 
 public void close() 
 { 
  if (isOpen)
  {
   try
   {
    serialPort.notifyOnDataAvailable(false);
    serialPort.removeEventListener();
    inputStream.close();
    serialPort.close();
    isOpen = false;
   } catch (IOException ex)
   {
   //"关闭串口失败";
   }
  }
 }
 
 public void serialEvent( SerialPortEvent event )
 {
  try
  {
   Thread.sleep( delayRead );
  }
  catch ( InterruptedException e )
  {
   e.printStackTrace();
  }
  switch ( event.getEventType() )
  {
   case SerialPortEvent.BI: // 10
   case SerialPortEvent.OE: // 7
   case SerialPortEvent.FE: // 9
   case SerialPortEvent.PE: // 8
   case SerialPortEvent.CD: // 6
   case SerialPortEvent.CTS: // 3
   case SerialPortEvent.DSR: // 4
   case SerialPortEvent.RI: // 5
   case SerialPortEvent.OUTPUT_BUFFER_EMPTY: // 2
    break;
   case SerialPortEvent.DATA_AVAILABLE: // 1
    try
    {
     // 多次读取,将所有数据读入
      while (inputStream.available() > 0) {
      numBytes = inputStream.read(readBuffer);
      }
      
      //打印接收到的字节数据的ASCII码
      for(int i=0;i<numBytes;i++){
      // System.out.println("msg[" + numBytes + "]: [" +readBuffer[i] + "]:"+(char)readBuffer[i]);
      }
//     numBytes = inputStream.read( readBuffer );
     changeMessage( readBuffer, numBytes );
    }
    catch ( IOException e )
    {
     e.printStackTrace();
    }
    break;
  }
 }
 // 通过observer pattern将收到的数据发送给observer
 // 将buffer中的空字节删除后再发送更新消息,通知观察者
 public void changeMessage( byte[] message, int length )
 {
  setChanged();
  byte[] temp = new byte[length];
  System.arraycopy( message, 0, temp, 0, length );
  notifyObservers( temp );
 }
 static void listPorts()
 {
  Enumeration portEnum = CommPortIdentifier.getPortIdentifiers();
  while ( portEnum.hasMoreElements() )
  {
   CommPortIdentifier portIdentifier = ( CommPortIdentifier ) portEnum
    .nextElement();
   
  }
 }
 
 
 public void openSerialPort(String message)
 {
  HashMap<String, Comparable> params = new HashMap<String, Comparable>(); 
  otherDAO odao=new otherDAO();
  String port=odao.selectNumberById(15);
  String rate = "9600";
  String dataBit = ""+SerialPort.DATABITS_8;
  String stopBit = ""+SerialPort.STOPBITS_1;
  String parity = ""+SerialPort.PARITY_NONE; 
  int parityInt = SerialPort.PARITY_NONE; 
  params.put( SerialReader.PARAMS_PORT, port ); // 端口名称
  params.put( SerialReader.PARAMS_RATE, rate ); // 波特率
  params.put( SerialReader.PARAMS_DATABITS,dataBit ); // 数据位
  params.put( SerialReader.PARAMS_STOPBITS, stopBit ); // 停止位
  params.put( SerialReader.PARAMS_PARITY, parityInt ); // 无奇偶校验
  params.put( SerialReader.PARAMS_TIMEOUT, 100 ); // 设备超时时间 1秒
  params.put( SerialReader.PARAMS_DELAY, 100 ); // 端口数据准备时间 1秒
  try {
 open(params);//打开串口
 LoginFrame cf=new LoginFrame();
 addObserver(cf);
 if(message!=null&&message.length()!=0)
 {
 String str="";
 for(int i=0;i<10;i++)
 {
  str+=message;
 }
  start(); 
  run(str); 
 } 
 } catch (Exception e) { 
 }
 }
 static String getPortTypeName( int portType )
 {
  switch ( portType )
  {
   case CommPortIdentifier.PORT_I2C:
    return "I2C";
   case CommPortIdentifier.PORT_PARALLEL:
    return "Parallel";
   case CommPortIdentifier.PORT_RAW:
    return "Raw";
   case CommPortIdentifier.PORT_RS485:
    return "RS485";
   case CommPortIdentifier.PORT_SERIAL:
    return "Serial";
   default:
    return "unknown type";
  }
 }
  
 public HashSet<CommPortIdentifier> getAvailableSerialPorts()//本来static
 {
  HashSet<CommPortIdentifier> h = new HashSet<CommPortIdentifier>();
  Enumeration thePorts = CommPortIdentifier.getPortIdentifiers();
  while ( thePorts.hasMoreElements() )
  {
   CommPortIdentifier com = ( CommPortIdentifier ) thePorts
    .nextElement();
   switch ( com.getPortType() )
   {
    case CommPortIdentifier.PORT_SERIAL:
     try
     {
      CommPort thePort = com.open( "CommUtil", 50 );
      thePort.close();
      h.add( com );
     }
     catch ( PortInUseException e )
     {
      System.out.println( "Port, " + com.getName()
       + ", is in use." );
     }
     catch ( Exception e )
     {
      System.out.println( "Failed to open port "
       + com.getName() + e );
     }
   }
  }
  return h;
 }
}
 
//ASCII表
//-------------------------------------------------------------
//     ASCII Characters       
//       
//Dec Hex  Char Code Dec Hex Char
//       
//0  0   NUL   64 40 @
//1  1   SOH   65 41 A
//2  2   STX   66 42 B
//3  3   ETX   67 43 C
//4  4   EOT   68 44 D
//5  5   ENQ   69 45 E
//6  6   ACK   70 46 F
//7  7   BEL   71 47 G
//8  8   BS    72 48 H
//9  9   HT    73 49 I
//10 0A  LF    74 4A J
//11 0B  VT    75 4B K
//12 0C  FF    76 4C L
//13 0D  CR    77 4D M
//14 0E  SO    78 4E N
//15 0F  SI    79 4F O
//16 10  SLE   80 50 P
//17 11  CS1   81 51 Q
//18 12  DC2   82 52 R
//19 13  DC3   83 53 S
//20 14  DC4   84 54 T
//21 15  NAK   85 55 U
//22 16  SYN   86 56 V
//23 17  ETB   87 57 W
//24 18  CAN   88 58 X
//25 19  EM    89 59 Y
//26 1A  SIB   90 5A Z
//27 1B  ESC   91 5B [
//        92 5C  \
//28 1C  FS    93 5D ]
//29 1D  GS    94 5E ^
//30 1E  RS    95 5F _
//31 1F  US    96 60 `
//32 20 (space)   97 61 a
//33 21  !    98 62 b
//34 22  " 
//        99 63 c
//35 23  #    100 64 d
//36 24  $     
//37 25  %    101 65 e
//38 26  &    102 66 f
//39 27  '    103 67 g
//40 28  (    104 68 h
//41 29  )    105 69 i
//42 2A  *    106 6A j
//43 2B  +    107 6B k
//44 2C  ,    108 6C l
//45 2D  -    109 6D m
//46 2E  .    110 6E n
//47 2F  /    111 6F o
//48 30  0    112 70 p
//49 31  1    113 72 q
//50 32  2    114 72 r
//51 33  3    115 73 s
//52 34  4    116 74 t
//53 35  5    117 75 u
//54 36  6    118 76 v
//55 37  7    119 77 w
//56 38  8    120 78 x
//57 39  9    121 79 y
//58 3A  :    122 7A z
//59 3B  ;    123 7B {
//60 3C  <    124 7C |
//61 3D  =    125 7D }
//62 3E  >    126 7E ~
//63 3F  ?    127 7F