Netty向设备发送消息并等待设备响应

在使用netty开发和硬件对接时,经常会遇到服务端给硬件设备发送命令后需要等待设备反馈响应命令后执行逻辑。

一、定义同步等待

/*** @author: 晨光* @description: 同步等待* @Version 1.0*/
public class SyncPromise {// 用于接收结果private BaseMessageInfoVo messageResponse;//CountDownLatch可以看作是一个计数器,当计数器的值减到0时,所有等待的线程将被释放并继续执行。private final CountDownLatch countDownLatch = new CountDownLatch(1);// 用于判断是否超时private boolean isTimeout = false;/*** 同步等待返回结果* timeout 超时时间    unit 时间单位*/public BaseMessageInfoVo get(long timeout, TimeUnit unit) throws InterruptedException {// 等待阻塞,超时时间内countDownLatch减到0,将提前唤醒,以此作为是否超时判断// 如果在指定时间内计数器仍未归零,则返回false,否则返回true。boolean earlyWakeUp = countDownLatch.await(timeout, unit);if(earlyWakeUp) {// 超时时间内countDownLatch减到0,提前唤醒,说明已有结果return messageResponse;} else {// 超时时间内countDownLatch没有减到0,自动唤醒,说明超时时间内没有等到结果isTimeout = true;return null;}}// 计数器清零,唤醒public void wake() {countDownLatch.countDown();}public BaseMessageInfoVo getMessageResponse() {return messageResponse;}public void setMessageResponse(BaseMessageInfoVo messageResponse) {this.messageResponse = messageResponse;}public boolean isTimeout() {return isTimeout;}
}

2、定义工具类发送同步消息

/*** @author: 晨光* @description: 定义工具类* @Version 1.0*/
public class SyncUtil {private final static Map<String, SyncPromise> syncPromiseMap =  new ConcurrentHashMap<>();//key 唯一主键类,方便在处理逻辑中找到唤醒public static BaseMessageInfoVo send(String key,Channel channel,BaseMessageInfoVo messageRequest, long timeout, TimeUnit unit) throws Exception{if(channel == null) {throw new NullPointerException("channel");}if(messageRequest == null) {throw new NullPointerException("rpcRequest");}if(timeout <= 0) {throw new IllegalArgumentException("timeout must greater than 0");}// 创造一个容器,用于存放当前线程与rpcClient中的线程交互SyncPromise syncPromise = new SyncPromise();syncPromiseMap.put(key, syncPromise);// 发送消息,此处如果发送玩消息并且在get之前返回了结果,下一行的get将不会进入阻塞,也可以顺利拿到结果channel.writeAndFlush(messageRequest);// 等待获取结果BaseMessageInfoVo messageResponse = syncPromise.get(timeout, unit);if(messageResponse == null) {if(syncPromise.isTimeout()) {throw new TimeoutException("等待响应结果超时");} else{throw new Exception("其他异常");}}// 移除容器syncPromiseMap.remove(header+ ChannelMap.getEquipCode(channel));return messageResponse;}public static Map<String, SyncPromise> getSyncPromiseMap(){return syncPromiseMap;}
}

通过上面的类即可同步向设备发送命令。

3、在设备返回命令的逻辑中对应唤醒处理逻辑

/*** 连接管理 handler*/
@Slf4j
@Service
@ChannelHandler.Sharable
public class SyncRequestHandler extends SimpleChannelInboundHandler<BaseMessageInfoVo> { //ChannelInboundHandlerAdapter@Overrideprotected void channelRead0(ChannelHandlerContext ctx, BaseMessageInfoVo resp) throws Exception {//查询相应key对应的是否有返回,如果有返回就唤醒,直接返回响应数据SyncPromise syncPromise = SyncUtil.getSyncPromiseMap().get(resp.getHeader()+ChannelMap.getEquipCode(ctx.channel()));if(syncPromise != null){//在获取对象不为null时执行唤醒操作,否则直接丢弃syncPromise.setMessageResponse(resp);syncPromise.wake();}}
}

4、具体的调用发送命令处理逻辑

