原创 Java串口助手结业作(程序源码)

/**
 * Java串口助手结业作 菜农HotPower@126.com 2008.11.25 与西安雁塔菜地 
 * 本程序主要是模拟delphi/vc#/vb.net的窗体构架来简化Java的SWT应用
 */
package comm;

import java.io.*;
import java.util.*;
import java.util.Timer;
//import java.text.SimpleDateFormat;
//import java.util.Date;

import javax.comm.*;

//import org.eclipse.jface.dialogs.MessageDialog;
import org.eclipse.swt.*;
import org.eclipse.swt.browser.Browser;
//import org.eclipse.swt.browser.CloseWindowListener;
//import org.eclipse.swt.browser.WindowEvent;
import org.eclipse.swt.events.*;
import org.eclipse.swt.layout.*;
import org.eclipse.swt.widgets.*;

//import org.eclipse.swt.graphics.Color;

public class CommReadWrite {//CommReadWrite只是摆设
 public static void main(String[] args) {//main()只是摆设
  new Form();//建立新窗体直接并运行
 }

 public static class Form implements SerialPortEventListener {
  private Display display;

  private Shell shell;

  private Browser browser;

  private Label status;

  private Label datetime;

  private Label labelPortName;

  private Combo comboPortName;

  private Label labelBaudrate;

  private Combo comboBaudrate;

  private Label labelByteSize;

  private Combo comboByteSize;

  private Label labelParity;

  private Combo comboParity;

  private Label labelStopBits;

  private Combo comboStopBits;

  private Button buttonOpen;

  private Button buttonClose;

  private Button buttonSend;

  private Button buttonExit;

  private Label labelWrite;

  private Text textWrite;

  private Label labelRead;

  private Text textRead;

  private String messageString = "菜农Java习作\n";

  private Enumeration portList;

  private CommPortIdentifier portId;

  private OutputStream outputStream;

  private InputStream inputStream;

  private SerialPort serialPort;

  private Timer TimerDisplay;

  private byte[] readRxBuffer = new byte[2048];

  private int readRxCount = 0;

  public Form() {
   Initialize();//窗体组件初始化
   Load();// 窗体装载初始化
   Event();// 监听事件处理
   Run();//运行窗体程序
  }

//  public void finalize() {
//   System.out.println("程序结束!!!");
//  }

