• java 串口通讯

     参考 Java实现串口通信_我不吃芹菜的博客-CSDN博客_java 串口

     java 串口通讯，直接控制报警灯的灯亮和播放音乐。

    报警灯接口文档：接收16进制数组 。

    报警灯指令文档：

     工具方法： hexToByte （）   把16进制 转成 bit，传参会用到。

    1.     public static byte hexToByte(String arg) {
    2.         int val = Integer.valueOf(arg, 16).intValue();
    3.         byte c = (byte) (val & 0xff);
    4.         return c;
    5.     }

    实现类 Chuankou.java

    1. package com.hs.server;
    2.  
    3. import com.hs.util.NumberUtils;
    4. import gnu.io.*;
    5. import lombok.extern.slf4j.Slf4j;
    6.  
    7. import java.io.IOException;
    8. import java.io.OutputStream;
    9. import java.util.Arrays;
    10. import java.util.Enumeration;
    11.  
    12. /**
    13.  * 串口通讯  modbus 485
    14.  */
    15. @Slf4j
    16. public class ChuanKou {
    17.    public static SerialPort port = null;
    18.     /**
    19.      * 打开电脑上指定的串口
    20.      *
    21.      * @param portName 端口名称，如 COM1，为 null 时，默认使用电脑中能用的端口中的第一个
    22.      * @param b        波特率(baudrate)，如 9600
    23.      * @param d        数据位（datebits），如 SerialPort.DATABITS_8 = 8
    24.      * @param s        停止位（stopbits），如 SerialPort.STOPBITS_1 = 1
    25.      * @param p        校验位 (parity)，如 SerialPort.PARITY_NONE = 0
    26.      * @return 打开的串口对象，打开失败时，返回 null
    27.      */
    28.     public static final SerialPort openComPort(String portName, int b, int d, int s, int p) {
    29.         Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers();
    30.         CommPort commPort = null;
    31.         try {
    32.             //当没有传入可用的 com 口时，默认使用电脑中可用的 com 口中的第一个
    33. //            if (portName == null || "".equals(portName)) {
    34. //                List<String> comPortList = findSystemAllComPort();
    35. //                if (comPortList != null && comPortList.size() > 0) {
    36. //                    portName = comPortList.get(0);
    37. //                }
    38. //            }
    39.             log.info("开始打开串口：portName=" + portName + ",baudrate=" + b + ",datebits=" + d + ",stopbits=" + s + ",parity=" + p);
    40.  
    41.             //通过端口名称识别指定 COM 端口
    42.             CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(portName);
    43.             /**
    44.              * open(String TheOwner, int i)：打开端口
    45.              * TheOwner 自定义一个端口名称，随便自定义即可
    46.              * i：打开的端口的超时时间，单位毫秒，超时则抛出异常：PortInUseException if in use.
    47.              * 如果此时串口已经被占用，则抛出异常：gnu.io.PortInUseException: Unknown Application
    48.              */
    49.             commPort = portIdentifier.open(portName, 5000);
    50.             /**
    51.              * 判断端口是不是串口
    52.              * public abstract class SerialPort extends CommPort
    53.              */
    54.             if (commPort instanceof SerialPort) {
    55.                 SerialPort serialPort = (SerialPort) commPort;
    56.                 port = serialPort;
    57.                 /**
    58.                  * 设置串口参数：setSerialPortParams( int b, int d, int s, int p )
    59.                  * b：波特率（baudrate）
    60.                  * d：数据位（datebits），SerialPort 支持 5,6,7,8
    61.                  * s：停止位（stopbits），SerialPort 支持 1,2,3
    62.                  * p：校验位 (parity)，SerialPort 支持 0,1,2,3,4
    63.                  * 如果参数设置错误，则抛出异常：gnu.io.UnsupportedCommOperationException: Invalid Parameter
    64.                  * 此时必须关闭串口，否则下次 portIdentifier.open 时会打不开串口，因为已经被占用
    65.                  */
    66.                 serialPort.setSerialPortParams(b, d, s, p);
    67.                 log.info("打开串口 " + portName + " 成功...");
    68.                 return serialPort;
    69.             } else {
    70.                 log.error("当前端口 " + commPort.getName() + " 不是串口...");
    71.             }
    72.         } catch (NoSuchPortException e) {
    73.             log.info("NoSuchPortException === ");
    74.             e.printStackTrace();
    75.         } catch (PortInUseException e) {
    76.             log.warn("串口 " + portName + " 已经被占用，请先解除占用...");
    77.             e.printStackTrace();
    78.         } catch (UnsupportedCommOperationException e) {
    79.             log.warn("串口参数设置错误，关闭串口，数据位[5-8]、停止位[1-3]、验证位[0-4]...");
    80.             e.printStackTrace();
    81.             if (commPort != null) {//此时必须关闭串口，否则下次 portIdentifier.open 时会打不开串口，因为已经被占用
    82.                 commPort.close();
    83.             }
    84.         }
    85.         log.error("打开串口 " + portName + " 失败...");
    86.         return null;
    87.     }
    88.  
    89.     /**
    90.      * 往串口发送数据
    91.      *
    92.      * @param serialPort 串口对象
    93.      */
    94.     public static void sendDataToComPort(SerialPort serialPort, byte[] orders) {
    95.         OutputStream outputStream = null;
    96.         try {
    97.             if (serialPort != null) {
    98.                 outputStream = serialPort.getOutputStream();
    99.                 outputStream.write(orders);
    100.                 outputStream.flush();
    101.                 log.info("往串口 " + serialPort.getName() + " 发送数据：" + Arrays.toString(orders) + " 完成...");
    102.             } else {
    103.                 log.error("gnu.io.SerialPort 为null，取消数据发送...");
    104.             }
    105.         } catch (IOException e) {
    106.             e.printStackTrace();
    107.         } finally {
    108.             if (outputStream != null) {
    109.                 try {
    110.                     outputStream.close();
    111.                 } catch (IOException e) {
    112.                     e.printStackTrace();
    113.                 }
    114.             }
    115.         }
    116.     }
    117.     /**
    118.      * 关闭串口
    119.      *
    120.      * @param serialPort 待关闭的串口对象
    121.      */
    122.     public static void closeComPort(SerialPort serialPort) {
    123.         if (serialPort != null) {
    124.             serialPort.close();
    125.             log.info("关闭串口 " + serialPort.getName());
    126.         }else{
    127.             log.info("串口未关闭，串口为空");
    128.         }
    129.     }
    130.  
    131.     public static void main(String[] args) {
    132.         String string = Integer.toHexString(31);
    133.         System.out.println(string);
    134. //        SerialPort serialPort = ChuanKou.openComPort("COM7", 9600, 8, 1, 502);
    135. //        byte[] orders = {01,06,31,03,00,04};
    136. //        ChuanKou.sendDataToComPort(serialPort,orders);
    137.         System.out.println(Integer.parseInt(string,16));;
    138.     }
    139.  
    140.     public static void WARN(String com){
    141.         if(com==null){
    142.             com="COM7";
    143.         }
    144.         SerialPort serialPort = ChuanKou.openComPort(com, 9600, 8, 1, 0);
    145.         byte[] orders = {NumberUtils.hexToByte("FF"),
    146.                 NumberUtils.hexToByte("06"),
    147.                 NumberUtils.hexToByte("11"),
    148.                 NumberUtils.hexToByte("03"),
    149.                 NumberUtils.hexToByte("00"),
    150.                 NumberUtils.hexToByte("04"),
    151.                 NumberUtils.hexToByte("68"),
    152.                 NumberUtils.hexToByte("EB")};
    153.         ChuanKou.sendDataToComPort(serialPort,orders);
    154.         ChuanKou.closeComPort(ChuanKou.port);
    155.  
    156.     }
    157.  
    158.  
    159. }

    遇到的问题及解决

    一、java崩溃，原因缺少RXTXcomm.jar 包 和rxtxSerial.dll 配置

    no rxtxSerial64 in java.library.path thrown while loading gnu.io.RXTXCommDriver

    解决： 

    1、将rxtxParallel.dll和rxtxSerial.dll文件放到${JAVA_HOME}（jdk目录,不是jre目录）\jre\bin目录下

    如： C:\Program Files\Java\jdk1.8.0_31\jre\bin
    2、将RXTXcomm.jar 包放到{JAVA_HOME}jdk目录\jre\lib\ext目录下即可

    如：  C:\Program Files\Java\jdk1.8.0_31\jre\lib\ext

    如图：

    二、 jdk版本不合适

    # A fatal error has been detected by the Java Runtime Environment:

    java version "1.8.0_341"
    Java(TM) SE Runtime Environm

    See problematic frame for where to report the bug.

    解决：jdk使用1.8.031版本。 

    相关附件传送门：

    链接：https://pan.baidu.com/s/1OgZ-SxJwQ58riKx620P9Ew 
    提取码：jf98

    补充：获取校验码，传入参数的前几位，获取后两位的校验码，每次换前面的参数都要重新获取校验码。比如选择绿灯红灯还是爆闪常亮。

    1. /**
    2.      * 获取校验码
    3.      * crc16 X16+x15+x2+1
    4.      * 16进制报文是 02 03 00 00 00 40 CRC16
    5.      * 传输的str：“020300000040”
    6.      * 结果：4409
    7.      * @param str
    8.      * @return
    9.      */
    10.     public static String getCRC(String str) {
    11.         byte[] bytes = NumberUtils.hexStringToBytes(str);
    12.         int CRC = 0x0000ffff;
    13.         int POLYNOMIAL = 0x0000a001;
    14.  
    15.         int i, j;
    16.         for (i = 0; i < bytes.length; i++) {
    17.             CRC ^= ((int) bytes[i] & 0x000000ff);
    18.             for (j = 0; j < 8; j++) {
    19.                 if ((CRC & 0x00000001) != 0) {
    20.                     CRC >>= 1;
    21.                     CRC ^= POLYNOMIAL;
    22.                 } else {
    23.                     CRC >>= 1;
    24.                 }
    25.             }
    26.         }
    27.         String crc = Integer.toHexString(CRC);
    28.         if (crc.length() == 2) {
    29.             crc = "00" + crc;
    30.         } else if (crc.length() == 3) {
    31.             crc = "0" + crc;
    32.         }
    33.         crc = crc.substring(2, 4) + crc.substring(0, 2);
    34.         return crc.toUpperCase();
    35.     }

    拓展：

    控制报警灯亮的时间的方法有两种：

    一是选择想要播放时间长的音乐文件

    二是用程序控制，亮灯指令和关灯指令，中间休息想要的时间。 

    1.    public static void WARN(String com){
    2.         if(com==null){
    3.             com="COM7";
    4.         }
    5.         SerialPort serialPort = ChuanKou.openComPort(com, 9600, 8, 1, 0);
    6.         byte[] orders = {NumberUtils.hexToByte("FF"),
    7.                 NumberUtils.hexToByte("06"),
    8.                 NumberUtils.hexToByte("31"),
    9.                 NumberUtils.hexToByte("03"),
    10.                 NumberUtils.hexToByte("00"),
    11.                 NumberUtils.hexToByte("04"),
    12.                 NumberUtils.hexToByte("63"),
    13.                 NumberUtils.hexToByte("2B")};
    14.         ChuanKou.sendDataToComPort(serialPort,orders);//制定串口发送指令
    15.         ChuanKou.closeComPort(ChuanKou.port);//关闭报警灯
    16.  
    17.     }

  • 相关阅读:
    wstunnel (websocket模式ssh)
    python爬虫实战——抖音
    2023宁夏大学计算机考研信息汇总
    【SpringSecurity】SpringSecurity2.7.x 的使用（03）
    AotuDL中Linux环境下运行pix2pix-tensorflow的环境配置（tensorflow==1.8.0 python==3.6）
    mysql高阶语句（一）
    Linux基础内容（12）—— 程序地址空间
    使用Java实现一个简单的贪吃蛇小游戏
    uniapp——uniapp基础知识
    抢先看！阿里发布2023最新版分布式核心小册，GitHub标星破已千万
  • 原文地址：https://blog.csdn.net/somdip/article/details/126469213