JAVA串口通讯程序

淡淡的烟草味﹌ 2022-08-21 06:45 264阅读 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. import com.jetf.mm.CRC16;
  39. import com.jfinal.kit.StrKit;
  41. public class JavaRs232 extends JFrame implements ActionListener,
  42.         SerialPortEventListener {
  44.     /**
  45.      * JDK Serial Version UID
  46.      */
  47.     private static final long serialVersionUID = -7270865686330790103L;
  49.     protected int WIN_WIDTH = 500;
  50.     protected int WIN_HEIGHT = 420;
  52.     private JComboBox portCombox, rateCombox, dataCombox, stopCombox,
  53.             parityCombox, parityCombox1;
  55.     private Button openPortBtn, closePortBtn, sendMsgBtn, sendMsgBtn1;
  57.     private TextField sendTf;
  58.     private TextField sendD1;
  59.     private TextField sendD2;
  60.     private TextField sendD3;
  62.     private TextField sendTf1;
  64.     private TextArea readTa;
  66.     private JLabel statusLb;
  68.     private String portname, rate, data, stop, parity;
  70.     protected CommPortIdentifier portId;
  72.     protected Enumeration<?> ports;
  74.     protected List<String> portList;
  76.     protected SerialPort serialPort;
  78.     protected OutputStream outputStream = null;
  80.     protected InputStream inputStream = null;
  82.     protected String mesg;
  83.     protected String mesg1;
  84.     protected String mesg_info_D1;
  85.     protected String mesg_info_D2;
  86.     protected String mesg_info_D3;
  88.     protected String[] mesgs;
  90.     protected int sendCount, reciveCount;
  92.     /**
  93.      * 默认构造函数
  94.      */
  95.     public JavaRs232() {
  96.         super("Java串口通信测试程序");
  97.         setSize(WIN_WIDTH, WIN_HEIGHT);
  98.         setLocationRelativeTo(null);
  99.         Image icon = null;
  100.         try {
  101.             icon = ImageIO.read(JavaRs232.class
  102.                     .getResourceAsStream("rs232.png"));
  103.         } catch (IOException e) {
  104.             showErrMesgbox(e.getMessage());
  105.         }
  106.         setIconImage(icon);
  107.         setResizable(false);
  108.         scanPorts();
  109.         initComponents();
  110.         setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  111.         setVisible(true);
  112.     }
  114.     /**
  115.      * 初始化各UI组件
  116.      * 
  117.      * @since 2012-3-22 下午11:56:39
  118.      */
  119.     public void initComponents() {
  120.         // 共用常量
  121.         Font lbFont = new Font("微软雅黑", Font.TRUETYPE_FONT, 14);
  123.         // 创建左边面板
  124.         JPanel northPane = new JPanel();
  125.         northPane.setLayout(new GridLayout(1, 1));
  126.         // 设置左边面板各组件
  127.         JPanel leftPane = new JPanel();
  128.         leftPane.setOpaque(false);
  129.         leftPane.setLayout(new GridLayout(3, 2));
  130.         JLabel portnameLb = new JLabel("串口号：");
  131.         portnameLb.setFont(lbFont);
  132.         portnameLb.setHorizontalAlignment(SwingConstants.RIGHT);
  133.         portCombox = new JComboBox((String[]) portList.toArray(new String[0]));
  134.         portCombox.addActionListener(this);
  135.         JLabel databitsLb = new JLabel("数据位：");
  136.         databitsLb.setFont(lbFont);
  137.         databitsLb.setHorizontalAlignment(SwingConstants.RIGHT);
  138.         // 设置中间面板各组件
  139.         dataCombox = new JComboBox(new Integer[] { 5, 6, 7, 8 });
  140.         dataCombox.setSelectedIndex(3);
  141.         dataCombox.addActionListener(this);
  142.         JLabel parityLb = new JLabel("校验位：");
  143.         parityLb.setFont(lbFont);
  144.         parityLb.setHorizontalAlignment(SwingConstants.RIGHT);
  145.         parityCombox = new JComboBox(new String[] { "NONE", "ODD", "EVEN",
  146.                 "MARK", "SPACE" });
  147.         parityCombox.addActionListener(this);
  149.         JLabel parityLb1 = new JLabel("01写：");
  150.         parityLb1.setFont(lbFont);
  151.         parityLb1.setLayout(new GridLayout(1, 1));
  152.         parityLb1.setHorizontalAlignment(SwingConstants.RIGHT);
  153.         // 设置中间面板各组件
  154.         sendD1 = new TextField(5);
  156.         JLabel parityLb2 = new JLabel("03读：");
  157.         parityLb2.setFont(lbFont);
  158.         parityLb2.setLayout(new GridLayout(1, 1));
  159.         parityLb2.setHorizontalAlignment(SwingConstants.RIGHT);
  160.         // 设置中间面板各组件
  161.         sendD3 = new TextField(5);
  163.         JLabel parityLb3 = new JLabel("0002：");
  164.         parityLb3.setFont(lbFont);
  165.         parityLb3.setLayout(new GridLayout(1, 1));
  166.         parityLb3.setHorizontalAlignment(SwingConstants.RIGHT);
  167.         // 设置中间面板各组件
  168.         sendD2 = new TextField(5);
  170.         // 添加组件至面板
  172.         leftPane.add(portnameLb);
  173.         leftPane.add(portCombox);
  174.         leftPane.add(databitsLb);
  175.         leftPane.add(dataCombox);
  176.         leftPane.add(parityLb);
  177.         leftPane.add(parityCombox);
  179.         leftPane.add(parityLb1);
  180.         leftPane.add(sendD1);
  181.         leftPane.add(parityLb2);
  182.         leftPane.add(sendD3);
  183.         leftPane.add(parityLb3);
  184.         leftPane.add(sendD2);
  186.         // 创建右边面板
  187.         JPanel rightPane = new JPanel();
  188.         rightPane.setLayout(new GridLayout(3, 2));
  189.         // 设置右边面板各组件
  190.         JLabel baudrateLb = new JLabel("波特率：");
  191.         baudrateLb.setFont(lbFont);
  192.         baudrateLb.setHorizontalAlignment(SwingConstants.RIGHT);
  193.         rateCombox = new JComboBox(new Integer[] { 2400, 4800, 9600, 14400,
  194.                 19200, 38400, 56000 });
  195.         rateCombox.setSelectedIndex(2);
  196.         rateCombox.addActionListener(this);
  198.         JLabel stopbitsLb = new JLabel("停止位：");
  199.         stopbitsLb.setFont(lbFont);
  200.         stopbitsLb.setHorizontalAlignment(SwingConstants.RIGHT);
  201.         stopCombox = new JComboBox(new String[] { "1", "2", "1.5" });
  202.         stopCombox.addActionListener(this);
  204.         // JLabel stopbitsLb4 = new JLabel("DDDD：");
  205.         // stopbitsLb4.setFont(lbFont);
  206.         // stopbitsLb4.setHorizontalAlignment(SwingConstants.RIGHT);
  207.         // sendTf = new TextField(5);
  209.         openPortBtn = new Button("start");
  210.         openPortBtn.addActionListener(this);
  211.         closePortBtn = new Button("coles");
  212.         closePortBtn.addActionListener(this);
  213.         // 添加组件至面板
  214.         rightPane.add(baudrateLb);
  215.         rightPane.add(rateCombox);
  216.         rightPane.add(stopbitsLb);
  217.         rightPane.add(stopCombox);
  219.         // rightPane.add(stopbitsLb4);
  220.         // rightPane.add(sendTf);
  222.         rightPane.add(openPortBtn);
  223.         rightPane.add(closePortBtn);
  224.         // 将左右面板组合添加到北边的面板
  225.         northPane.add(leftPane);
  226.         northPane.add(rightPane);
  228.         JLabel stopbitsLbdd = new JLabel("地址端口：");
  229.         stopbitsLbdd.setFont(lbFont);
  230.         stopbitsLbdd.setHorizontalAlignment(SwingConstants.RIGHT);
  232.         // 创建中间面板
  233.         JPanel centerPane = new JPanel();
  234.         // 设置中间面板各组件
  235.         sendTf = new TextField(30);
  236.         readTa = new TextArea(8, 50);
  237.         readTa.setEditable(false);
  238.         readTa.setBackground(new Color(225, 242, 250));
  239.         centerPane.add(sendTf);
  240.         sendMsgBtn = new Button("send ");
  241.         sendMsgBtn.addActionListener(this);
  243.         JLabel stopbitsLbdd1 = new JLabel("地址：");
  244.         stopbitsLbdd1.setFont(lbFont);
  245.         stopbitsLbdd1.setHorizontalAlignment(SwingConstants.RIGHT);
  246.         sendTf1 = new TextField(20);
  247.         sendMsgBtn1 = new Button("send2 ");
  248.         sendMsgBtn1.addActionListener(this);
  250.         JLabel parityLb4 = new JLabel("命令：");
  251.         parityLb4.setFont(lbFont);
  252.         parityLb4.setHorizontalAlignment(SwingConstants.RIGHT);
  253.         parityCombox1 = new JComboBox(new String[] { "上传开关量", "上传SOE整定值",
  254.                 "标志信息模拟量" });
  255.         parityCombox1.addActionListener(this);
  257.         // 添加组件至面板
  258.         centerPane.add(stopbitsLbdd);
  259.         centerPane.add(sendTf);
  260.         centerPane.add(sendMsgBtn);
  261.         centerPane.add(readTa);
  262.         centerPane.add(parityLb4);
  263.         centerPane.add(parityCombox1);
  264.         centerPane.add(stopbitsLbdd1);
  265.         centerPane.add(sendTf1);
  266.         centerPane.add(sendMsgBtn1);
  267.         // 设置南边组件
  268.         statusLb = new JLabel();
  269.         statusLb.setText(initStatus());
  270.         statusLb.setOpaque(true);
  272.         // 获取主窗体的容器,并将以上三面板以北、中、南的布局整合
  273.         JPanel contentPane = (JPanel) getContentPane();
  274.         contentPane.setLayout(new BorderLayout());
  275.         contentPane.setBorder(new EmptyBorder(0, 0, 0, 0));
  276.         contentPane.setOpaque(false);
  277.         contentPane.add(northPane, BorderLayout.NORTH);
  278.         contentPane.add(centerPane, BorderLayout.CENTER);
  280.         contentPane.add(statusLb, BorderLayout.SOUTH);
  281.     }
  283.     /**
  284.      * 初始化状态标签显示文本
  285.      * 
  286.      * @return String
  287.      * @since 2012-3-23 上午12:01:53
  288.      */
  289.     public String initStatus() {
  290.         portname = portCombox.getSelectedItem().toString();
  291.         rate = rateCombox.getSelectedItem().toString();
  292.         data = dataCombox.getSelectedItem().toString();
  293.         stop = stopCombox.getSelectedItem().toString();
  294.         parity = parityCombox.getSelectedItem().toString();
  296.         StringBuffer str = new StringBuffer("当前串口号:");
  297.         str.append(portname).append(" 波特率:");
  298.         str.append(rate).append(" 数据位:");
  299.         str.append(data).append(" 停止位:");
  300.         str.append(stop).append(" 校验位:");
  301.         str.append(parity);
  302.         return str.toString();
  303.     }
  305.     /**
  306.      * 扫描本机的所有COM端口
  307.      * 
  308.      * @since 2012-3-23 上午12:02:42
  309.      */
  310.     public void scanPorts() {
  311.         portList = new ArrayList<String>();
  312.         Enumeration<?> en = CommPortIdentifier.getPortIdentifiers();
  313.         CommPortIdentifier portId;
  314.         while (en.hasMoreElements()) {
  315.             portId = (CommPortIdentifier) en.nextElement();
  316.             if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
  317.                 String name = portId.getName();
  318.                 if (!portList.contains(name)) {
  319.                     portList.add(name);
  320.                 }
  321.             }
  322.         }
  323.         if (null == portList || portList.isEmpty()) {
  324.             showErrMesgbox("未找到可用的串行端口号,程序无法启动!");
  325.             System.exit(0);
  326.         }
  327.     }
  329.     /**
  330.      * 打开串行端口
  331.      * 
  332.      * @since 2012-3-23 上午12:03:07
  333.      */
  334.     public void openSerialPort() {
  335.         // 获取要打开的端口
  336.         try {
  337.             portId = CommPortIdentifier.getPortIdentifier(portname);
  338.         } catch (NoSuchPortException e) {
  339.             showErrMesgbox("抱歉,没有找到" + portname + "串行端口号!");
  340.             setComponentsEnabled(true);
  341.             return;
  342.         }
  343.         // 打开端口
  344.         try {
  345.             serialPort = (SerialPort) portId.open("JavaRs232", 3927);
  346.             statusLb.setText(portname + "串口已经打开!");
  347.         } catch (PortInUseException e) {
  348.             showErrMesgbox(portname + "端口已被占用,请检查!");
  349.             setComponentsEnabled(true);
  350.             return;
  351.         }
  352.         // 打开端口的IO流管道
  353.         try {
  354.             outputStream = serialPort.getOutputStream();
  355.             inputStream = serialPort.getInputStream();
  356.         } catch (IOException e) {
  357.             showErrMesgbox(e.getMessage());
  358.         }
  360.         // 给端口添加监听器
  361.         try {
  362.             serialPort.addEventListener(this);
  363.         } catch (TooManyListenersException e) {
  364.             showErrMesgbox(e.getMessage());
  365.         }
  367.         serialPort.notifyOnDataAvailable(true);
  368.         // 设置端口参数
  369.         try {
  370.             int rate = Integer.parseInt(this.rate);
  371.             int data = Integer.parseInt(this.data);
  372.             int stop = stopCombox.getSelectedIndex() + 1;
  373.             int parity = parityCombox.getSelectedIndex();
  374.             System.out.println("rate:" + rate);
  375.             System.out.println("data:" + data);
  376.             System.out.println("stop:" + stop);
  377.             System.out.println("parity:" + parity);
  378.             serialPort.setSerialPortParams(rate, data, stop, parity);
  379.         } catch (UnsupportedCommOperationException e) {
  380.             showErrMesgbox(e.getMessage());
  381.         }
  383.     }
  385.     /**
  386.      * 给串行端口发送数据
  387.      * 
  388.      * @since 2012-3-23 上午12:05:00
  389.      */
  390.     public void sendDataToSeriaPort(String mesg_info) {
  391.         byte[] sbuf = null;
  392.         String s_info = "";
  393.         sbuf = CRC16.getSendBuf(mesg_info);
  394.         s_info = CRC16.getBufHexStr(sbuf);
  395.         try {
  396.             sendCount++;
  397.             outputStream.write(hexStringToBytes(s_info));
  398.             outputStream.flush();
  399.             StringBuilder receivedMsg = new StringBuilder();
  400.             receivedMsg.append(receivedMsg)
  401.                     .append("发送数据: " + mesg_info + " \n");
  402.             readTa.append(receivedMsg.toString());
  403.         } catch (IOException e) {
  404.             showErrMesgbox(e.getMessage());
  405.             System.out.println(mesg_info);
  406.         }
  407.         statusLb.setText("  发送: " + sendCount
  408.                 + "                                      接收: " + reciveCount);
  409.     }
  411.     /**
  412.      * 关闭串行端口
  413.      * 
  414.      * @since 2012-3-23 上午12:05:28
  415.      */
  416.     public void closeSerialPort() {
  417.         try {
  418.             if (outputStream != null)
  419.                 outputStream.close();
  420.             if (serialPort != null)
  421.                 serialPort.close();
  422.             serialPort = null;
  423.             statusLb.setText(portname + "串口已经关闭!");
  424.             sendCount = 0;
  425.             reciveCount = 0;
  426.             sendTf.setText("");
  427.             sendTf1.setText("");
  428.             sendD1.setText("");
  429.             sendD2.setText("");
  430.             sendD3.setText("");
  431.             readTa.setText("");
  432.         } catch (Exception e) {
  433.             showErrMesgbox(e.getMessage());
  434.         }
  435.     }
  437.     /**
  438.      * 显示错误或警告信息
  439.      * 
  440.      * @param msg
  441.      *            信息
  442.      * @since 2012-3-23 上午12:05:47
  443.      */
  444.     public void showErrMesgbox(String msg) {
  445.         JOptionPane.showMessageDialog(this, msg);
  446.     }
  448.     /**
  449.      * 各组件行为事件监听
  450.      */
  451.     public void actionPerformed(ActionEvent e) {
  452.         String msg_info = "";
  453.         if (e.getSource() == portCombox || e.getSource() == rateCombox
  454.                 || e.getSource() == dataCombox || e.getSource() == stopCombox
  455.                 || e.getSource() == parityCombox) {
  456.             statusLb.setText(initStatus());
  457.         }
  458.         if (e.getSource() == openPortBtn) {
  459.             setComponentsEnabled(false);
  460.             System.err.println("打开");
  461.             openSerialPort();
  462.         }
  463.         if (e.getSource() == closePortBtn) {
  464.             if (serialPort != null) {
  465.                 closeSerialPort();
  466.             }
  467.             setComponentsEnabled(true);
  468.         }
  470.         if (e.getSource() == sendMsgBtn) {
  471.             if (serialPort == null) {
  472.                 showErrMesgbox("请先打开串行端口!");
  473.                 return;
  474.             }
  475.             mesg = sendTf.getText();
  476.             mesg_info_D1 = sendD1.getText();
  477.             mesg_info_D2 = sendD2.getText();
  478.             mesg_info_D3 = sendD3.getText();
  479.             String info_length = mesg + "" + mesg_info_D1 + "" + mesg_info_D2
  480.                     + "" + mesg_info_D3;
  481.             if (StrKit.isBlank(mesg) || StrKit.isBlank(mesg_info_D1)
  482.                     || StrKit.isBlank(mesg_info_D2)
  483.                     || StrKit.isBlank(mesg_info_D3)) {
  484.                 showErrMesgbox("4个文本框必须填写完整!");
  485.                 return;
  486.             } else {
  487.                 boolean result = info_length.matches("[0-9]+");
  488.                 if (result) {
  489.                     msg_info = stringToHex16(mesg_info_D1, mesg_info_D2,
  490.                             mesg_info_D3, mesg);
  491.                 } else {
  492.                     showErrMesgbox("输入内容中存在非法字符,内容只支持数字!");
  493.                     return;
  494.                 }
  496.                 if (msg_info.length() < 12) {
  497.                     showErrMesgbox("输入内容长度不够默认4个文本框总长度12位!");
  498.                     return;
  499.                 } else if (msg_info.length() > 12) {
  500.                     showErrMesgbox("输入内容长度超限默认4个文本框总长度12位!");
  501.                     return;
  502.                 }
  503.             }
  504.             sendDataToSeriaPort(msg_info);
  505.         }
  507.         if (e.getSource() == sendMsgBtn1) {
  508.             String sc_info = "";
  509.             if (serialPort == null) {
  510.                 showErrMesgbox("请先打开串行端口!");
  511.                 return;
  512.             }
  514.             switch (parityCombox1.getSelectedIndex()) {
  515.             case 0:
  516.                 sc_info = "0100000040";
  517.                 break;
  518.             case 1:
  519.                 sc_info = "030000000B";
  520.                 break;
  521.             case 2:
  522.                 sc_info = "0400000015";
  523.                 break;
  524.             default:
  525.                 break;
  526.             }
  527.             mesg1 = sendTf1.getText();
  529.             if (StrKit.isBlank(mesg1)) {
  530.                 showErrMesgbox("请填写地址信息!");
  531.                 return;
  532.             } else {
  533.                 boolean result = mesg1.matches("[0-9]+");
  534.                 if (result) {
  535.                     if (Integer.parseInt(mesg1) > 255) {
  536.                         showErrMesgbox("地址输入有误，1-255之间!");
  537.                         return;
  538.                     } else {
  539.                         msg_info = stringToHex16(mesg1);
  540.                     }
  542.                 } else {
  543.                     showErrMesgbox("输入内容中存在非法字符,内容只支持数字!");
  544.                     return;
  545.                 }
  546.             }
  547.             sendDataToSeriaPort(msg_info + "" + sc_info);
  548.         }
  549.     }
  551.     private String stringToHex16(String mesg12) {
  552.         String msg = "";
  553.         if (Integer.toString(Integer.parseInt(mesg12), 16).length() == 1) {
  554.             mesg12 = "0" + Integer.toString(Integer.parseInt(mesg12), 16);
  555.         } else {
  556.             mesg12 = Integer.toString(Integer.parseInt(mesg12), 16);
  557.         }
  558.         msg = mesg12;
  559.         return msg;
  561.     }
  563.     private String stringToHex16(String mesg_info_D1, String mesg_info_D2,
  564.             String mesg_info_D3, String mesg) {
  565.         String msg = "";
  566.         if (Integer.toString(Integer.parseInt(mesg_info_D1), 16).length() == 1) {
  567.             mesg_info_D1 = "0"
  568.                     + Integer.toString(Integer.parseInt(mesg_info_D1), 16);
  569.         } else {
  570.             mesg_info_D1 = Integer.toString(Integer.parseInt(mesg_info_D1), 16);
  571.         }
  573.         if (Integer.toString(Integer.parseInt(mesg_info_D3), 16).length() == 1) {
  574.             mesg_info_D3 = "0"
  575.                     + Integer.toString(Integer.parseInt(mesg_info_D3), 16);
  576.         } else {
  577.             mesg_info_D3 = Integer.toString(Integer.parseInt(mesg_info_D3), 16);
  578.         }
  579.         if (Integer.toString(Integer.parseInt(mesg_info_D2), 16).length() == 1) {
  580.             mesg_info_D2 = "000"
  581.                     + Integer.toString(Integer.parseInt(mesg_info_D2), 16);
  582.         } else if (Integer.toString(Integer.parseInt(mesg_info_D2), 16)
  583.                 .length() == 2) {
  584.             mesg_info_D2 = "00"
  585.                     + Integer.toString(Integer.parseInt(mesg_info_D2), 16);
  586.         } else if (Integer.toString(Integer.parseInt(mesg_info_D2), 16)
  587.                 .length() == 3) {
  588.             mesg_info_D2 = "0"
  589.                     + Integer.toString(Integer.parseInt(mesg_info_D2), 16);
  590.         } else {
  591.             mesg_info_D2 = Integer.toString(Integer.parseInt(mesg_info_D2), 16);
  592.         }
  594.         if (Integer.toString(Integer.parseInt(mesg), 16).length() == 1) {
  595.             mesg = "000" + Integer.toString(Integer.parseInt(mesg), 16);
  596.         } else if (Integer.toString(Integer.parseInt(mesg), 16).length() == 2) {
  597.             mesg = "00" + Integer.toString(Integer.parseInt(mesg), 16);
  598.         } else if (Integer.toString(Integer.parseInt(mesg), 16).length() == 3) {
  599.             mesg = "0" + Integer.toString(Integer.parseInt(mesg), 16);
  600.         } else {
  601.             mesg = Integer.toString(Integer.parseInt(mesg), 16);
  602.         }
  603.         msg = mesg_info_D1 + "" + mesg_info_D3 + "" + mesg + "" + mesg_info_D2;
  604.         return msg;
  605.     }
  607.     /**
  608.      * 端口事件监听
  609.      */
  610.     public void serialEvent(SerialPortEvent event) {
  611.         switch (event.getEventType()) {
  612.         case SerialPortEvent.BI:
  613.         case SerialPortEvent.OE:
  614.         case SerialPortEvent.FE:
  615.         case SerialPortEvent.PE:
  616.         case SerialPortEvent.CD:
  617.         case SerialPortEvent.CTS:
  618.         case SerialPortEvent.DSR:
  619.         case SerialPortEvent.RI:
  620.         case SerialPortEvent.OUTPUT_BUFFER_EMPTY:
  621.             break;
  622.         case SerialPortEvent.DATA_AVAILABLE:
  623.             byte[] readBuffer = null;
  624.             try {
  625.                 Thread.sleep(30l);
  626.             } catch (InterruptedException e2) {
  627.                 // TODO Auto-generated catch block
  628.                 e2.printStackTrace();
  629.             }
  630.             try {
  631.                 readBuffer = new byte[inputStream.available()];
  632.             } catch (IOException e1) {
  633.                 // TODO Auto-generated catch block
  634.                 e1.printStackTrace();
  635.             }
  637.             try {
  638.                 while (inputStream.available() > 0) {
  639.                     inputStream.read(readBuffer);
  640.                 }
  641.                 System.out.println(byte2hex(readBuffer));
  642.                 String msg = byte2hex(readBuffer).trim();
  643.                 msg = msg.replaceAll(" ", "");
  644.                 String v_info = Float16(msg.substring(10, 14) + ""
  645.                         + msg.substring(6, 10));
  646.                 StringBuilder receivedMsg = new StringBuilder();
  647.                 receivedMsg.append(receivedMsg).append(
  648.                         "回复数据: " + v_info + "V\n");
  649.                 readTa.append(receivedMsg.toString());
  650.                 reciveCount++;
  651.                 statusLb.setText("  发送: " + sendCount
  652.                         + "                                      接收: "
  653.                         + reciveCount);
  654.             } catch (IOException e) {
  656.             }
  658.         }
  659.     }
  661.     /**
  662.      * 设置各组件的开关状态
  663.      * 
  664.      * @param enabled
  665.      *            状态
  666.      * @since 2012-3-23 上午12:06:24
  667.      */
  668.     public void setComponentsEnabled(boolean enabled) {
  669.         openPortBtn.setEnabled(enabled);
  670.         openPortBtn.setEnabled(enabled);
  671.         portCombox.setEnabled(enabled);
  672.         rateCombox.setEnabled(enabled);
  673.         dataCombox.setEnabled(enabled);
  674.         stopCombox.setEnabled(enabled);
  675.         parityCombox.setEnabled(enabled);
  676.     }
  678.     /**
  679.      * 运行主函数
  680.      * 
  681.      * @param args
  682.      * @since 2012-3-23 上午12:06:45
  683.      */
  684.     public static void main(String[] args) {
  685.         new JavaRs232();
  686.     }
  688.     public String readPort() {
  689.         byte[] readBuffer = new byte[50];
  691.         try {
  692.             while (inputStream.available() > 0) {
  693.                 inputStream.read(readBuffer);
  694.             }
  695.             StringBuilder receivedMsg = new StringBuilder("/-- ");
  696.             receivedMsg.append(new String(readBuffer).trim()).append(" --/\n");
  697.             readTa.append(receivedMsg.toString());
  698.             reciveCount++;
  699.             statusLb.setText("  发送: " + sendCount
  700.                     + "                                      接收: "
  701.                     + reciveCount);
  702.         } catch (IOException e) {
  703.             showErrMesgbox(e.getMessage());
  704.         }
  705.         return "";
  706.     }
  708.     private static String byte2hex(byte[] buffer) {
  709.         String h = "";
  711.         for (int i = 0; i < buffer.length; i++) {
  712.             String temp = Integer.toHexString(buffer[i] & 0xFF);
  713.             if (temp.length() == 1) {
  714.                 temp = "0" + temp;
  715.             }
  716.             h = h + " " + temp;
  717.         }
  719.         return h;
  721.     }
  723.     public static byte[] hexStringToBytes(String hexString) {
  724.         if (hexString == null || hexString.equals("")) {
  725.             return null;
  726.         }
  727.         hexString = hexString.toUpperCase();
  728.         int length = hexString.length() / 2;
  729.         char[] hexChars = hexString.toCharArray();
  730.         byte[] d = new byte[length];
  731.         for (int i = 0; i < length; i++) {
  732.             int pos = i * 2;
  733.             d[i] = (byte) (charToByte(hexChars[pos]) << 4 | charToByte(hexChars[pos + 1]));
  734.         }
  735.         return d;
  736.     }
  738.     private static byte charToByte(char c) {
  739.         return (byte) "0123456789ABCDEF".indexOf(c);
  740.     }
  742.     public static String Float16(String msg) {
  743.         Float value = Float.intBitsToFloat(Integer.valueOf(msg.trim(), 16));
  744.         Float f = 0.15490197f;
  745.         return value + "";
  746.     }
  747. }

