java-串口通讯-连接硬件

串口通信(Serial Communications)的概念非常简单,串口按位(bit)发送和接收字节。尽管比按字节(byte)的并行通信慢,但是串口可以在使用一根线发送数据的同时用另一根线接收数据。它很简单并且能够实现远距离通信。比如IEEE488定义并行通行状态时,规定设备线总长不得超过20米,并且任意两个设备间的长度不得超过2米;而对于串口而言,长度可达1200米。典型地,串口用于ASCII码字符的传输。通信使用3根线完成,分别是地线、发送、接收。由于串口通信是异步的,端口能够在一根线上发送数据同时在另一根线上接收数据。其他线用于握手,但不是必须的。串口通信最重要的参数是波特率、数据位、停止位和奇偶校验。对于两个进行通信的端口,这些参数必须匹配。

上面说的,对于非专业人士来说,都是多余的话
一句话简单的说:串口通讯,一般情况下指windows电脑(或者一些安卓系统,单片机系统)和硬件进行数据交互的协议(方式)(硬件指,扫码抢,扫码盒子,刷卡机,继电器等一些硬件)。

这些硬件一般通过串口线,或者是USB线, 如果不带USB线也可以通过转换成USB线的方式,和电脑连接。

举例几个场景,一个windows 系统的柜式机器,控制开门关门。
一个windows机器的闸机,控制开门关门,或者开灯关灯
一个扫码枪,想要获取扫码数据并处理扫码获得的数据。等等各种情况
我这里主要是以 继电器 和 扫码器两种情况为例子。

场景一:windows电脑控制继电器的开关**

这种场景主要是,windows主动发送串口指令到硬件,控制硬件的状态
淘宝上买了一个继电器
在这里插入图片描述
话不多说,直接上串口通讯代码
POM 依赖包

