嵌入式设备网络的动态ID分配机制实现

文章目录

  • 前言
  • 一、系统设计要点
  • 二、核心数据结构
    • 2.1 设备唯一标识(DeviceUID)
    • 2.2 节点信息(Node)
    • 2.3 节点管理器(NodeManager)
  • 三、核心算法实现
    • 3.1 初始化与清理
      • 3.1.1 初始化节点管理器
      • 3.1.2 清理节点管理器
    • 3.2 动态ID分配策略
      • 3.2.1 查找最小可用ID
      • 3.2.2 ID使用检查
    • 3.3 心跳处理机制
    • 3.4 超时检测机制
  • 四、节点查找与管理
    • 4.1 通过UID查找节点
    • 4.2 通过ID查找节点
    • 4.3 获取活跃节点列表
  • 五、回调机制实现
    • 5.1 回调函数注册
    • 5.2 示例回调函数
  • 六、应用示例
  • 七、总结


前言

在嵌入式设备网络中,节点的动态加入与退出是常态,尤其是在无人机、传感器网络、智能家居等系统中,节点通常无法提前预设 ID,这就要求系统具备动态 ID 分配与管理能力。本篇博客将围绕“动态 ID 管理”这一核心,介绍一个基于设备 UID 的动态 ID 分配系统,支持重复上线检测、最小可用 ID 分配、ID 冲突检测、ID 释放与复用等功能,代码完全由 C 语言实现,结构清晰,易于移植与扩展。


一、系统设计要点

该系统以节点唯一标识符 DeviceUID 为基础,实现了以下关键特性:

  • 动态 ID 分配:无需提前为设备分配 ID,系统自动为新设备分配最小可用 ID。

  • UID 唯一识别机制:通过对 UID 的比较实现节点重复检测与状态更新。

  • ID 冲突检测:避免多个设备使用相同 ID 导致状态混乱。

  • ID 释放与复用:支持节点主动释放 ID,或超时后自动回收,以复用资源。

  • 回调机制:支持注册上线、下线回调函数,便于系统业务集成。

  • 心跳检测:通过心跳机制维护节点活跃状态

  • 超时处理:自动检测并清理离线节点

二、核心数据结构

2.1 设备唯一标识(DeviceUID)

typedef struct {uint8_t bytes[6];  // 6字节的唯一设备标识
} DeviceUID;

这个结构体用于存储设备的唯一标识符,通常可以是MAC地址或其他硬件唯一ID。

2.2 节点信息(Node)

typedef struct Node {uint8_t id;          // 分配的节点IDDeviceUID uid;       // 设备唯一标识uint64_t lastSeenMs; // 最后活跃时间戳(毫秒)struct Node* next;   // 下一个节点指针
} Node;

每个节点包含分配的ID、设备唯一标识、最后活跃时间和指向下一个节点的指针。

2.3 节点管理器(NodeManager)

typedef struct {Node* head;                  // 链表头指针uint8_t activeCount;         // 活跃节点计数NodeOnlineCallback onOnline; // 节点上线回调函数NodeOfflineCallback onOffline; // 节点下线回调函数
} NodeManager;

节点管理器维护所有活跃节点的链表,并提供回调函数接口。

三、核心算法实现

3.1 初始化与清理

3.1.1 初始化节点管理器

void NodeManager_Init(NodeManager* manager) {manager->head = NULL;manager->activeCount = 0;manager->onOnline = NULL;manager->onOffline = NULL;
}

3.1.2 清理节点管理器