CRC16算法:

  1. package com.jetf.mm;
  4. public class CRC16 {
  5.     static final String HEXES = "0123456789ABCDEF";
  6.     byte uchCRCHi = (byte) 0xFF;
  7.     byte uchCRCLo = (byte) 0xFF;
  8.     private static byte[] auchCRCHi = { 0x00, (byte) 0xC1, (byte) 0x81,
  9.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  10.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  11.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
  12.             (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  13.             (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,
  14.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01,
  15.             (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,
  16.             (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  17.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  18.             (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01,
  19.             (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0,
  20.             (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  21.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  22.             (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00,
  23.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
  24.             (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  25.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  26.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  27.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,
  28.             (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,
  29.             (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  30.             (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01,
  31.             (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,
  32.             (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  33.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  34.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  35.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,
  36.             (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,
  37.             (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,
  39.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01,
  40.             (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,
  41.             (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  42.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  43.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  44.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
  45.             (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  46.             (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,
  47.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  48.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
  49.             (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80,
  50.             (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,
  51.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  52.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,
  53.             (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,
  54.             (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  55.             (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00,
  56.             (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,
  57.             (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,
  58.             (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,
  59.             (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,
  60.             (byte) 0xC1, (byte) 0x81, (byte) 0x40 };
  61.     private static byte[] auchCRCLo = { (byte) 0x00, (byte) 0xC0, (byte) 0xC1,
  62.             (byte) 0x01, (byte) 0xC3, (byte) 0x03, (byte) 0x02, (byte) 0xC2,
  63.             (byte) 0xC6, (byte) 0x06, (byte) 0x07, (byte) 0xC7, (byte) 0x05,
  64.             (byte) 0xC5, (byte) 0xC4, (byte) 0x04, (byte) 0xCC, (byte) 0x0C,
  65.             (byte) 0x0D, (byte) 0xCD, (byte) 0x0F, (byte) 0xCF, (byte) 0xCE,
  66.             (byte) 0x0E, (byte) 0x0A, (byte) 0xCA, (byte) 0xCB, (byte) 0x0B,
  67.             (byte) 0xC9, (byte) 0x09, (byte) 0x08, (byte) 0xC8, (byte) 0xD8,
  68.             (byte) 0x18, (byte) 0x19, (byte) 0xD9, (byte) 0x1B, (byte) 0xDB,
  69.             (byte) 0xDA, (byte) 0x1A, (byte) 0x1E, (byte) 0xDE, (byte) 0xDF,
  70.             (byte) 0x1F, (byte) 0xDD, (byte) 0x1D, (byte) 0x1C, (byte) 0xDC,
  71.             (byte) 0x14, (byte) 0xD4, (byte) 0xD5, (byte) 0x15, (byte) 0xD7,
  72.             (byte) 0x17, (byte) 0x16, (byte) 0xD6, (byte) 0xD2, (byte) 0x12,
  73.             (byte) 0x13, (byte) 0xD3, (byte) 0x11, (byte) 0xD1, (byte) 0xD0,
  74.             (byte) 0x10, (byte) 0xF0, (byte) 0x30, (byte) 0x31, (byte) 0xF1,
  75.             (byte) 0x33, (byte) 0xF3, (byte) 0xF2, (byte) 0x32, (byte) 0x36,
  76.             (byte) 0xF6, (byte) 0xF7, (byte) 0x37, (byte) 0xF5, (byte) 0x35,
  77.             (byte) 0x34, (byte) 0xF4, (byte) 0x3C, (byte) 0xFC, (byte) 0xFD,
  78.             (byte) 0x3D, (byte) 0xFF, (byte) 0x3F, (byte) 0x3E, (byte) 0xFE,
  79.             (byte) 0xFA, (byte) 0x3A, (byte) 0x3B, (byte) 0xFB, (byte) 0x39,
  80.             (byte) 0xF9, (byte) 0xF8, (byte) 0x38, (byte) 0x28, (byte) 0xE8,
  81.             (byte) 0xE9, (byte) 0x29, (byte) 0xEB, (byte) 0x2B, (byte) 0x2A,
  82.             (byte) 0xEA, (byte) 0xEE, (byte) 0x2E, (byte) 0x2F, (byte) 0xEF,
  83.             (byte) 0x2D, (byte) 0xED, (byte) 0xEC, (byte) 0x2C, (byte) 0xE4,
  84.             (byte) 0x24, (byte) 0x25, (byte) 0xE5, (byte) 0x27, (byte) 0xE7,
  85.             (byte) 0xE6, (byte) 0x26, (byte) 0x22, (byte) 0xE2, (byte) 0xE3,
  86.             (byte) 0x23, (byte) 0xE1, (byte) 0x21, (byte) 0x20, (byte) 0xE0,
  87.             (byte) 0xA0, (byte) 0x60, (byte) 0x61, (byte) 0xA1, (byte) 0x63,
  88.             (byte) 0xA3, (byte) 0xA2, (byte) 0x62, (byte) 0x66, (byte) 0xA6,
  89.             (byte) 0xA7, (byte) 0x67, (byte) 0xA5, (byte) 0x65, (byte) 0x64,
  90.             (byte) 0xA4, (byte) 0x6C, (byte) 0xAC, (byte) 0xAD, (byte) 0x6D,
  92.             (byte) 0xAF, (byte) 0x6F, (byte) 0x6E, (byte) 0xAE, (byte) 0xAA,
  93.             (byte) 0x6A, (byte) 0x6B, (byte) 0xAB, (byte) 0x69, (byte) 0xA9,
  94.             (byte) 0xA8, (byte) 0x68, (byte) 0x78, (byte) 0xB8, (byte) 0xB9,
  95.             (byte) 0x79, (byte) 0xBB, (byte) 0x7B, (byte) 0x7A, (byte) 0xBA,
  96.             (byte) 0xBE, (byte) 0x7E, (byte) 0x7F, (byte) 0xBF, (byte) 0x7D,
  97.             (byte) 0xBD, (byte) 0xBC, (byte) 0x7C, (byte) 0xB4, (byte) 0x74,
  98.             (byte) 0x75, (byte) 0xB5, (byte) 0x77, (byte) 0xB7, (byte) 0xB6,
  99.             (byte) 0x76, (byte) 0x72, (byte) 0xB2, (byte) 0xB3, (byte) 0x73,
  100.             (byte) 0xB1, (byte) 0x71, (byte) 0x70, (byte) 0xB0, (byte) 0x50,
  101.             (byte) 0x90, (byte) 0x91, (byte) 0x51, (byte) 0x93, (byte) 0x53,
  102.             (byte) 0x52, (byte) 0x92, (byte) 0x96, (byte) 0x56, (byte) 0x57,
  103.             (byte) 0x97, (byte) 0x55, (byte) 0x95, (byte) 0x94, (byte) 0x54,
  104.             (byte) 0x9C, (byte) 0x5C, (byte) 0x5D, (byte) 0x9D, (byte) 0x5F,
  105.             (byte) 0x9F, (byte) 0x9E, (byte) 0x5E, (byte) 0x5A, (byte) 0x9A,
  106.             (byte) 0x9B, (byte) 0x5B, (byte) 0x99, (byte) 0x59, (byte) 0x58,
  107.             (byte) 0x98, (byte) 0x88, (byte) 0x48, (byte) 0x49, (byte) 0x89,
  108.             (byte) 0x4B, (byte) 0x8B, (byte) 0x8A, (byte) 0x4A, (byte) 0x4E,
  109.             (byte) 0x8E, (byte) 0x8F, (byte) 0x4F, (byte) 0x8D, (byte) 0x4D,
  110.             (byte) 0x4C, (byte) 0x8C, (byte) 0x44, (byte) 0x84, (byte) 0x85,
  111.             (byte) 0x45, (byte) 0x87, (byte) 0x47, (byte) 0x46, (byte) 0x86,
  112.             (byte) 0x82, (byte) 0x42, (byte) 0x43, (byte) 0x83, (byte) 0x41,
  113.             (byte) 0x81, (byte) 0x80, (byte) 0x40 };
  114.     public int value;
  116.     public CRC16() {
  117.         value = 0;
  118.     }
  120.     public void update(byte[] puchMsg, int usDataLen) {
  121.         int uIndex; // int i = 0;
  122.         for (int i = 0; i < usDataLen; i++) {
  123.             uIndex = (uchCRCHi ^ puchMsg[i]) & 0xff;
  124.             uchCRCHi = (byte) (uchCRCLo ^ auchCRCHi[uIndex]);
  125.             uchCRCLo = auchCRCLo[uIndex];
  126.         }
  127.         value = ((((int) uchCRCHi) << 8 | (((int) uchCRCLo) & 0xff))) & 0xffff;
  128.         return;
  129.     }
  131.     public void reset() {
  132.         value = 0;
  133.         uchCRCHi = (byte) 0xff;
  134.         uchCRCLo = (byte) 0xff;
  135.     }
  137.     public int getValue() {
  138.         return value;
  140.     }
  142.     private static byte uniteBytes(byte src0, byte src1) {
  143.         byte _b0 = Byte.decode("0x" + new String(new byte[] { src0 }))
  144.                 .byteValue();
  145.         _b0 = (byte) (_b0 << 4);
  146.         byte _b1 = Byte.decode("0x" + new String(new byte[] { src1 }))
  147.                 .byteValue();
  148.         byte ret = (byte) (_b0 ^ _b1);
  149.         return ret;
  150.     }
  152.     private static byte[] HexString2Buf(String src) {
  153.         int len = src.length();
  154.         byte[] ret = new byte[len / 2 + 2];
  155.         byte[] tmp = src.getBytes();
  156.         for (int i = 0; i < len; i += 2) {
  157.             ret[i / 2] = uniteBytes(tmp[i], tmp[i + 1]);
  158.         }
  159.         return ret;
  160.     }
  162.     public static byte[] getSendBuf(String toSend) {
  163.         byte[] bb = HexString2Buf(toSend);
  164.         CRC16 crc16 = new CRC16();
  165.         crc16.update(bb, bb.length - 2);
  166.         int ri = crc16.getValue();
  167.         bb[bb.length - 1] = (byte) (0xff & ri);
  168.         bb[bb.length - 2] = (byte) ((0xff00 & ri) >> 8);
  169.         return bb;
  170.     }
  172.     public static boolean checkBuf(byte[] bb) {
  173.         CRC16 crc16 = new CRC16();
  174.         crc16.update(bb, bb.length - 2);
  175.         int ri = crc16.getValue();
  176.         if (bb[bb.length - 1] == (byte) (ri & 0xff)
  177.                 && bb[bb.length - 2] == (byte) ((0xff00 & ri) >> 8))
  178.             return true;
  179.         return false;
  180.     }
  182.     public static String getBufHexStr(byte[] raw) {
  183.         if (raw == null) {
  184.             return null;
  185.         }
  186.         final StringBuilder hex = new StringBuilder(2 * raw.length);
  187.         for (final byte b : raw) {
  188.             hex.append(HEXES.charAt((b & 0xF0) >> 4)).append(
  189.                     HEXES.charAt((b & 0x0F)));
  190.         }
  191.         return hex.toString().toLowerCase();
  192.     }
  194.     /****
  195.      * * 得到CRC验证 } } } } } }
  196.      * 
  197.      * @param tt
  198.      *            * @return
  199.      */
  200.     public static String getCrc(String tem) { // String tem=""; // for(int
  201.                                                 // i=0;i<tt.length;i++){ //
  202.                                                 // tem+=tt[i]; //
  203.                                                 // System.out.println("这是传入的值"+tt[i]);
  204.                                                 // // }
  205.         byte[] sbuf = CRC16.getSendBuf(tem);
  206.         System.out.println("这是得到的crc" + CRC16.getBufHexStr(sbuf));
  207.         return CRC16.getBufHexStr(sbuf).substring(12, 16).toLowerCase();
  208.     }
  210.     /** 得到要发送的数据 * @param args */
  211.     public static String getSendData(String[] tt) {
  212.         String tem = "";
  213.         for (int i = 0; i < tt.length; i++) {
  214.             tem += tt[i];
  215.         }
  216.         byte[] sbuf = CRC16.getSendBuf(tem);
  217.         return CRC16.getBufHexStr(sbuf);
  218.     }
  220.     public static byte[] getSendBuf2(String[] tt) {
  221.         String tem = "";
  222.         for (int i = 0; i < tt.length; i++) {
  223.             tem += tt[i];
  224.         }
  225.         byte[] bb = HexString2Buf(tem);
  226.         CRC16 crc16 = new CRC16();
  227.         crc16.update(bb, bb.length - 2);
  228.         int ri = crc16.getValue();
  229.         bb[bb.length - 1] = (byte) (0xff & ri);
  230.         bb[bb.length - 2] = (byte) ((0xff00 & ri) >> 8);
  231.         return bb;
  232.     }
  234.     public static void main(String[] args) { // TODO Auto-generated method stub
  235.                                                 // //0103040a3d3fb739a1----sendB
  236.                                                 // //010304b8523ffeef32----sendB
  237.         String ms = "";
  238.         byte[] sbuf = CRC16.getSendBuf("010400000015");
  239.         System.out.println(CRC16.getBufHexStr(sbuf));
  240.     }
  242. }

Float16算法:

  1. package com.jetf.mm;
  3. public class Float16 {
  4.     @SuppressWarnings("unused")
  5.     public static void main(String[] args) {
  6.         String s = "057e";
  7.         Float value = Float.intBitsToFloat(Integer.valueOf(s.trim(), 16));
  8.         // Double
  9.         System.out.println(Integer.valueOf(s.trim(), 16));
  10.         Float f = 225.92f;
  11.         System.out.println(Integer.toHexString(Float.floatToIntBits(f)));
  12.     }
  13. }

发表评论

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

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

相关阅读

    相关 串口通讯介绍

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

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

    相关 java串口通讯实例

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

    小咪咪小咪咪/ 0 赞/ 313 阅读

    相关 串口通讯之 CRC校验

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

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