java串口通讯带UI界面

ゝ一纸荒年。 2022-07-30 15:25 279阅读 0赞 
  1. package com.jetf.serialport;
  3. import gnu.io.CommPortIdentifier;
  4. import gnu.io.NoSuchPortException;
  5. import gnu.io.PortInUseException;
  6. import gnu.io.SerialPort;
  7. import gnu.io.SerialPortEvent;
  8. import gnu.io.SerialPortEventListener;
  9. import gnu.io.UnsupportedCommOperationException;
  11. import java.awt.BorderLayout;
  12. import java.awt.Button;
  13. import java.awt.Color;
  14. import java.awt.Font;
  15. import java.awt.GridLayout;
  16. import java.awt.Image;
  17. import java.awt.TextArea;
  18. import java.awt.TextField;
  19. import java.awt.event.ActionEvent;
  20. import java.awt.event.ActionListener;
  21. import java.io.IOException;
  22. import java.io.InputStream;
  23. import java.io.OutputStream;
  24. import java.util.ArrayList;
  25. import java.util.Enumeration;
  26. import java.util.List;
  27. import java.util.TooManyListenersException;
  29. import javax.imageio.ImageIO;
  30. import javax.swing.JComboBox;
  31. import javax.swing.JFrame;
  32. import javax.swing.JLabel;
  33. import javax.swing.JOptionPane;
  34. import javax.swing.JPanel;
  35. import javax.swing.SwingConstants;
  36. import javax.swing.border.EmptyBorder;
  38. public class JavaRs232 extends JFrame implements ActionListener,
  39.         SerialPortEventListener {
  41.     /**
  42.      * JDK Serial Version UID
  43.      */
  44.     private static final long serialVersionUID = -7270865686330790103L;
  46.     protected int WIN_WIDTH = 380;
  48.     protected int WIN_HEIGHT = 300;
  50.     private JComboBox portCombox, rateCombox, dataCombox, stopCombox,
  51.             parityCombox;
  53.     private Button openPortBtn, closePortBtn, sendMsgBtn;
  55.     private TextField sendTf;
  57.     private TextArea readTa;
  59.     private JLabel statusLb;
  61.     private String portname, rate, data, stop, parity;
  63.     protected CommPortIdentifier portId;
  65.     protected Enumeration<?> ports;
  67.     protected List<String> portList;
  69.     protected SerialPort serialPort;
  71.     protected OutputStream outputStream = null;
  73.     protected InputStream inputStream = null;
  75.     protected String mesg;
  77.     protected int sendCount, reciveCount;
  79.     /**
  80.      * 默认构造函数
  81.      */
  82.     public JavaRs232() {
  83.         super("Java RS-232串口通信测试程序   凡梦星尘");
  84.         setSize(WIN_WIDTH, WIN_HEIGHT);
  85.         setLocationRelativeTo(null);
  86.         Image icon = null;
  87.         try {
  88.             icon = ImageIO.read(JavaRs232.class
  89.                     .getResourceAsStream("rs232.png"));
  90.         } catch (IOException e) {
  91.             showErrMesgbox(e.getMessage());
  92.         }
  93.         setIconImage(icon);
  94.         setResizable(false);
  95.         scanPorts();
  96.         initComponents();
  97.         setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  98.         setVisible(true);
  99.     }
  101.     /**
  102.      * 初始化各UI组件
  103.      * 
  104.      * @since 2012-3-22 下午11:56:39
  105.      */
  106.     public void initComponents() {
  107.         // 共用常量
  108.         Font lbFont = new Font("微软雅黑", Font.TRUETYPE_FONT, 14);
  110.         // 创建左边面板
  111.         JPanel northPane = new JPanel();
  112.         northPane.setLayout(new GridLayout(1, 1));
  113.         // 设置左边面板各组件
  114.         JPanel leftPane = new JPanel();
  115.         leftPane.setOpaque(false);
  116.         leftPane.setLayout(new GridLayout(3, 2));
  117.         JLabel portnameLb = new JLabel("串口号：");
  118.         portnameLb.setFont(lbFont);
  119.         portnameLb.setHorizontalAlignment(SwingConstants.RIGHT);
  120.         portCombox = new JComboBox((String[]) portList.toArray(new String[0]));
  121.         portCombox.addActionListener(this);
  122.         JLabel databitsLb = new JLabel("数据位：");
  123.         databitsLb.setFont(lbFont);
  124.         databitsLb.setHorizontalAlignment(SwingConstants.RIGHT);
  125.         dataCombox = new JComboBox(new Integer[] { 5, 6, 7, 8 });
  126.         dataCombox.setSelectedIndex(3);
  127.         dataCombox.addActionListener(this);
  128.         JLabel parityLb = new JLabel("校验位：");
  129.         parityLb.setFont(lbFont);
  130.         parityLb.setHorizontalAlignment(SwingConstants.RIGHT);
  131.         parityCombox = new JComboBox(new String[] { "NONE", "ODD", "EVEN",
  132.                 "MARK", "SPACE" });
  133.         parityCombox.addActionListener(this);
  134.         // 添加组件至面板
  135.         leftPane.add(portnameLb);
  136.         leftPane.add(portCombox);
  137.         leftPane.add(databitsLb);
  138.         leftPane.add(dataCombox);
  139.         leftPane.add(parityLb);
  140.         leftPane.add(parityCombox);
  142.         // 创建右边面板
  143.         JPanel rightPane = new JPanel();
  144.         rightPane.setLayout(new GridLayout(3, 2));
  145.         // 设置右边面板各组件
  146.         JLabel baudrateLb = new JLabel("波特率：");
  147.         baudrateLb.setFont(lbFont);
  148.         baudrateLb.setHorizontalAlignment(SwingConstants.RIGHT);
  149.         rateCombox = new JComboBox(new Integer[] { 2400, 4800, 9600, 14400,
  150.                 19200, 38400, 56000 });
  151.         rateCombox.setSelectedIndex(2);
  152.         rateCombox.addActionListener(this);
  153.         JLabel stopbitsLb = new JLabel("停止位：");
  154.         stopbitsLb.setFont(lbFont);
  155.         stopbitsLb.setHorizontalAlignment(SwingConstants.RIGHT);
  156.         stopCombox = new JComboBox(new String[] { "1", "2", "1.5" });
  157.         stopCombox.addActionListener(this);
  158.         openPortBtn = new Button("打开端口");
  159.         openPortBtn.addActionListener(this);
  160.         closePortBtn = new Button("关闭端口");
  161.         closePortBtn.addActionListener(this);
  162.         // 添加组件至面板
  163.         rightPane.add(baudrateLb);
  164.         rightPane.add(rateCombox);
  165.         rightPane.add(stopbitsLb);
  166.         rightPane.add(stopCombox);
  167.         rightPane.add(openPortBtn);
  168.         rightPane.add(closePortBtn);
  169.         // 将左右面板组合添加到北边的面板
  170.         northPane.add(leftPane);
  171.         northPane.add(rightPane);
  173.         // 创建中间面板
  174.         JPanel centerPane = new JPanel();
  175.         // 设置中间面板各组件
  176.         sendTf = new TextField(42);
  177.         readTa = new TextArea(8, 50);
  178.         readTa.setEditable(false);
  179.         readTa.setBackground(new Color(225, 242, 250));
  180.         centerPane.add(sendTf);
  181.         sendMsgBtn = new Button(" 发送 ");
  182.         sendMsgBtn.addActionListener(this);
  183.         // 添加组件至面板
  184.         centerPane.add(sendTf);
  185.         centerPane.add(sendMsgBtn);
  186.         centerPane.add(readTa);
  188.         // 设置南边组件
  189.         statusLb = new JLabel();
  190.         statusLb.setText(initStatus());
  191.         statusLb.setOpaque(true);
  193.         // 获取主窗体的容器,并将以上三面板以北、中、南的布局整合
  194.         JPanel contentPane = (JPanel) getContentPane();
  195.         contentPane.setLayout(new BorderLayout());
  196.         contentPane.setBorder(new EmptyBorder(0, 0, 0, 0));
  197.         contentPane.setOpaque(false);
  198.         contentPane.add(northPane, BorderLayout.NORTH);
  199.         contentPane.add(centerPane, BorderLayout.CENTER);
  200.         contentPane.add(statusLb, BorderLayout.SOUTH);
  201.     }
  203.     /**
  204.      * 初始化状态标签显示文本
  205.      * 
  206.      * @return String
  207.      * @since 2012-3-23 上午12:01:53
  208.      */
  209.     public String initStatus() {
  210.         portname = portCombox.getSelectedItem().toString();
  211.         rate = rateCombox.getSelectedItem().toString();
  212.         data = dataCombox.getSelectedItem().toString();
  213.         stop = stopCombox.getSelectedItem().toString();
  214.         parity = parityCombox.getSelectedItem().toString();
  216.         StringBuffer str = new StringBuffer("当前串口号:");
  217.         str.append(portname).append(" 波特率:");
  218.         str.append(rate).append(" 数据位:");
  219.         str.append(data).append(" 停止位:");
  220.         str.append(stop).append(" 校验位:");
  221.         str.append(parity);
  222.         return str.toString();
  223.     }
  225.     /**
  226.      * 扫描本机的所有COM端口
  227.      * 
  228.      * @since 2012-3-23 上午12:02:42
  229.      */
  230.     public void scanPorts() {
  231.         portList = new ArrayList<String>();
  232.         Enumeration<?> en = CommPortIdentifier.getPortIdentifiers();
  233.         CommPortIdentifier portId;
  234.         while (en.hasMoreElements()) {
  235.             portId = (CommPortIdentifier) en.nextElement();
  236.             if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
  237.                 String name = portId.getName();
  238.                 if (!portList.contains(name)) {
  239.                     portList.add(name);
  240.                 }
  241.             }
  242.         }
  243.         if (null == portList || portList.isEmpty()) {
  244.             showErrMesgbox("未找到可用的串行端口号,程序无法启动!");
  245.             System.exit(0);
  246.         }
  247.     }
  249.     /**
  250.      * 打开串行端口
  251.      * 
  252.      * @since 2012-3-23 上午12:03:07
  253.      */
  254.     public void openSerialPort() {
  255.         // 获取要打开的端口
  256.         try {
  257.             portId = CommPortIdentifier.getPortIdentifier(portname);
  258.         } catch (NoSuchPortException e) {
  259.             showErrMesgbox("抱歉,没有找到" + portname + "串行端口号!");
  260.             setComponentsEnabled(true);
  261.             return;
  262.         }
  263.         // 打开端口
  264.         try {
  265.             serialPort = (SerialPort) portId.open("JavaRs232", 2000);
  266.             statusLb.setText(portname + "串口已经打开!");
  267.         } catch (PortInUseException e) {
  268.             showErrMesgbox(portname + "端口已被占用,请检查!");
  269.             setComponentsEnabled(true);
  270.             return;
  271.         }
  273.         // 设置端口参数
  274.         try {
  275.             int rate = Integer.parseInt(this.rate);
  276.             int data = Integer.parseInt(this.data);
  277.             int stop = stopCombox.getSelectedIndex() + 1;
  278.             int parity = parityCombox.getSelectedIndex();
  279.             System.out.println("rate:"+rate);
  280.             System.out.println("data:"+data);
  281.             System.out.println("stop:"+stop);
  282.             System.out.println("parity:"+parity);
  283.             serialPort.setSerialPortParams(rate, data, stop, parity);
  284.         } catch (UnsupportedCommOperationException e) {
  285.             showErrMesgbox(e.getMessage());
  286.         }
  288.         // 打开端口的IO流管道
  289.         try {
  290.             outputStream = serialPort.getOutputStream();
  291.             inputStream = serialPort.getInputStream();
  292.         } catch (IOException e) {
  293.             showErrMesgbox(e.getMessage());
  294.         }
  296.         // 给端口添加监听器
  297.         try {
  298.             serialPort.addEventListener(this);
  299.         } catch (TooManyListenersException e) {
  300.             showErrMesgbox(e.getMessage());
  301.         }
  303.         serialPort.notifyOnDataAvailable(true);
  304.     }
  306.     /**
  307.      * 给串行端口发送数据
  308.      * 
  309.      * @since 2012-3-23 上午12:05:00
  310.      */
  311.     public void sendDataToSeriaPort() {
  312.         try {
  313.             sendCount++;
  314.             outputStream.write(mesg.getBytes());
  315.             outputStream.flush();
  317.         } catch (IOException e) {
  318.             showErrMesgbox(e.getMessage());
  319.         }
  321.         statusLb.setText("  发送: " + sendCount
  322.                 + "                                      接收: " + reciveCount);
  323.     }
  325.     /**
  326.      * 关闭串行端口
  327.      * 
  328.      * @since 2012-3-23 上午12:05:28
  329.      */
  330.     public void closeSerialPort() {
  331.         try {
  332.             if (outputStream != null)
  333.                 outputStream.close();
  334.             if (serialPort != null)
  335.                 serialPort.close();
  336.             serialPort = null;
  337.             statusLb.setText(portname + "串口已经关闭!");
  338.             sendCount = 0;
  339.             reciveCount = 0;
  340.             sendTf.setText("");
  341.             readTa.setText("");
  342.         } catch (Exception e) {
  343.             showErrMesgbox(e.getMessage());
  344.         }
  345.     }
  347.     /**
  348.      * 显示错误或警告信息
  349.      * 
  350.      * @param msg
  351.      *            信息
  352.      * @since 2012-3-23 上午12:05:47
  353.      */
  354.     public void showErrMesgbox(String msg) {
  355.         JOptionPane.showMessageDialog(this, msg);
  356.     }
  358.     /**
  359.      * 各组件行为事件监听
  360.      */
  361.     public void actionPerformed(ActionEvent e) {
  362.         if (e.getSource() == portCombox || e.getSource() == rateCombox
  363.                 || e.getSource() == dataCombox || e.getSource() == stopCombox
  364.                 || e.getSource() == parityCombox) {
  365.             statusLb.setText(initStatus());
  366.         }
  367.         if (e.getSource() == openPortBtn) {
  368.             setComponentsEnabled(false);
  369.             openSerialPort();
  370.         }
  371.         if (e.getSource() == closePortBtn) {
  372.             if (serialPort != null) {
  373.                 closeSerialPort();
  374.             }
  375.             setComponentsEnabled(true);
  376.         }
  378.         if (e.getSource() == sendMsgBtn) {
  379.             if (serialPort == null) {
  380.                 showErrMesgbox("请先打开串行端口!");
  381.                 return;
  382.             }
  383.             mesg = sendTf.getText();
  384.             if (null == mesg || mesg.isEmpty()) {
  385.                 showErrMesgbox("请输入你要发送的内容!");
  386.                 return;
  387.             }
  388.             sendDataToSeriaPort();
  389.         }
  390.     }
  392.     /**
  393.      * 端口事件监听
  394.      */
  395.     public void serialEvent(SerialPortEvent event) {
  396.         switch (event.getEventType()) {
  397.         case SerialPortEvent.BI:
  398.         case SerialPortEvent.OE:
  399.         case SerialPortEvent.FE:
  400.         case SerialPortEvent.PE:
  401.         case SerialPortEvent.CD:
  402.         case SerialPortEvent.CTS:
  403.         case SerialPortEvent.DSR:
  404.         case SerialPortEvent.RI:
  405.         case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
  406.             break;
  407.         case SerialPortEvent.DATA_AVAILABLE:
  408.             byte[] readBuffer = new byte[50];
  410.             try {
  411.                 while (inputStream.available() > 0) {
  412.                     inputStream.read(readBuffer);
  413.                 }
  414.                 StringBuilder receivedMsg = new StringBuilder("/-- ");
  415.                 receivedMsg.append(new String(readBuffer).trim()).append(
  416.                         " --/\n");
  417.                 readTa.append(receivedMsg.toString());
  418.                 reciveCount++;
  419.                 statusLb.setText("  发送: " + sendCount
  420.                         + "                                      接收: "
  421.                         + reciveCount);
  422.             } catch (IOException e) {
  423.                 showErrMesgbox(e.getMessage());
  424.             }
  425.         }
  426.     }
  428.     /**
  429.      * 设置各组件的开关状态
  430.      * 
  431.      * @param enabled
  432.      *            状态
  433.      * @since 2012-3-23 上午12:06:24
  434.      */
  435.     public void setComponentsEnabled(boolean enabled) {
  436.         openPortBtn.setEnabled(enabled);
  437.         openPortBtn.setEnabled(enabled);
  438.         portCombox.setEnabled(enabled);
  439.         rateCombox.setEnabled(enabled);
  440.         dataCombox.setEnabled(enabled);
  441.         stopCombox.setEnabled(enabled);
  442.         parityCombox.setEnabled(enabled);
  443.     }
  445.     /**
  446.      * 运行主函数
  447.      * 
  448.      * @param args
  449.      * @since 2012-3-23 上午12:06:45
  450.      */
  451.     public static void main(String[] args) {
  452.         new JavaRs232();
  453.     }
  454. }

