码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift

  • 基于 Netty + RXTX 的无协议 COM 通讯案例实现

    参考

    Netty集成串口RXTX编程，为什么过时了？

    Java版本

    1. java version "1.8.0_231"
    2. Java(TM) SE Runtime Environment (build 1.8.0_231-b11)
    3. Java HotSpot(TM) 64-Bit Server VM (build 25.231-b11, mixed mode)

    RXTX版本

    1. # 官网 http://rxtx.qbang.org/wiki/index.php/Download
    2. # 版本 rxtx-2.2pre1-bins

    POM依赖

    1.     <dependencies>
    2.         <dependency>
    3.             <groupId>org.projectlombok</groupId>
    4.             <artifactId>lombok</artifactId>
    5.             <version>1.18.24</version>
    6.         </dependency>
    7.         <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
    8.         <dependency>
    9.             <groupId>io.netty</groupId>
    10.             <artifactId>netty-all</artifactId>
    11.             <version>4.1.42.Final</version>
    12.         </dependency>
    13.     </dependencies>

    Com 配置类封装

    1. package com.yushanma.config;
    2.  
    3. import io.netty.channel.rxtx.RxtxChannelConfig;
    4. import lombok.Data;
    5.  
    6. /**
    7.  * desc
    8.  *
    9.  * @author Yushanma
    10.  * @since 2023/6/4 17:20
    11.  */
    12. @Data
    13. public final class ComConfig {
    14.     /**
    15.      * 串口名称，以COM开头(COM0、COM1、COM2等等)
    16.      */
    17.     private String serialPortName;
    18.     /**
    19.      * 波特率， 默认：9600
    20.      */
    21.     private int baudRate = 9600;
    22.     /**
    23.      * 数据位 默认8位
    24.      * 可以设置的值：SerialPort.DATABITS_5、SerialPort.DATABITS_6、SerialPort.DATABITS_7、SerialPort.DATABITS_8
    25.      */
    26.     private RxtxChannelConfig.Databits dataBits = RxtxChannelConfig.Databits.DATABITS_8;
    27.     /**
    28.      * 停止位
    29.      * 可以设置的值：SerialPort.STOPBITS_1、SerialPort.STOPBITS_2、SerialPort.STOPBITS_1_5
    30.      */
    31.     private RxtxChannelConfig.Stopbits stopBits = RxtxChannelConfig.Stopbits.STOPBITS_1;
    32.     /**
    33.      * 校验位
    34.      * 可以设置的值：SerialPort.PARITY_NONE、SerialPort.PARITY_ODD、SerialPort.PARITY_EVEN、SerialPort.PARITY_MARK、SerialPort.PARITY_SPACE
    35.      */
    36.     private RxtxChannelConfig.Paritybit parity = RxtxChannelConfig.Paritybit.NONE;
    37. }

    字节编解码工具

    1. package com.yushanma.utils;
    2.  
    3. import java.util.List;
    4. import io.netty.buffer.ByteBuf;
    5. import io.netty.channel.ChannelHandlerContext;
    6. import io.netty.handler.codec.ByteToMessageDecoder;
    7.  
    8. /**
    9.  * 解码器
    10.  *
    11.  * @author Yushanma
    12.  * @since 2023/6/4 17:17
    13.  */
    14. public class ByteArrayDecoder extends ByteToMessageDecoder {
    15.  
    16.     @Override
    17.     protected void decode(ChannelHandlerContext ctx, ByteBuf in, List out) throws Exception {
    18.         // 标记一下当前的 readIndex 的位置
    19.         in.markReaderIndex();
    20.         int dataLength = in.readableBytes();
    21.         byte[] array = new byte[dataLength];
    22.         in.readBytes(array, 0, dataLength);
    23.         if(array.length > 0){
    24.             out.add(array);
    25.         }
    26.     }
    27. }
      28.  

      1. package com.yushanma.utils;
      2.  
      3. import io.netty.buffer.ByteBuf;
      4. import io.netty.channel.ChannelHandlerContext;
      5. import io.netty.handler.codec.MessageToByteEncoder;
      6.  
      7. /**
      8.  * 编码器
      9.  *
      10.  * @author Yushanma
      11.  * @since 2023/6/4 17:18
      12.  */
      13. public class ByteArrayEncoder extends MessageToByteEncoder<byte[]> {
      14.  
      15.     @Override
      16.     protected void encode(ChannelHandlerContext ctx, byte[] msg, ByteBuf out) throws Exception {
      17.         // 消息体，包含我们要发送的数据
      18.         out.writeBytes(msg);
      19.     }
      20. }
       

      Channel 事件处理器
       

      1. package com.yushanma.handler;
      2.  
      3. import io.netty.buffer.ByteBuf;
      4. import io.netty.buffer.Unpooled;
      5. import io.netty.channel.ChannelHandler;
      6. import io.netty.channel.ChannelHandlerContext;
      7. import io.netty.channel.SimpleChannelInboundHandler;
      8. import io.netty.util.ReferenceCountUtil;
      9.  
      10. import java.time.LocalDateTime;
      11.  
      12. /**
      13.  * Channel 事件处理器
      14.  * 需要处理什么事件就重写 SimpleChannelInboundHandler 中对应的方法
      15.  * @author Yushanma
      16.  * @since 2023/6/4 17:19
      17.  */
      18. @ChannelHandler.Sharable
      19. public class RxtxHandler extends SimpleChannelInboundHandler<byte[]> {
      20.  
      21.     /**
      22.      * 当 COM 口接收到数据时
      23.      * 根据不同的进制对数据包进行解码
      24.      * 然后执行对应业务逻辑
      25.      * @param ctx 上下文
      26.      * @param msg 接收到的数据包
      27.      * @throws Exception 异常
      28.      */
      29.     @Override
      30.     protected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {
      31.  
      32.         // 十六进制发送编解码
      33.         int dataLength = msg.length;
      34.         ByteBuf buf = Unpooled.buffer(dataLength);
      35.         buf.writeBytes(msg);
      36.         System.out.println(LocalDateTime.now() + "接收到：");
      37.         while(buf.isReadable()){
      38.             System.out.print(buf.readByte() + " ");
      39.         }
      40.         System.out.println();
      41.         // 释放资源
      42.         ReferenceCountUtil.release(msg);
      43.     }
      44. }
       

      启动类封装
       

      1. package com.yushanma.server;
      2.  
      3. import com.yushanma.config.ComConfig;
      4. import com.yushanma.handler.RxtxHandler;
      5. import com.yushanma.utils.ByteArrayDecoder;
      6. import com.yushanma.utils.ByteArrayEncoder;
      7. import io.netty.bootstrap.Bootstrap;
      8. import io.netty.buffer.ByteBuf;
      9. import io.netty.buffer.Unpooled;
      10. import io.netty.channel.ChannelFuture;
      11. import io.netty.channel.ChannelInitializer;
      12. import io.netty.channel.EventLoop;
      13. import io.netty.channel.EventLoopGroup;
      14. import io.netty.channel.oio.OioEventLoopGroup;
      15. import io.netty.channel.rxtx.RxtxChannel;
      16. import io.netty.channel.rxtx.RxtxDeviceAddress;
      17. import io.netty.util.concurrent.GenericFutureListener;
      18.  
      19. import java.util.concurrent.CompletableFuture;
      20. import java.util.concurrent.Executors;
      21.  
      22. /**
      23.  * desc
      24.  *
      25.  * @author Yushanma
      26.  * @since 2023/6/4 17:23
      27.  */
      28. public class RxtxServer {
      29.  
      30.     private RxtxChannel channel;
      31.  
      32.     private ComConfig config;
      33.  
      34.     public RxtxServer(ComConfig config) {
      35.         this.config = config;
      36.     }
      37.  
      38.     public void createRxtx() throws Exception {
      39.         // 串口使用阻塞io
      40.         EventLoopGroup group = new OioEventLoopGroup();
      41.         try {
      42.             Bootstrap bootstrap = new Bootstrap();
      43.             bootstrap.group(group)
      44.                     .channelFactory(() -> {
      45.                         RxtxChannel rxtxChannel = new RxtxChannel();
      46.                         rxtxChannel.config()
      47.                                 .setBaudrate(config.getBaudRate()) // 波特率
      48.                                 .setDatabits(config.getDataBits()) // 数据位
      49.                                 .setParitybit(config.getParity())    // 校验位
      50.                                 .setStopbits(config.getStopBits()); // 停止位
      51.                         return rxtxChannel;
      52.                     })
      53.                     .handler(new ChannelInitializer() {
      54.                         @Override
      55.                         protected void initChannel(RxtxChannel rxtxChannel) {
      56.                             rxtxChannel.pipeline().addLast(
      57.                                     // 十六进制形式发送编解码
      58.                                     new ByteArrayDecoder(),
      59.                                     new ByteArrayEncoder(),
      60.                                     new RxtxHandler()
      61.                             );
      62.                         }
      63.                     });
      64.  
      65.             ChannelFuture f = bootstrap.connect(new RxtxDeviceAddress(config.getSerialPortName())).sync();
      66.             f.addListener(connectedListener);
      67.  
      68.             f.channel().closeFuture().sync();
      69.         } finally {
      70.             group.shutdownGracefully();
      71.         }
      72.     }
      73.  
      74.  
      75.     // 连接监听
      76.     GenericFutureListener connectedListener = (ChannelFuture f) -> {
      77.         final EventLoop eventLoop = f.channel().eventLoop();
      78.         if (!f.isSuccess()) {
      79.             System.out.println("连接失败");
      80.         } else {
      81.             channel = (RxtxChannel) f.channel();
      82.             System.out.println("连接成功");
      83.             sendData();
      84.         }
      85.     };
      86.  
      87.     /**
      88.      * 发送数据
      89.      */
      90.     public void sendData() {
      91.         // 十六机制形式发送
      92.         ByteBuf buf = Unpooled.buffer(2);
      93.         buf.writeByte(3);
      94.         buf.writeByte(2);
      95.         channel.writeAndFlush(buf.array());
      96.  
      97.         // 文本形式发送
      98.         //channel.writeAndFlush("2");
      99.     }
      100.  
      101.     public void start() {
      102.         CompletableFuture.runAsync(() -> {
      103.             try {
      104.                 // 阻塞的函数
      105.                 createRxtx();
      106.             } catch (Exception e) {
      107.                 e.printStackTrace();
      108.             }
      109.         }, Executors.newSingleThreadExecutor());//不传默认使用ForkJoinPool，都是守护线程
      110.     }
      111.  
      112.     public static void main(String[] args) {
      113.         // 串口连接服务类
      114.         ComConfig comConfig = new ComConfig();
      115.         comConfig.setSerialPortName("COM1");
      116.         comConfig.setBaudRate(9600);
      117.         RxtxServer rxtxServer = new RxtxServer(comConfig);
      118.         rxtxServer.start();
      119.         try {
      120.             // 连接串口需要一点时间，这里稍微等待一下
      121.             Thread.sleep(5000);
      122.         } catch (InterruptedException e) {
      123.             e.printStackTrace();
      124.         }
      125.         // 发送数据
      126.         rxtxServer.sendData();
      127.     }
      128. }
       

      测试效果
       

       

      这里注意，因为解码是按照十六进制解码，所以需要以“十六进制发送”，“十六进制显示”。
      
                
                    
                

                
    28. 

                    相关阅读:
      
                    