void NodeManager_Cleanup(NodeManager* manager) {Node* current = manager->head;while (current) {Node* next = current->next;// 回调通知节点离线if (manager->onOffline) {manager->onOffline(current->id, &current->uid);}free(current);current = next;}manager->head = NULL;manager->activeCount = 0;
}

3.2 动态ID分配策略

3.2.1 查找最小可用ID

static uint8_t FindMinAvailableID(NodeManager* manager) {for (uint8_t id = MIN_VALID_ID; id <= MAX_VALID_ID; id++) {if (!IsIDUsed(manager, id)) return id;}return INVALID_ID;
}

该算法从MIN_VALID_ID开始遍历,返回第一个未被使用的ID。

3.2.2 ID使用检查

static bool IsIDUsed(NodeManager* manager, uint8_t id) {Node* current = manager->head;while (current) {if (current->id == id) return true;current = current->next;}return false;
}

3.3 心跳处理机制

uint8_t ProcessHeartbeat(NodeManager* manager, uint8_t nodeId, const DeviceUID* uid) {// 1. 检查是否已有相同UID的节点Node* existing = FindNodeByUID(manager, uid);if (existing) {existing->lastSeenMs = GetSysTimeMs(); // 更新活跃时间return existing->id;}// 2. 检查请求的ID是否已被占用if (nodeId != INVALID_ID && FindNodeByID(manager, nodeId)) {nodeId = INVALID_ID; // 如果已被占用,则重置为无效ID}// 3. 分配新IDif (nodeId == INVALID_ID) {nodeId = FindMinAvailableID(manager);if (nodeId == INVALID_ID) return INVALID_ID; // 无可用ID}// 4. 添加新节点return AddNode(manager, nodeId, uid) ? nodeId : INVALID_ID;
}
  • 心跳处理流程

    1. 如果是已知节点,更新其活跃时间

    2. 如果是新节点,检查请求ID是否可用

    3. 分配最小可用ID

    4. 添加新节点到管理器

3.4 超时检测机制

void CheckTimeoutNodes(NodeManager* manager) {uint64_t now = GetSysTimeMs();Node** pnode = &manager->head;while (*pnode) {Node* current = *pnode;if ((now - current->lastSeenMs) > HEARTBEAT_TIMEOUT) {*pnode = current->next; // 从链表中移除// 回调通知节点离线if (manager->onOffline) {manager->onOffline(current->id, &current->uid);}free(current); // 释放节点内存manager->activeCount--;} else {pnode = &(*pnode)->next;}}
}

该函数遍历所有节点,检查最后活跃时间是否超时,超时则移除节点并触发下线回调。

四、节点查找与管理

4.1 通过UID查找节点

static Node* FindNodeByUID(NodeManager* manager, const DeviceUID* uid) {Node* current = manager->head;while (current) {if (CompareDeviceUID(&current->uid, uid)) return current;current = current->next;}return NULL;
}

4.2 通过ID查找节点

static Node* FindNodeByID(NodeManager* manager, uint8_t id) {Node* current = manager->head;while (current) {if (current->id == id) return current;current = current->next;}return NULL;
}

4.3 获取活跃节点列表

uint8_t GetActiveNodeIDs(NodeManager* manager, uint8_t* outputBuffer, uint8_t bufferSize) {uint8_t count = 0;Node* current = manager->head;while (current && count < bufferSize) {outputBuffer[count++] = current->id;current = current->next;}qsort(outputBuffer, count, sizeof(uint8_t), CompareNodeIDs);return count;
}

五、回调机制实现

5.1 回调函数注册

void NodeManager_RegisterCallbacks(NodeManager* manager, NodeOnlineCallback onOnline, NodeOfflineCallback onOffline) {manager->onOnline = onOnline;manager->onOffline = onOffline;
}

5.2 示例回调函数

void OnNodeOnline(uint8_t id, const DeviceUID* uid) {printf("[Callback] Node %d is ONLINE!\n", id);
}void OnNodeOffline(uint8_t id, const DeviceUID* uid) {printf("[Callback] Node %d is OFFLINE!\n", id);
}

六、应用示例

void TestNodeManager() {NodeManager manager;NodeManager_Init(&manager);// 注册回调NodeManager_RegisterCallbacks(&manager, OnNodeOnline, OnNodeOffline);// 模拟设备UIDDeviceUID uid1 = {{0x00, 0x11, 0x22, 0x33, 0x44, 0x55}};DeviceUID uid2 = {{0x66, 0x77, 0x88, 0x99, 0xAA, 0xBB}};// 节点上线ProcessHeartbeat(&manager, 1, &uid1);  // 指定ID=1ProcessHeartbeat(&manager, INVALID_ID, &uid2);  // 自动分配ID// 打印活跃节点PrintActiveNodes(&manager);// 模拟超时printf("\nSimulating timeout...\n");GetSysTimeMs();  // 模拟时间流逝CheckTimeoutNodes(&manager);PrintActiveNodes(&manager);// 主动释放节点printf("\nManually releasing node...\n");ReleaseNodeID(&manager, 2);PrintActiveNodes(&manager);// 清理NodeManager_Cleanup(&manager);
}

七、总结

本文详细介绍了一个高效的动态ID管理系统的设计与实现,该系统具有以下优点:

  • 灵活性:支持动态ID分配和释放

  • 可靠性:通过心跳机制确保节点状态准确

  • 可扩展性:易于添加新功能如安全验证等

  • 低开销:内存占用小,适合嵌入式环境

  • 事件驱动:通过回调机制实现松耦合

这种动态ID管理方案非常适合物联网设备、传感器网络等需要管理大量动态节点的嵌入式应用场景。

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

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

相关文章

WebSocket 双向通信技术详解

引言 在现代Web应用中&#xff0c;实时通信已经成为不可或缺的一部分。想象一下聊天应用、在线游戏、股票交易平台或协作工具&#xff0c;这些应用都需要服务器能够即时将更新推送给客户端&#xff0c;而不仅仅是等待客户端请求。WebSocket技术应运而生&#xff0c;它提供了一…

kafka菜鸟教程

一、kafka原理 1、kafka是一个高性能的消息队列系统&#xff0c;能够处理大规模的数据流&#xff0c;并提供低延迟的数据传输&#xff0c;它能够以每秒数十万条消息的速度进行读写操作。 二、kafka优点 1、服务解耦 &#xff08;1&#xff09;提高系统的可维护性‌ 通过服务…

SQLMap工具使用

一、SQLMap介绍 SQLMap 是一款强大的开源自动化 SQL 注入工具&#xff0c;用于检测和利用 Web 应用程序中的 SQL 注入漏洞。其工作原理是SQLMap 通过向目标 URL 发送带有特殊构造的 SQL 语句的请求&#xff0c;观察目标应用程序的响应&#xff0c;来判断是否存在 SQL 注入漏洞…

virtualbox安装xp系统卡顿的解决

安装virtualbox的增强功能即可。 先去下载 — Oracle VirtualBox下载 VirtualBox Guest Additions iso镜像 然后在这里导入iso镜像 再按照这几步操作 virtualbox按键 强制关闭xp-cuckoo的虚拟机 VBoxManage controlvm "xp-cuckoo" poweroff

观察者 ➜ 事件总线:一路走来的碎碎念

写给未来的自己:每次手敲事件模型都要 Google,干脆把思路和踩坑一次性记清楚。文章很长,都是唠叨,目的是让自己看两眼就能把设计理由找回来。 目录 为什么我要折腾事件模型?V0 ─ 单一事件的观察者模式V1 ─ 多事件同步总线(类型拆分)V2 ─ 订阅者优先级(链式调用可控)…

windwos脚本 | 基于scrcpy,只投声音、只投画面

安装scrcpy&#xff0c;scrcpy自带adb 写脚本命名为 .bat 结尾 注意这里的set "PATHD:\tools\scrcpy-win64-v3.2;%PATH%" 替换成scrcpy的安装目录 echo off :: 设置UTF-8编码 chcp 65001 > nul :: 设置标题 title 手机投屏工具:: 添加 scrcpy 路径到 PATH set &q…

Android device PCO (protocol configuration options) intro

术语 英文缩写英文全称中文PCOprotocol configuration options协议配置选项RILradio interface layer 无线电接口层PCO介绍 PCO(Protocol Configuration Options) 是 3GPP 标准协议(TS 24.008)中定义的核心概念,用于在 LTE/5G 网络建立 PDN 连接时传递动态配置参数(如 D…

Spring Boot配置文件优先级全解析:如何优雅覆盖默认配置?

&#x1f4da; 一、为什么需要了解配置文件优先级&#xff1f; 想象一下&#xff0c;你正在玩一个游戏&#x1f3ae;&#xff0c;游戏里有默认设置&#xff0c;但你可以通过不同的方式修改这些设置&#xff1a; 游戏内置的默认设置&#xff08;就像Spring Boot的默认配置&…

汽车行驶工况特征参数:从“速度曲线”到“驾驶DNA”的硬核解码

作为新能源汽车行业的从业者&#xff0c;你是否曾困惑于这些问题&#xff1a; 为什么同一款电动车&#xff0c;不同用户的实际续航差异高达30%&#xff1f;如何精准量化驾驶行为对电池寿命的影响&#xff1f;车企标定的“NEDC续航”与真实路况差距的根源是什么&#xff1f; 这…

HTTP 2.0 协议特性详解

1. 使用二进制协议&#xff0c;简化传输的复杂性&#xff0c;提高了效率 2. 支持一个 TCP 链接发起多请求&#xff0c;移除 pipeline HTTP/2 移除了 HTTP/1.1中的管道化&#xff08;pipeline&#xff09;机制&#xff0c;转而采用多路复用&#xff08;Multiplexing&#xff0…

完美解决浏览器不能复制的问题(比如赛氪网的中题库练习题)

仅供复制题库题目进行打印学习使用&#xff01; 最近想把赛氪网题库中的题目打印出来做练习&#xff0c;发现题库中的题目不能复制&#xff0c;不能在试卷上勾画标记太难受了&#xff0c;而且不能留作材料以后复习&#xff0c;故出此策。 而且CtrlP打印出的pdf会缺少题目。(我…

std::set (C++)

std::set 1. 概述定义特点 2. 内部实现3. 性能特征4. 常用 API5. 使用示例6. 自定义比较器7. 注意事项与优化8. 使用建议 1. 概述 定义 template<class Key,class Compare std::less<Key>,class Allocator std::allocator<Key> > class std::set;特点 有…

SSM省市区三级联动和三表联查附带数据库

SSM省市区三级联动和三表联查 ------附带数据库码云地址&#xff1a;https://gitee.com/Mr_ZKC/NO1 数据库在项目中

曲棍球·棒球1号位

中国女子曲棍球队曾涌现过马弋博、李红侠等优秀选手&#xff0c;但“李红”这一名字可能为信息误差。以下为您系统介绍曲棍球&#xff0c;并结合棒球进行对比分析&#xff1a; 曲棍球&#xff08;Hockey&#xff09;核心特点 运动形式 分为草地曲棍球&#xff08;夏季奥运会项…

12芯束装光纤不同包层线颜色之间的排列顺序

为什么光纤线必须按照以下颜色顺序进行排序&#xff1f;这其实是为了防止光污染的问题&#xff0c;不同颜色在传递光时从包层表皮漏光传感到梳妆的其它纤芯上&#xff0c;会有光污染的问题&#xff0c;而为了减少并防止光污染的现象&#xff0c;所以在光通信之中&#xff0c;需…

c++程序的打包编译cmake+make

c打包编译 1 在不用系统中打包介绍1.1 linux中打包c程序的2种方式1.2 windows中打包c程序1.3 cmakeNinja和cmakemake的两种方式对比1.3.1 Ninja是什么&#xff08;可以认为是make工具的一个替代产品&#xff09;1.3.2 cmakeNinja可以用于linux和windows系统中&#xff0c;编译效…

Spark on K8s 在 vivo 大数据平台的混部实战与优化

一、Spark on K8s 简介 (一)定义与架构 Spark on K8s 是一种将 Spark 运行在 Kubernetes(K8s)集群上的架构,由 K8s 直接创建 Driver 和 Executor 的 Pod 来运行 Spark 作业。其架构如下。 Driver Pod:相当于 Spark 集群中的 Driver,负责作业的调度和管理,它会根据作业…

MDA测量数据查看器【内含工具和源码地址】

一、工具介绍 MDA测量数据查看器用于显示和分析以MDF格式提供的测量数据。 支持MDF3.3之前含MDF3.3的二进制格式&#xff0c;支持Vector CANape and ETAS Inca. Kvaser CAN Logger (MDF 3.2) 文件。 MDF (Measurement Data Format)是一种二进制文件&#xff0c;用来记录、交换…

番外篇 | SEAM-YOLO:引入SEAM系列注意力机制,提升遮挡小目标的检测性能

前言:Hello大家好,我是小哥谈。SEAM(Squeeze-and-Excitation Attention Module)系列注意力机制是一种高效的特征增强方法,特别适合处理遮挡和小目标检测问题。该机制通过建模通道间关系来自适应地重新校准通道特征响应。在遮挡小目标检测中的应用优势包括:1)通道注意力增强…