查看: 3582|回复: 5

Java串口助手结业作(程序源码) [复制链接]

hotpower (离线)
积分
82850
帖子
313
发表于 2009-4-2 23:59:26 |显示全部楼层
关键词: 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() + "输入失败!!!");
      }
     });
    }
    break;
   }
  }
}
}
●█〓██▄▄▄▄▄▄ ●●●●●●→ ''''╭WWWW╮
▄▅██████▅▄▃▂ 传播非典灌水四方 ( ●_●)
███天█马█行█空████ '''',,,;,;,;'''/▇\''
◥⊙▲⊙▲⊙▲⊙▲⊙▲⊙▲◤ 群魔乱舞见阳光/MMMM\
xiahang (离线)
积分
5
帖子
5
发表于 2009-6-30 20:17:02 |显示全部楼层
xiahang (离线)
积分
5
帖子
5
发表于 2009-6-30 20:17:30 |显示全部楼层
还是沙发?
好好好
wangkj (离线)
积分
57305
帖子
3129
发表于 2009-6-30 20:28:17 |显示全部楼层
倒,大叔这个也玩啊。
qq:1248780
email:1248780@qq.com
VGA 显示卡 arm单片机 显卡 cortex-m0 fpga 烧写器 开发板

http://item.taobao.com/item.htm?id=7801503020
李冬发 (离线)
积分
7509
帖子
116
发表于 2010-5-15 01:46:27 |显示全部楼层
java的串口在linux下用不来,我是用c中转的。
罗克韦尔 (离线)
积分
21191
帖子
242
发表于 2010-5-18 17:36:05 |显示全部楼层
AWT 还是swing?
您需要登录后才可以发表评论 登录 | 立即注册

关于我们  -  服务条款  -  使用指南  -  站点地图  -  友情链接  -  联系我们
电子工程网 © 版权所有   京ICP备11013910号 | 京公网安备11010502021702
回顶部