BaseMessageInfoVo responseInfo = SyncUtil.send(MessageConstant.UPGRADE_PREIX, channel, baseMessageInfoVo, 5, TimeUnit.SECONDS);
System.out.println(JSONObject.toJSONString(responseInfo));//根据具体逻辑进行判断
return ApiResult.success(responseInfo.getHeader()+responseInfo.getData(),"发送成功");

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

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

相关文章

计网总结☞物理层

五层协议体系结构->各层的功能有&#xff1a; 物理层 物理层的任务就是尽可能地屏蔽传输媒体的差异&#xff0c;透明地传送比特流&#xff08;注意&#xff1a;传递信息的物理媒体&#xff0c;如双绞线、同轴电缆、光缆等&#xff0c;是在物理层的下面&#xff0c;当做第 0…

Python AI 编程助手:Fitten Code插件

一. 简介 今天为大家推荐一款适配了 Viusal Studio&#xff0c;VS Code(本文使用)&#xff0c;JetBrains 系列(本文使用)以及Vim等多种编译器环境的插件 Fitten Code&#xff0c;Fitten Code 是由非十大模型驱动的 AI 编程助手&#xff0c;它可以自动生成代码&#xff0c;提升…

python --Datatframe 索引与列名操作

学习目标 知道如何查看索引及列名 知道如何修改索引及列名 1 数据准备 数据在文章顶部,找不到的可以主页私聊我 我们继续使用链家租房数据来学习本章节的API&#xff0c;导包并读取数据 import pandas as pd ​ # 加载数据集 df pd.read_csv(../data/LJdata.csv) # 获取天通…

【AIGC】基于大模型+知识库的Code Review实践

一、背景描述 一句话介绍就是&#xff1a;基于开源大模型 知识库的 Code Review 实践&#xff0c;类似一个代码评审助手&#xff08;CR Copilot&#xff09;。信息安全合规问题&#xff1a;公司内代码直接调 ChatGPT / Claude 会有安全/合规问题&#xff0c;为了使用 ChatGPT…

Mybatis CRUD操作

Mybatis 第一步-编写工具类 package com.ruoxue.utils;import org.apache.ibatis.io.Resources; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder;import jav…

集合中removeIf和stream流的filter差异比较

一、背景 今天在看同事写的代码的时候&#xff0c;看到了一个我很少使用的集合操作&#xff0c;一般我习惯过滤集合的数据的时候&#xff0c;采用stream流当中的filter操作&#xff0c;但是同事使用的是removeIf&#xff0c;对此简单看了看两者的区别&#xff0c;对此进行记录…

STM32F103C8开发板 STM32最小系统核心板 AD硬件原理图+PCB封装文件分享

STM32F103C8开发板原理图 原理图和PCB下载地址&#xff1a; STM32F103C8开发板 STM32最小系统核心板 AD硬件原理图PCB封装文件.zip: https://url83.ctfile.com/f/45573183-1269573020-8f85b2?p7526 (访问密码: 7526)

新手指南:如何使用Python快速上手深度学习

新手指南&#xff1a;如何使用Python快速上手深度学习 对于刚入门的新手而言&#xff0c;开始深度学习的旅程可能看起来既令人兴奋又略感困惑。Python是进行深度学习研究和应用的首选语言&#xff0c;因为它拥有丰富的库和框架&#xff0c;能够简化深度学习模型的开发和测试过…

前端使用axios下载文件和上传文件

首先&#xff0c;axios实例在发起下载文件请求时&#xff0c;应该配置responseType: ‘blob’&#xff0c;例如&#xff1a; // axios发起下载文档请求 export const downloadDoc (id: string) > {return request.get(/downloadDoc?id${id}, {// 参考官方文档https://www…

Bio-Info 每日一题:Rosalind-04-Rabbits and Recurrence Relations

&#x1f389; 进入生物信息学的世界&#xff0c;与Rosalind一起探索吧&#xff01;&#x1f9ec; Rosalind是一个在线平台&#xff0c;专为学习和实践生物信息学而设计。该平台提供了一系列循序渐进的编程挑战&#xff0c;帮助用户从基础到高级掌握生物信息学知识。无论你是初…