『 基础算法题解 』之双指针（下）                            
      
面过了,起薪30k                            
      
pytest + yaml 框架 -4.用例参数化parameters功能实现                            
      
Redis的 延时双删以及数据一致性                            
      
阿里云无影云电脑角色AliyunServiceRoleForGws什么意思？                            
      
Angular 配置开发环境                            
      
40-SpringBoot                            
      
UI设计师(界面设计)面试题                            
      
Android学习笔记 50. Android 多媒体技术——SoundPool播放音效                            
      
Web前端与其他前端：深度对比与差异性剖析                            
      
                          
                
      29. 
                
    29. 
                    原文地址：https://blog.csdn.net/weixin_47560078/article/details/131021932
                
      30. 

            
        

        
      
            
        
                
      • 
                    最新文章
                
        • 
                
      • 
                    
攻防演习之三天拿下官网站群                            
        
数据安全治理学习——前期安全规划和安全管理体系建设                            
        
企业安全 | 企业内一次钓鱼演练准备过程                            
        
内网渗透测试 | Kerberos协议及其部分攻击手法                            
        
0day的产生 | 不懂代码的"代码审计"                            
        
安装scrcpy-client模块av模块异常，环境问题解决方案                            
        
leetcode hot100【LeetCode 279. 完全平方数】java实现                            
        