  public void Initialize() {//窗体控件构建及初始化过程处理
   display = new Display();// 创建一个Display对象
   // shell = new Shell(display, SWT.CLOSE | SWT.SYSTEM_MODAL);//
   // 创建一个Shell对象(程序的窗口)
   shell = new Shell(display);// 创建一个Shell对象(程序的窗口)
   shell.setText("                           Java串口助手");// 窗口标题

   shell.setLayout(new FormLayout());

   Composite controls = new Composite(shell, SWT.NONE);
   FormData data = new FormData();
   data.top = new FormAttachment(0, 0);
   data.left = new FormAttachment(0, 0);
   data.right = new FormAttachment(100, 0);
   controls.setLayoutData(data);

   status = new Label(shell, SWT.NONE);
   data = new FormData();
   data.left = new FormAttachment(0, 0);
   data.right = new FormAttachment(100, 0);
   data.bottom = new FormAttachment(100, 0);
   status.setLayoutData(data);

   browser = new Browser(shell, SWT.BORDER);
   data = new FormData();
   data.top = new FormAttachment(controls);
   data.bottom = new FormAttachment(status);
   data.left = new FormAttachment(0, 0);
   data.right = new FormAttachment(100, 0);
   browser.setLayoutData(data);

   browser.setText("Java 串口助手");

   controls.setLayout(new GridLayout(11, false));

   labelPortName = new Label(controls, SWT.BORDER);
   comboPortName = new Combo(controls, SWT.DROP_DOWN | SWT.BORDER);
   labelBaudrate = new Label(controls, SWT.BORDER);
   comboBaudrate = new Combo(controls, SWT.DROP_DOWN | SWT.BORDER);
   labelByteSize = new Label(controls, SWT.BORDER);
   comboByteSize = new Combo(controls, SWT.DROP_DOWN | SWT.BORDER);
   labelParity = new Label(controls, SWT.BORDER);
   comboParity = new Combo(controls, SWT.DROP_DOWN | SWT.BORDER);
   labelStopBits = new Label(controls, SWT.BORDER);
   comboStopBits = new Combo(controls, SWT.DROP_DOWN | SWT.BORDER);

   buttonOpen = new Button(controls, SWT.PUSH);
   buttonClose = new Button(controls, SWT.PUSH);

   labelRead = new Label(controls, SWT.BORDER);
   textRead = new Text(controls, SWT.BORDER | SWT.MULTI);// 多行文本框
   labelWrite = new Label(controls, SWT.BORDER);
   textWrite = new Text(controls, SWT.BORDER | SWT.MULTI);// 多行文本框

   buttonSend = new Button(controls, SWT.PUSH);
   buttonExit = new Button(controls, SWT.PUSH);

   datetime = new Label(controls, SWT.NONE);
   datetime.setText("2008-11-18 11:11:11");

   controls.setLayout(new GridLayout(10, false));

   labelPortName.setText("串口号");

   labelBaudrate.setText("波特率");
   comboBaudrate.add("110");
   comboBaudrate.add("300");
   comboBaudrate.add("600");
   comboBaudrate.add("1200");
   comboBaudrate.add("2400");
   comboBaudrate.add("4800");
   comboBaudrate.add("9600");
   comboBaudrate.add("14400");
   comboBaudrate.add("15200");
   comboBaudrate.add("28800");
   comboBaudrate.add("38400");
   comboBaudrate.add("56000");
   comboBaudrate.add("57600");
   comboBaudrate.add("115200");
   comboBaudrate.add("128000");
   comboBaudrate.add("256000");
   comboBaudrate.add("512000");
   comboBaudrate.add("921600");
   comboBaudrate.select(6);// 9600

   labelByteSize.setText("数据位");
   comboByteSize.add("5");
   comboByteSize.add("6");
   comboByteSize.add("7");
   comboByteSize.add("8");
   comboByteSize.select(3);// 8

   labelParity.setText("校验位");
   comboParity.add("无");
   comboParity.add("奇校验");
   comboParity.add("偶校验");
   comboParity.select(0);// 无

   labelStopBits.setText("停止位");
   comboStopBits.add("1");
   comboStopBits.add("2");
   comboStopBits.select(0);// 1

   buttonOpen.setText("打开串口");// 按钮标题
   buttonClose.setText("关闭串口");// 按钮标题
   buttonSend.setText("发送数据");// 按钮标题
   buttonExit.setText("退出系统");// 按钮标题
   labelWrite.setText("发送数据区");
   textWrite.setText(messageString);
   labelRead.setText("接收数据区");

   status.setText("系统提示:");

   comboPortName.setToolTipText("选择合法串口");
   comboBaudrate.setToolTipText("选择合法波特率");
   comboByteSize.setToolTipText("选择合法数据位");
   comboParity.setToolTipText("选择合法校验位");
   comboStopBits.setToolTipText("选择合法停止位");

   buttonOpen.setToolTipText("打开所选串口");
   buttonClose.setToolTipText("关闭当前串口");
   buttonSend.setToolTipText("发送所选串口数据");
   buttonExit.setToolTipText("关闭当前窗口,并退出系统");
   buttonSend.setToolTipText("发送所选串口数据");

   textWrite.setToolTipText("双击发送文本框数据");
   textRead.setToolTipText("双击清空文本框数据");

   comboPortName.setEnabled(true);
   comboBaudrate.setEnabled(true);
   comboByteSize.setEnabled(true);
   comboParity.setEnabled(true);
   comboStopBits.setEnabled(true);
   buttonOpen.setEnabled(true);
   buttonClose.setEnabled(false);
   buttonSend.setEnabled(false);
   textWrite.setEnabled(false);

   TimerDisplay = new Timer();

  }

