一种物联网应用中基于Netty的海量数据接入方法及系统

    公开(公告)号:CN114095537B

    公开(公告)日:2023-07-14

    申请号:CN202111369026.X

    申请日:2021-11-18

    Abstract: 本发明属于物联网数据接入技术领域,特别涉及一种物联网应用中基于Netty的海量数据接入方法及系统,方法包括当接入层节点的Netty服务端接收到终端报文后,对报文类型进行识别并以线程无锁化调度存入本地阻塞队列中;阻塞队列专属消费线程从队列拉取报文数据,若报文为核心数据,线程调用负载均衡模块选报文数据进行转发;否则线程通过本地Kafka客户端将报文数据发送到kafka转发专属Topic分区;数据解析层节点的Netty服务端接收到或者从Kafka中拉取到报文数据后,将其转换成结构化数据后发送到Kafka业务专属Topic分区;本发明充分发挥Netty可承接数十万终端通信的优势,实现业务解耦。

    一种车联网中基于NOMA的多任务卸载方法

    公开(公告)号:CN114501550A

    公开(公告)日:2022-05-13

    申请号:CN202210162243.X

    申请日:2022-02-22

    Abstract: 本发明属于车联网系统中无线通信技术领域,涉及一种车联网中基于NOMA的多任务卸载方法,包括:初始化网络模型,确定请求卸载车辆用户数目、车辆用户的卸载任务和网络信道容量;判断请求卸载车辆用户数目是否超过网络信道容量,若当前车辆用户数目不超过网络信道容量,则选择基于OMA的卸载方法进行任务卸载,若超过网络信道容量,则选择基于NOMA的卸载方法进行任务卸载。本发明解决了多车辆用户同时卸载所面临的信道资源不足,任务卸载排序的问题,利用基于NOMA的卸载方法进行卸载,该方法可提高信道资源利用率和系统吞吐量,可有效地降低任务传输时延。

    一种车联网中基于NOMA的多任务卸载方法

    公开(公告)号:CN114501550B

    公开(公告)日:2025-02-11

    申请号:CN202210162243.X

    申请日:2022-02-22

    Abstract: 本发明属于车联网系统中无线通信技术领域,涉及一种车联网中基于NOMA的多任务卸载方法,包括:初始化网络模型,确定请求卸载车辆用户数目、车辆用户的卸载任务和网络信道容量;判断请求卸载车辆用户数目是否超过网络信道容量,若当前车辆用户数目不超过网络信道容量,则选择基于OMA的卸载方法进行任务卸载,若超过网络信道容量,则选择基于NOMA的卸载方法进行任务卸载。本发明解决了多车辆用户同时卸载所面临的信道资源不足,任务卸载排序的问题,利用基于NOMA的卸载方法进行卸载,该方法可提高信道资源利用率和系统吞吐量,可有效地降低任务传输时延。

    一种物联网应用中基于Netty的海量数据接入方法及系统

    公开(公告)号:CN114095537A

    公开(公告)日:2022-02-25

    申请号:CN202111369026.X

    申请日:2021-11-18

    Abstract: 本发明属于物联网数据接入技术领域,特别涉及一种物联网应用中基于Netty的海量数据接入方法及系统,方法包括当接入层节点的Netty服务端接收到终端报文后,对报文类型进行识别并以线程无锁化调度存入本地阻塞队列中;阻塞队列专属消费线程从队列拉取报文数据,若报文为核心数据,线程调用负载均衡模块选报文数据进行转发;否则线程通过本地Kafka客户端将报文数据发送到kafka转发专属Topic分区;数据解析层节点的Netty服务端接收到或者从Kafka中拉取到报文数据后,将其转换成结构化数据后发送到Kafka业务专属Topic分区;本发明充分发挥Netty可承接数十万终端通信的优势,实现业务解耦。

Patent Agency Ranking