OpenWrt下安装Mosquitto                            
        
AnatoMask论文汇总                            
        
【AI日记】24.11.01 LangChain、openai api和github copilot                            
        
                            
                
        • 
            
      

            
        
                
      • 
                    热门文章
                
        • 
                
      • 
                    
十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧！！！                            
        
奉劝各位学弟学妹们，该打造你的技术影响力了！                            
        
五年了，我在 CSDN 的两个一百万。                            
        
Java俄罗斯方块，老程序员花了一个周末，连接中学年代！                            
        
面试官都震惊，你这网络基础可以啊！                            
        
你真的会用百度吗？我不信 — 那些不为人知的搜索引擎语法                            
        
心情不好的时候，用 Python 画棵樱花树送给自己吧                            
        
通宵一晚做出来的一款类似CS的第一人称射击游戏Demo！原来做游戏也不是很难，连憨憨学妹都学会了！                            
        
13 万字 C 语言从入门到精通保姆级教程2021 年版                            
        
10行代码集2000张美女图，Python爬虫120例，再上征途                            
        
                            
                
        • 
            
      

        
      
    




    
    
    
    

      
    
      
        
      
            
      
                
      
                    Copyright © 2022 侵权请联系2656653265@qq.com   
                    京ICP备2022015340号-1
                
      
                
      
                    正则表达式工具
                    cron表达式工具
                    密码生成工具
                
      
                
      
                    
                    
      京公网安备 11010502049817号