  public void Load() {//装载及用户初始化处理过程
   CommPortInit();// Comm控件初始化
   comboPortName.setText(comboPortName.getItem(0));
  }

  public void Run() {//运行主窗体
   shell.open();// 显示窗体
   while (!shell.isDisposed())// 测试关闭窗口事件
   {
    if (!display.readAndDispatch())
     display.sleep();// 休眠
   }
   this.Close();// 关闭窗体及资源

  }

  public void Close() {//关闭及卸载事件处理过程
   if (serialPort != null)
    serialPort.close();// 关闭串口
   TimerDisplay.cancel();
   this.display.dispose();// 显式地调用dispose() 方法来释放程序运行中所获得的资源
  }

  public void Event() {//添加所有事件(监听)处理过程

   TimerDisplay.schedule(new TimerTask() {
    public void run() {
     Display.getDefault().asyncExec(new Runnable() {
      // @Override
      public void run() {
       // Calendar Now = Calendar.getInstance();
       // SimpleDateFormat fmt = new
       // SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
       // datetime.setText(fmt.format(Now.getTime()));
       if (!shell.isDisposed()) {// 避免异常并显示本地日期和时间
        // 不要理会系统的建议！！！toLocaleString方法很好(2008-11-18
        // 11:11:11)
        datetime.setText(Calendar.getInstance()
          .getTime().toLocaleString());
       }
      }
     });
    }
   }, 1000, 1);

   textWrite.addMouseListener(new MouseAdapter() {

    public void mouseDoubleClick(MouseEvent e) {// 鼠标双击事件处理
     if (serialPort != null) {
      try {
       if (((Text) e.widget).getText().length() > 0) {
        outputStream.write(((Text) e.widget).getText()
          .getBytes());
        status.setText("系统提示: " + "串口"
          + serialPort.getName() + "发送成功!!!");
       } else
        status.setText("系统提示: " + "串口"
          + serialPort.getName() + "空串发送失败!!!");
      } catch (IOException ex) {
       status.setText("系统提示: " + "串口"
         + serialPort.getName() + "发送失败!!!");
      }

     }
    }

   });

   textRead.addMouseListener(new MouseAdapter() {

    public void mouseDoubleClick(MouseEvent e) {// 鼠标双击事件处理
     ((Text) e.widget).setText("");
    }

    public void mouseDown(MouseEvent e) {// 鼠标单击事件处理
     // MessageDialog.openInformation (null,"","Hello World");
     // ((Text)e.widget).setText("1223");
    }

    public void mouseUp(MouseEvent e) {// 鼠标单击释放事件处理
     // ((Text)e.widget).setText("");
    }

   });

   buttonOpen.addSelectionListener(new SelectionAdapter() {// 加入按钮事件监听
      public void widgetSelected(SelectionEvent e) {
       portList = CommPortIdentifier.getPortIdentifiers();// 枚举端口
       while (portList.hasMoreElements()) {// 枚举端口(串口)
        portId = (CommPortIdentifier) portList
          .nextElement();
        if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {// 只取串口设备
         if (portId.getName().equals(
           comboPortName.getText())) {
          CommPortOpen();
         }
        }
       }
      }
     });

   buttonClose.addSelectionListener(new SelectionAdapter() {// 加入按钮事件监听
      public void widgetSelected(SelectionEvent e) {
       if (serialPort != null) {
        status.setText("系统提示: " + "串口"
          + serialPort.getName() + "被关闭!!!");
        serialPort.close();// 关闭串口
        comboPortName.setEnabled(true);
        comboBaudrate.setEnabled(true);
        comboByteSize.setEnabled(true);
        comboParity.setEnabled(true);
        comboStopBits.setEnabled(true);
        buttonOpen.setEnabled(true);
        buttonClose.setEnabled(false);
        buttonSend.setEnabled(false);
       }
      }
     });

   buttonSend.addSelectionListener(new SelectionAdapter() {// 加入按钮事件监听
      public void widgetSelected(SelectionEvent e) {
       if (serialPort != null) {
        try {
         if (textWrite.getText().length() > 0) {
          outputStream.write(textWrite.getText()
            .getBytes());
          status.setText("系统提示: " + "串口"
            + serialPort.getName()
            + "发送成功!!!");
         } else
          status.setText("系统提示: " + "串口"
            + serialPort.getName()
            + "空串发送失败!!!");
        } catch (IOException ex) {
         status.setText("系统提示: " + "串口"
           + serialPort.getName() + "发送失败!!!");
        }
       }
      }
     });

   buttonExit.addSelectionListener(new SelectionAdapter() {// 加入按钮事件监听
      public void widgetSelected(SelectionEvent e) {
       Close();
      }
     });
  }