另注配置：

将javacomm20-win32 .zip下载的文件解压缩后，在\javacomm20-win32\commapi目录下有必需的三个文件：

comm.jar，javax.comm. properties和win32comm.dll。

将文件comm.jar拷贝到%JAVA_HOME%\jre\lib\ext;

文件 javax.comm. properties拷贝到%JAVA_HOME%\jre\lib;

文件win32comm.dll拷贝到%JAVA_HOME%\bin。

注意%JAVA_HOME%是jdk的路径，而非jre。

发表评论

表情：
评论列表 （有 0 条评论，279人围观）

还没有评论，来说两句吧...

相关阅读

    相关 串口通讯介绍

    串口通讯的物理连接和传输协议，是学习单片机串口编程的基础。 本文参照《深入浅出玩转51单片机》和《零死角玩转STM32》书籍，对通讯以及串口一些基本概念做了详解。 1. 串

    - 日理万妓- 日理万妓/ 0 赞/ 73 阅读

    相关 java串口通讯实例

    现在一般的电脑都没有串口端口的了，所以还是用虚拟的串口来做测试吧。 我们用 VSPD（Virtual Serial Port Driver） 这个软件建立两个虚拟串口，COM

    小咪咪小咪咪/ 0 赞/ 316 阅读

    相关 串口通讯之 CRC校验

    一、CRC16简介       循环冗余码CRC检验技术广泛应用于测控及通信领域。CRC计算可以靠专用的硬件来实现，但是对于低成本的微控制器系统，在没有硬件支持下实现CRC

    绝地灬酷狼绝地灬酷狼/ 0 赞/ 340 阅读