Java串口助手結業(yè)作(程序源碼)

hotpower

/**
* Java串口助手結業(yè)作 菜農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();// 監(jiān)聽事件處理
   Run();//運行窗體程序
  }
//  public void finalize() {
//   System.out.println("程序結束!!!");
//  }
  public void Initialize() {//窗體控件構建及初始化過程處理
   display = new Display();// 創(chuàng)建一個Display對象
   // shell = new Shell(display, SWT.CLOSE | SWT.SYSTEM_MODAL);//
   // 創(chuàng)建一個Shell對象(程序的窗口)
   shell = new Shell(display);// 創(chuàng)建一個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("數(shù)據(jù)位");
   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("發(fā)送數(shù)據(jù)");// 按鈕標題
   buttonExit.setText("退出系統(tǒng)");// 按鈕標題
   labelWrite.setText("發(fā)送數(shù)據(jù)區(qū)");
   textWrite.setText(messageString);
   labelRead.setText("接收數(shù)據(jù)區(qū)");
   status.setText("系統(tǒng)提示:");
   comboPortName.setToolTipText("選擇合法串口");
   comboBaudrate.setToolTipText("選擇合法波特率");
   comboByteSize.setToolTipText("選擇合法數(shù)據(jù)位");
   comboParity.setToolTipText("選擇合法校驗位");
   comboStopBits.setToolTipText("選擇合法停止位");
   buttonOpen.setToolTipText("打開所選串口");
   buttonClose.setToolTipText("關閉當前串口");
   buttonSend.setToolTipText("發(fā)送所選串口數(shù)據(jù)");
   buttonExit.setToolTipText("關閉當前窗口,并退出系統(tǒng)");
   buttonSend.setToolTipText("發(fā)送所選串口數(shù)據(jù)");
   textWrite.setToolTipText("雙擊發(fā)送文本框數(shù)據(jù)");
   textRead.setToolTipText("雙擊清空文本框數(shù)據(jù)");
   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() {//添加所有事件(監(jiān)聽)處理過程
   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()) {// 避免異常并顯示本地日期和時間
        // 不要理會系統(tǒng)的建議！！！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("系統(tǒng)提示: " + "串口"
          + serialPort.getName() + "發(fā)送成功!!!");
       } else
        status.setText("系統(tǒng)提示: " + "串口"
          + serialPort.getName() + "空串發(fā)送失敗!!!");
      } catch (IOException ex) {
       status.setText("系統(tǒng)提示: " + "串口"
         + serialPort.getName() + "發(fā)送失敗!!!");
      }
     }
    }
   });
   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() {// 加入按鈕事件監(jiān)聽
      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() {// 加入按鈕事件監(jiān)聽
      public void widgetSelected(SelectionEvent e) {
       if (serialPort != null) {
        status.setText("系統(tǒng)提示: " + "串口"
          + 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() {// 加入按鈕事件監(jiān)聽
      public void widgetSelected(SelectionEvent e) {
       if (serialPort != null) {
        try {
         if (textWrite.getText().length() > 0) {
          outputStream.write(textWrite.getText()
            .getBytes());
          status.setText("系統(tǒng)提示: " + "串口"
            + serialPort.getName()
            + "發(fā)送成功!!!");
         } else
          status.setText("系統(tǒng)提示: " + "串口"
            + serialPort.getName()
            + "空串發(fā)送失敗!!!");
        } catch (IOException ex) {
         status.setText("系統(tǒng)提示: " + "串口"
           + serialPort.getName() + "發(fā)送失敗!!!");
        }
       }
      }
     });
   buttonExit.addSelectionListener(new SelectionAdapter() {// 加入按鈕事件監(jiān)聽
      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);// 打開監(jiān)聽
        status
          .setText("系統(tǒng)提示: " + "串口"
            + serialPort.getName()
            + "正常打開,監(jiān)聽開始!!!");
        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("系統(tǒng)提示: " + "串口"
          + serialPort.getName() + "設置異常!!!");
       }
      } catch (TooManyListenersException e) {
       status.setText("系統(tǒng)提示: " + "串口"
         + serialPort.getName() + "監(jiān)聽事件異常!!!");
      }
     } catch (IOException e) {
      status.setText("系統(tǒng)提示: " + "串口" + serialPort.getName()
        + "輸入流輸出異常!!!");
     }
    } catch (IOException e) {
     status.setText("系統(tǒng)提示: " + "串口" + serialPort.getName()
       + "輸出流輸出異常!!!");
    }
   } catch (PortInUseException ex) {
    status.setText("系統(tǒng)提示: " + "串口" + 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("系統(tǒng)提示: " + "串口"
           + serialPort.getName() + "輸入成功!!!");
        }
       });
       readRxCount = 0;
      }
     }
    } catch (IOException e) {
     Display.getDefault().asyncExec(new Runnable() {
      // @Override
      public void run() {
       status.setText("系統(tǒng)提示: " + "串口"
         + serialPort.getName() + "輸入失敗!!!");
      }
     });
    }
    break;
   }
  }
}
}

xiahang

xiahang

還是沙發(fā)？
好好好

wangkj

倒，大叔這個也玩啊。

李冬發(fā)

java的串口在linux下用不來，我是用c中轉的。

羅克韋爾

AWT 還是swing？