指针在C/C++中的魔力:一级指针与二级指针

什么是指针&#xff1f; 指针是一个变量&#xff0c;它的值是另一个变量的地址。在C/C中&#xff0c;指针是一个强大的工具&#xff0c;可以让我们直接操作内存地址。指针的主要用途包括动态内存分配、数组和字符串处理、函数参数传递等。 一级指针 一级指针&#xff08;也称为…

聊一聊大数据需求的流程

大致的流程&#xff1a;需求对接、口径梳理、数据开发、任务发布、任务监控、任务保障 流程图 startuml skinparam packageStyle rectangleactor 需求方 participant 数据BP as 数据组 participant 离线数仓 participant 实时数仓需求方 -> 数据组: 提出需求 数据组 -> …

Android 日志实时输出

开发中如果只是单纯的应用开发&#xff0c;Android studio基本上可以满足&#xff0c;但是如果应用和系统联调那就得用logcat实时输出了&#xff0c;我这里都是总结的实用经验&#xff0c;没那么多花里胡哨 Android 日志实时输出 1、输出 android log //分步&#xff0c;进入s…

造假高手——faker

在测试写好的代码时通常需要用到一些测试数据&#xff0c;大量的真实数据有时候很难获取&#xff0c;如果手动制造测试数据又过于繁重无聊&#xff0c;显得不够优雅&#xff0c;今天我们介绍的faker这个轮子可以完美的解决这个问题。faker是一个用于生成各种类型假数据的库&…

Spring AOP(实现,动态原理)详解版

Spring AOP 1.什么是AOP&#xff1f;1.1引入AOP依赖1.2编写AOP程序 2.Spring AOP核⼼概念2.1 切点(Pointcut)2.2连接点(Join Point)2.3通知(Advice)2.4 切⾯(Aspect) 3.通知类型3.1顺序3.2切⾯优先级 Order3.3 ⾃定义注解 MyAspect 4. Spring AOP 原理5 动态代理怎么实现5.1 JD…

D455相机RGB与深度图像对齐,缓解相机无效区域的问题

前言 上一次我们介绍了深度相机D455的使用&#xff1a;intel深度相机D455的使用-CSDN博客&#xff0c;我们也看到了相机检测到的无效区域。 在使用Intel深度相机D455时&#xff0c;我们经常会遇到深度图中的无效区域。这些无效区域可能由于黑色物体、光滑表面、透明物体以及视…

基于大模型 Gemma-7B 和 llama_index,轻松实现 NL2SQL

节前&#xff0c;我们星球组织了一场算法岗技术&面试讨论会&#xff0c;邀请了一些互联网大厂朋友、参加社招和校招面试的同学. 针对算法岗技术趋势、大模型落地项目经验分享、新手如何入门算法岗、该如何准备、面试常考点分享等热门话题进行了深入的讨论。 汇总合集&…

数字滤波器和模拟滤波器(一)

模拟滤波器和数字滤波器&#xff08;一&#xff09; 下面介绍模拟滤波器和数字滤波器的频率响应的异同&#xff0c;以及如何使用python地scipy.signal来绘制其频谱响应和冲激阶跃响应。在第二期将谈到如何设计模拟滤波器和数字滤波器。 在正文之间&#xff0c;应该介绍连续时…

嵌入式学习——Linux高级编程复习(目录IO、软硬连接、makefile)——day38

1. 目录IO 目录IO是指在计算机程序中对文件目录进行操作的一系列输入输出功能。这些操作允许程序创建、读取、修改和删除目录结构。在Unix/Linux系统和类似系统中&#xff0c;目录被视为特殊的文件&#xff0c;可以对其进行打开、读取、写入&#xff08;修改&#xff09;和关闭…

LLMs,即大型语言模型

LLMs&#xff0c;即大型语言模型&#xff0c;是一类基于深度学习的人工智能模型&#xff0c;它们通过海量的数据和大量的计算资源进行训练&#xff0c;可以理解和生成自然语言。LLMs的核心架构是Transformer&#xff0c;其关键在于自注意力机制&#xff0c;使得模型能够同时对…