  public void CommPortOpen() {
   try {
    if (serialPort != null)
     serialPort.close();// 保证只打开一个串口
    serialPort = (SerialPort) portId.open("CommReadWriteApp", 2000);
    try {
     outputStream = serialPort.getOutputStream();
     try {
      inputStream = serialPort.getInputStream();
      try {
       serialPort.addEventListener(this);
       try {
        serialPort.setSerialPortParams(Integer
          .parseInt(comboBaudrate.getText()),
          Integer.parseInt(comboByteSize
            .getText()),// SerialPort.DATABITS_8,
          Integer.parseInt(comboStopBits
            .getText()),// SerialPort.STOPBITS_1,
          comboParity.getSelectionIndex());// SerialPort.PARITY_NONE);
        serialPort.notifyOnDataAvailable(true);// 打开监听
        status
          .setText("系统提示: " + "串口"
            + serialPort.getName()
            + "正常打开,监听开始!!!");
        comboPortName.setEnabled(false);
        comboBaudrate.setEnabled(false);
        comboByteSize.setEnabled(false);
        comboParity.setEnabled(false);
        comboStopBits.setEnabled(false);
        buttonOpen.setEnabled(false);
        buttonClose.setEnabled(true);
        buttonSend.setEnabled(true);
        textWrite.setEnabled(true);

       } catch (UnsupportedCommOperationException e) {
        status.setText("系统提示: " + "串口"
          + serialPort.getName() + "设置异常!!!");
       }
      } catch (TooManyListenersException e) {
       status.setText("系统提示: " + "串口"
         + serialPort.getName() + "监听事件异常!!!");
      }
     } catch (IOException e) {
      status.setText("系统提示: " + "串口" + serialPort.getName()
        + "输入流输出异常!!!");
     }
    } catch (IOException e) {
     status.setText("系统提示: " + "串口" + serialPort.getName()
       + "输出流输出异常!!!");
    }
   } catch (PortInUseException ex) {
    status.setText("系统提示: " + "串口" + serialPort.getName()
      + "打开异常!!!");
   }
  }

  public void CommPortInit() {
   portList = CommPortIdentifier.getPortIdentifiers();// 枚举端口
   while (portList.hasMoreElements()) {// 枚举端口(串口)
    portId = (CommPortIdentifier) portList.nextElement();
    if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {// 只取串口设备
     comboPortName.add(portId.getName());
    }
   }
  }
  
  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[256];

    try {
     int numBytes = 0;
     while (inputStream.available() > 0) {
      numBytes = inputStream.read(readBuffer);
     }
     if (numBytes > 0) {
      for (int i = 0; i < numBytes; i++) {
       readRxBuffer[i + readRxCount] = readBuffer;
      }
      readRxCount += numBytes;
      if (readBuffer[numBytes - 1] == '\n') {
       readRxBuffer[readRxCount] = '\0';
       Display.getDefault().asyncExec(new Runnable() {
        // @Override
        public void run() {
         textRead.append(new String(readRxBuffer));
         browser.setText(textRead.getText());
         status.setText("系统提示: " + "串口"
           + serialPort.getName() + "输入成功!!!");
        }
       });
       readRxCount = 0;
      }
     }
    } catch (IOException e) {
     Display.getDefault().asyncExec(new Runnable() {
      // @Override
      public void run() {
       status.setText("系统提示: " + "串口"
         + serialPort.getName() + "输入失败!!!");
      }
     });
    }