<dependency><groupId>com.fazecast</groupId><artifactId>jSerialComm</artifactId><version>2.9.0</version></dependency>
package com.hzsmk.serial.service;import com.fazecast.jSerialComm.SerialPort;
import com.hzsmk.common.exception.BusinessException;
import com.hzsmk.common.util.RString;public class SerialHander {private static final byte[] open = new byte[] {(byte) 0xA0,0x01,0x01,(byte) 0xA2};private static final byte[] close = new byte[] {(byte) 0xA0,0x01,0x00,(byte) 0xA1};//private static final byte[] query = new byte[] {(byte) 0xA0,0x01,0x05,(byte) 0xA6};private static SerialPort connectPort(String portDescription,String systemPortName) {// 列举所有可用的串口SerialPort[] commPorts = SerialPort.getCommPorts();for (SerialPort port : commPorts) {String des = port.getPortDescription();System.out.println(des);if(RString.isNotBlank(portDescription) &&  !portDescription.equals(des)) {//端口描述不為空,需要检验 continue;}String portname = port.getSystemPortName();if(RString.isNotBlank(systemPortName) &&  !systemPortName.equals(portname)) {//端口不為空,需要检验 continue;}return port;}throw new BusinessException("未找到设备:"+portDescription+",端口"+systemPortName);}/*** 发送一个开关信号* @param portDescription* @param systemPortName* @throws InterruptedException */public static void hand(String portDescription,String systemPortName) {//获取可用端口SerialPort serialPort = connectPort(portDescription, systemPortName);try {//连接if(!serialPort.isOpen()) {boolean isopen = serialPort.openPort();if(!isopen) {//连接失败throw new BusinessException("连接设备失败,请重试,设备:"+portDescription+",端口"+systemPortName); }}//发送2个数据过去serialPort.writeBytes(open, open.length);Thread.sleep(300);//随眠200毫秒 关闭serialPort.writeBytes(close, close.length);}catch (InterruptedException e) {e.printStackTrace();} catch (BusinessException e) {throw e;} finally {// 关闭串口serialPort.closePort();}}}

1、核心代码是,查询出已经连接的串口设备,SerialPort.getCommPorts();

2、打开串口设备:serialPort.openPort();

3、发送串口数据:serialPort.writeBytes(close, close.length);

场景2,被动接受扫码器扫码获得的数据

这种场景主要是,串口支持被动获取数据。,
要解决的问题1: 要动态监测串口设备是否已失去连接,
2:串口设备支持自动重连。

package com.hzsmk.serial.service;import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;import com.fazecast.jSerialComm.SerialPort;
import com.hzsmk.common.exception.BusinessException;
import com.hzsmk.common.util.RString;@Service
public class ScanHander {private static SerialPort scanSerialPort = null;public static String scanSerialPortName = "";@Value("${serial.scanportdes}")String envScanPortdes;/*** 每5秒检查一次*/@Scheduled(cron = "0/5 * * * * *")public void scheduled(){System.out.println("定时检查设备是否运行中");if(scanSerialPort == null || !scanSerialPort.isOpen() || scanSerialPort.bytesAvailable() == -1) {//主要依赖  bytesAvailable 参数,  isopen基本无用scanSerialPortName = "";//重置信号参数synchronized (scanSerialPortName) {try {if(RString.isBlank(envScanPortdes)) {createListen("SM-2D PRODUCT USB UART","");}else {createListen(envScanPortdes,"");}} catch (Exception e) {e.printStackTrace();}}}}private static SerialPort connectPort(String portDescription,String systemPortName) {try {// 列举所有可用的串口SerialPort[] commPorts = SerialPort.getCommPorts();for (SerialPort port : commPorts) {String des = port.getPortDescription();System.out.println(des);if(RString.isNotBlank(portDescription) &&  !portDescription.equals(des)) {//端口描述不為空,需要检验 continue;}String portname = port.getSystemPortName();if(RString.isNotBlank(systemPortName) &&  !systemPortName.equals(portname)) {//端口不為空,需要检验 continue;}return port;}} catch (Exception e) {// TODO: handle exception}throw new BusinessException("获取设备异常,请重试");}public static void createListen(String portDescription,String systemPortName) {if(scanSerialPort != null) {//如果是断线重连scanSerialPort.closePort();}//获取可用端口scanSerialPort = connectPort(portDescription, systemPortName);try {scanSerialPortName = scanSerialPort.getSystemPortName()+":"+scanSerialPort.getPortDescription();scanSerialPort.addDataListener(new ScanDatLislen());boolean isopen = scanSerialPort.openPort();if(!isopen) {//连接失败throw new BusinessException("连接设备失败,请重试,设备:"+portDescription+",端口"+systemPortName); }System.out.println("open......");} catch (BusinessException e) {throw e;}  catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {//scanSerialPort.closePort();}}
}

##监听函数

package com.hzsmk.serial.service;import com.fazecast.jSerialComm.SerialPort;
import com.fazecast.jSerialComm.SerialPortDataListener;
import com.fazecast.jSerialComm.SerialPortEvent;
import com.hzsmk.common.util.RString;import cn.hutool.core.swing.RobotUtil;public class ScanDatLislen implements SerialPortDataListener{@Overridepublic int getListeningEvents() {// TODO Auto-generated method stubreturn  SerialPort.LISTENING_EVENT_DATA_RECEIVED;}@Overridepublic void serialEvent(SerialPortEvent event) {System.out.println("监听执行 LISTENING_EVENT_DATA_RECEIVED");// 读取数据try {byte[] buffer = event.getReceivedData(); // 缓冲区大小if (buffer.length > 0) {// 将读取的字节转换为字符串String data = new String(buffer, 0, buffer.length, "UTF-8");if(!data.startsWith("QRCODE") || !data.startsWith("SRC")) {String code = RString.byte2hex(buffer);if(code.startsWith("810169")) {data = code;}}RobotUtil.keyPressString(data);}Thread.sleep(1000);} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}}}

核心逻辑,1、开启定时任务,定时检测设备是否在线

重点,重点,重点,重点,重点,重点,重点,重点,重点,重点,重点,重点,这里有一个比较恶心的API,SerialPort.isOpen() 这个API,在打开过端口之后,设备掉线或者插口拔掉后,它依然是open状态。 这里的OPEN时间上只能说是 本地开启的服务是否open ,并不能检测设备的在线状态。
所以实际上有用的 SerialPort.bytesAvailable() ,查看是否有byte数据可用。用这个检测设备是否在线

2、开启监听函数,可以监听端口或者数据接收的事件addDataListener

SerialPort.LISTENING_EVENT_DATA_RECEIVED; 有很多种状态,目前业务需求监听数据响应状态。

3、监听到数据后,可以把数据传输给第三方接口,或者保存下来,但是如果要和WEB界面交互,这里有一个小技巧,可以把数据张贴到键盘聚焦点,使用hutool工具RobotUtil.keyPressString(data); ,, 简单的说就是把串口通讯又转换为了 usb-kwb-hid通讯了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/7677.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

经典面试题之滑动窗口专题

class Solution { public:int minSubArrayLen(int target, vector<int>& nums) {// 长度最小的子数组 // 大于等于 targetint min_len INT32_MAX;// 总和int sum 0;int start 0; // 起点for(int i 0; i< nums.size(); i) {sum nums[i];while(sum > targe…

leetcode 547.省份数量

思路&#xff1a;dfs 或者这道题用bfs也是可以的。 这道题有点迷惑性&#xff0c;这里的数组给的是无向图的数组&#xff0c;而并不是地图&#xff0c;这里需要着重注意一下。 而后&#xff0c;这里的状态数组st没必要是二维的&#xff0c;我们并不会去遍历所给的数组&#…

拥抱新质生产力,助力新型工业化!CMM电子展暨IARS机器人展5月东莞盛大起航

2024年5月15-17日&#xff0c;东浩兰生会展集团旗下CMM电子展&#xff06;IARS机器人展将在广东现代国际展览中心&#xff08;东莞厚街&#xff09;举办。展会面积达50000平方米&#xff0c;展示品牌700余个&#xff0c;同期论坛峰会30余场&#xff0c;预计专业观众超50000人次…

代码随想录训练营Day25:贪心算法:加油站、分发糖果和K次取反的最大数组和

1.1005K次取反后最大化的数组和 贪心策略&#xff1a;先按照绝对值的大小进行排序&#xff0c;绝对值大的排在前面&#xff0c;然后按照顺序&#xff0c;如果存在负值就翻转直到用完k次&#xff0c;或者遍历完之后&#xff0c;将最小的那个进行翻转即可。 class Solution { p…

a表存在b表不存在的数据

第二种&#xff1a;在卡法中最常见的left join 方法&#xff0c;实现数据的过滤。 SELECT * FROM A LEFT JOIN B ON A.IdB.Id WHERE 11 AND B.Id IS NULL;

error: pathspec ‘XXX‘ did not match any file(s) known to git

使用vscode&#xff0c;在本地开发切换分支时&#xff0c;报以下错误&#xff1a; error: pathspec XXX did not match any file(s) known to git 该问题是由于没有对应分支的原因。 首先使用一下命令&#xff0c;查看本地及远程的所有分支。 git branch -a 若没有对应的分…

【第12章】spring-mvc自定义类型转换器

文章目录 前言一、请求对象二、自定义转换器三、注册转换器四、控制器五、执行顺序六、执行结果总结 前言 【第6章】spring类型转换器 在spring系列已经介绍了类型转换器、接下来我们通过案例了解下转换器在SpringMvc中的应用。 场景模拟&#xff1a;我们接收到客户端请求,解析…

【MyBatisPlus】代码生成器、条件分页查询

代码生成器 第一步 引入依赖 <!-- mybatisPlus的代码生成器--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId><version>3.3.1</version></dependency>第二步 创…

极验4 一键解混淆

提示&#xff01;本文章仅供学习交流&#xff0c;严禁用于任何商业和非法用途&#xff0c;未经许可禁止转载&#xff0c;禁止任何修改后二次传播&#xff0c;如有侵权&#xff0c;可联系本文作者删除&#xff01; AST简介 AST&#xff08;Abstract Syntax Tree&#xff09;&a…

Linux专栏03:使用Xshell远程连接云服务器

博客主页&#xff1a;Duck Bro 博客主页系列专栏&#xff1a;Linux专栏关注博主&#xff0c;后期持续更新系列文章如果有错误感谢请大家批评指出&#xff0c;及时修改感谢大家点赞&#x1f44d;收藏⭐评论✍ 使用Xshell远程连接云服务器 编号&#xff1a;03 文章目录 使用Xsh…

Redis学习(九)|如何保证MySQL和Redis的数据一致性

文章目录 引言什么是数据一致性为什么会出现不一致的情况如何保证一致性分布式事务异步更新策略双写模式缓存失效策略定时同步策略 结论 引言 数据一致性是任何系统设计中至关重要的一个方面。在涉及到同时使用Redis和MySQL的场景中&#xff0c;保证两者之间的数据一致性尤为重…

Redis 中,集合(Set)

在 Redis 中&#xff0c;集合&#xff08;Set&#xff09;是一种无序的、由字符串组成的数据结构。集合中的每个元素都是唯一的&#xff0c;即集合不允许重复的元素。Redis 集合通过哈希表实现&#xff0c;添加、删除、查找元素的操作都能在平均常数时间内完成。 ### 集合的特…

Jenkins集成Kubernetes 部署springboot项目

文章目录 准备部署的yml文件Harbor私服配置测试使用效果Jenkins远程调用参考文章 准备部署的yml文件 apiVersion: apps/v1 kind: Deployment metadata:namespace: testname: pipelinelabels:app: pipeline spec:replicas: 2selector:matchLabels:app: pipelinetemplate:metada…

【linux系统开发基本命令】

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 基本命令dockergitCpython总结 基本命令 sudo 管理员权限&#xff0c;一般用在命令的最前面 例如&#xff1a; sudo rm our.py删除our.py文件 pwd打印当前目录 cd…

软件设计师-应用技术-数据结构及算法题4

考题形式&#xff1a; 第一题&#xff1a;代码填空 4-5空 8-10第二题&#xff1a;时间复杂度 / 代码策略第三题&#xff1a;拓展&#xff0c;跟一组数据&#xff0c;把数据带入代码中&#xff0c;求解 基础知识及技巧&#xff1a; 1. 分治法&#xff1a; 基础知识&#xff1…

STM32F103 ADC驱动程序设计

设计了一种通过软件触发&#xff0c;循环采集的ADC驱动程序 #include "stdbool.h" #include "string.h" #include "stm32f0xx_ll_bus.h" #include "stm32f0xx_ll_gpio.h" #include "stm32f0xx_ll_adc.h" #include "stm…

【Vue3 生命周期与组合式API】

文章目录 一、Vue3 生命周期概述二、Vue3 组合式API 与选项式API 的对比1. 选项式API 生命周期钩子函数常用的生命周期钩子函数包括&#xff1a; 2. 组合式API 的优势组合式API 的主要优势包括&#xff1a;在生命周期管理上的优势 三、Vue3 组合式API 生命周期钩子函数1. setup…

语音识别--降噪

⚠申明&#xff1a; 未经许可&#xff0c;禁止以任何形式转载&#xff0c;若要引用&#xff0c;请标注链接地址。 全文共计3077字&#xff0c;阅读大概需要3分钟 &#x1f308;更多学习内容&#xff0c; 欢迎&#x1f44f;关注&#x1f440;【文末】我的个人微信公众号&#xf…

三剑客之grep

grep初级简单使用&#xff1a;Liunx查找&过滤-CSDN博客 正则表达式-CSDN博客 目录 grep分类 返回值 使用返回值控制流程 grep参数示例 基本参数 grep与正则表达式的搭配使用与示例 看完正则与示例进行无答案式练习 grep 用于在文件或输入流中查找特定模式或文本。…

uniapp的app端推送功能,不使用unipush

1&#xff1a;推送功能使用htmlPlus实现&#xff1a;地址HTML5 API Reference (html5plus.org) 效果图&#xff1a; 代码实现&#xff1a; <template><view class"content"><view class"text-area"><button click"createMsg&q…