[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN107508909A - 多流实时管理无线中间件的处理方法 - Google Patents

多流实时管理无线中间件的处理方法 Download PDF

Info

Publication number
CN107508909A
CN107508909A CN201710833049.9A CN201710833049A CN107508909A CN 107508909 A CN107508909 A CN 107508909A CN 201710833049 A CN201710833049 A CN 201710833049A CN 107508909 A CN107508909 A CN 107508909A
Authority
CN
China
Prior art keywords
data
continuous
query
real
output control
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201710833049.9A
Other languages
English (en)
Inventor
侯君
李千目
王烁
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Wuxi Nanligong Technology Development Co Ltd
Original Assignee
Wuxi Nanligong Technology Development Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Wuxi Nanligong Technology Development Co Ltd filed Critical Wuxi Nanligong Technology Development Co Ltd
Priority to CN201710833049.9A priority Critical patent/CN107508909A/zh
Publication of CN107508909A publication Critical patent/CN107508909A/zh
Pending legal-status Critical Current

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/56—Provisioning of proxy services
    • H04L67/565—Conversion or adaptation of application format or content
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/56—Provisioning of proxy services
    • H04L67/565—Conversion or adaptation of application format or content
    • H04L67/5651—Reducing the amount or size of exchanged application data
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/56—Provisioning of proxy services
    • H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
    • H04L67/5682—Policies or rules for updating, deleting or replacing the stored data

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Mobile Radio Communication Systems (AREA)

Abstract

本发明公开了一种多流实时管理无线中间件的处理方法包括以下步骤：（1）根据应用提出的连续查询请求，分别进行连续查询语法分析和数据清洗、压缩；（2）所述步骤（1）中的连续查询语法分析具有查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要；（3）所述步骤（1）中的数据清洗、压缩后进行数据缓冲；（4）对所述步骤（3）产生的数据进行数据记录并输出控制和持久存储；（5）对数据的输出控制进行服务质量监控；输出的数据流反馈给所述步骤（1）中的连续查询语法分析和数据清洗、压缩。采用多通道流输入，多元数据探测连续查询注册，改变现有数据单通道流处理模式，增强数据管理的动态可扩展性。

Description

多流实时管理无线中间件的处理方法
技术领域
本发明属于计算机物联网技术领域，尤其是涉及一种多流实时管理无线中间件的处理方法。
背景技术
移动互联网智能终端的协同安全防护系统主要由三大功能模块组成：多层次静态安全感知功能、主动式安全服务功能和策略性安全风险控制功能。三个子系统协同防护，其中，多层次静态安全感知功能关注安全服务和管理控制，安全服务包括入侵检测、流量分析、漏洞扫描、日志审计，管理控制包括匿名双向安全接入；主动式安全服务功能重点利用安全策略层次联合建模方法，结合风险事件之间的因果关系，定位关键风险；策略性安全风险控制功能重点构建基于主观逻辑扩展的动态信任模型，设计维护终端公平性、隐私性的信任激励和惩罚机制，并研发可操作的基于马氏链的移动互联网智能终端安全风险预测和动态控制体系。
移动互联网智能终端的协同安全防护系统中的多层次静态安全感知功能、主动式安全服务功能和策略性安全风险控制功能三个关键技术问题。
发明内容
本发明要解决的问题是，提供一种改变现有数据单通道流处理模式，以流处理引擎为核心实时处理信息，实现运算管理、接口管理和存储管理，增强数据管理的动态可扩展性的多流实时管理无线中间件的处理方法。
为解决上述技术问题，本发明采用的技术方案是：该多流实时管理无线中间件的处理方法包括以下步骤：
（1）根据应用提出的连续查询请求，分别进行连续查询语法分析和数据清洗、压缩；
（2）所述步骤（1）中的连续查询语法分析具有查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要；其中，针对查询算子、查询计划缓冲进行查询计划优化，实时调度同步数据操作工作区，且对历史数据概要进行存储控制；
（3）所述步骤（1）中的数据清洗、压缩后进行数据缓冲，输入队列并形成结果队列，该结果受所述步骤（2）中的查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要的所形成的缓冲池影响；
（4）对所述步骤（3）产生的数据进行数据记录并输出控制和持久存储；
（5）对数据的输出控制进行服务质量监控，并将监控结果反馈给事件查询引擎；所述事件查询引擎根据反馈的结果进行查询计划优化、实时调度和存储控制；
在所述步骤（4）中输出的数据流通过数据流采集转换/阅读器适配反馈给所述步骤（1）中的连续查询语法分析和数据清洗、压缩。
上述技术方案采用多通道流输入，多元数据探测连续查询注册，改变现有数据单通道流处理模式，以流处理引擎为核心实时处理信息，实现运算管理、接口管理和存储管理，增强数据管理的动态可扩展性。中间件的多数据流实时管理和海量数据存储分发要求高密度计算、高性价比和高可扩展性。实时数据管理中间件控制板接口对标准总线 CAN/LIN 开放，接口对通用信号处理平台开放，直接以高速硬连接的方式为应用层提供数据。
优选的，所述步骤（4）中输出控制和持久存储的数据记录直接进行RFID应用。
优选的，所述步骤（4）中输出控制的数据记录连接有记录设备。
优选的，通过接口管理对所述步骤（4）中输出控制的数据记录进行选定数据输出。
具体实施方式
在本实施例中，多流实时管理无线中间件的处理方法包括以下步骤：
（1）根据应用提出的连续查询请求，分别进行连续查询语法分析和数据清洗、压缩；
（2）所述步骤（1）中的连续查询语法分析具有查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要；其中，针对查询算子、查询计划缓冲进行查询计划优化，实时调度同步数据操作工作区，且对历史数据概要进行存储控制；
（3）所述步骤（1）中的数据清洗、压缩后进行数据缓冲，输入队列并形成结果队列，该结果受所述步骤（2）中的查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要的所形成的缓冲池影响；
（4）对所述步骤（3）产生的数据进行数据记录并输出控制和持久存储；
（5）对数据的输出控制进行服务质量监控，并将监控结果反馈给事件查询引擎；所述事件查询引擎根据反馈的结果进行查询计划优化、实时调度和存储控制；
在所述步骤（4）中输出的数据流通过数据流采集转换/阅读器适配反馈给所述步骤（1）中的连续查询语法分析和数据清洗、压缩；
还可以的，所述步骤（4）中输出控制和持久存储的数据记录直接进行RFID应用，输出控制的数据记录连接有记录设备，通过接口管理对所述步骤（4）中输出控制的数据记录进行选定数据输出。
上面结合对本发明的实施方式作了详细的说明，但是本发明不限于上述实施方式，在所属技术领域普通技术人员所具备的知识范围内，还可以在不脱离本发明宗旨的前提下做出各种变化。

Claims (4)

1.一种多流实时管理无线中间件的处理方法，其特征在于，包括以下步骤：
（1）根据应用提出的连续查询请求，分别进行连续查询语法分析和数据清洗、压缩；
（2）所述步骤（1）中的连续查询语法分析具有查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要；其中，针对查询算子、查询计划缓冲进行查询计划优化，实时调度同步数据操作工作区，且对历史数据概要进行存储控制；
（3）所述步骤（1）中的数据清洗、压缩后进行数据缓冲，输入队列并形成结果队列，该结果受所述步骤（2）中的查询算子、查询计划缓冲，同步数据操作工作区以及历史数据概要的所形成的缓冲池影响；
（4）对所述步骤（3）产生的数据进行数据记录并输出控制和持久存储；
（5）对数据的输出控制进行服务质量监控，并将监控结果反馈给事件查询引擎；所述事件查询引擎根据反馈的结果进行查询计划优化、实时调度和存储控制；
在所述步骤（4）中输出的数据流通过数据流采集转换/阅读器适配反馈给所述步骤（1）中的连续查询语法分析和数据清洗、压缩。
2.根据权利要求1所述的多流实时管理无线中间件的处理方法，其特征在于，所述步骤（4）中输出控制和持久存储的数据记录直接进行RFID应用。
3.根据权利要求1所述的多流实时管理无线中间件的处理方法，其特征在于，所述步骤（4）中输出控制的数据记录连接有记录设备。
4.根据权利要求1所述的多流实时管理无线中间件的处理方法，其特征在于，通过接口管理对所述步骤（4）中输出控制的数据记录进行选定数据输出。
CN201710833049.9A 2017-09-15 2017-09-15 多流实时管理无线中间件的处理方法 Pending CN107508909A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201710833049.9A CN107508909A (zh) 2017-09-15 2017-09-15 多流实时管理无线中间件的处理方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201710833049.9A CN107508909A (zh) 2017-09-15 2017-09-15 多流实时管理无线中间件的处理方法

Publications (1)

Publication Number Publication Date
CN107508909A true CN107508909A (zh) 2017-12-22

Family

ID=60696805

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201710833049.9A Pending CN107508909A (zh) 2017-09-15 2017-09-15 多流实时管理无线中间件的处理方法

Country Status (1)

Country Link
CN (1) CN107508909A (zh)

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101013986A (zh) * 2007-02-02 2007-08-08 南京邮电大学 基于移动代理中间件的传感器网络数据查询系统实现方法
CN102156893A (zh) * 2011-03-24 2011-08-17 大连海事大学 Rfid设备网络环境下采集数据的清洗系统及方法
CN102546247A (zh) * 2011-12-29 2012-07-04 华中科技大学 一种适用流式处理的大规模数据连续分析系统
CN103064875A (zh) * 2012-10-30 2013-04-24 中国标准化研究院 一种服务化空间数据分布式查询方法
CN104391679A (zh) * 2014-11-18 2015-03-04 浪潮电子信息产业股份有限公司 一种非规则流中高维数据流的gpu处理方法
CN106897343A (zh) * 2016-07-20 2017-06-27 阿里巴巴集团控股有限公司 执行计划的查找方法、存储方法及装置

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101013986A (zh) * 2007-02-02 2007-08-08 南京邮电大学 基于移动代理中间件的传感器网络数据查询系统实现方法
CN102156893A (zh) * 2011-03-24 2011-08-17 大连海事大学 Rfid设备网络环境下采集数据的清洗系统及方法
CN102546247A (zh) * 2011-12-29 2012-07-04 华中科技大学 一种适用流式处理的大规模数据连续分析系统
CN103064875A (zh) * 2012-10-30 2013-04-24 中国标准化研究院 一种服务化空间数据分布式查询方法
CN104391679A (zh) * 2014-11-18 2015-03-04 浪潮电子信息产业股份有限公司 一种非规则流中高维数据流的gpu处理方法
CN106897343A (zh) * 2016-07-20 2017-06-27 阿里巴巴集团控股有限公司 执行计划的查找方法、存储方法及装置

Similar Documents

Publication Publication Date Title
Zhen et al. Scheduling quay cranes and yard trucks for unloading operations in container ports
CN107977795A (zh) 一种政府采购管理交易系统
CN103778384A (zh) 一种基于身份认证的虚拟终端安全环境的保护方法及系统
CN112532718B (zh) 基于区块链的海上装备数据共享系统、方法和介质
CN106161566A (zh) 一种云计算数据中心访问管理方法和云计算数据中心
CN104683348A (zh) 一种基于属性的访问控制策略合成方法
WO2023000413A1 (zh) 一种自适应跨域访问认证方法、系统、终端以及存储介质
CN111275391A (zh) 在线式资产智能分发系统和方法
US20220014589A1 (en) System for intelligent sensor data transfer and device manipulation leveraging quantum optimization engine
An et al. [Retracted] Legal Protection of Artificial Intelligence Data and Algorithms from the Perspective of Internet of Things Resource Sharing
CN107508909A (zh) 多流实时管理无线中间件的处理方法
CN109271769A (zh) 一种用户管理系统及用户管理方法
CN116910161B (zh) 一种协同分析系统、方法、电子设备以及计算机可读介质
CN205419354U (zh) 手机乘梯系统
CN114978715B (zh) 一种基于社会情境访问控制模型的虚假信息传播控制方法
Yue et al. Internet of connected vehicles against cyber-attacks based on resilient adaptive event trigger mechanism control
CN107580061A (zh) 多流实时管理无线中间件的框架系统
CN111427961B (zh) 基于区块链的简历确权方法以及区块链简历系统及其设备
Shuanglin Data security policy in the cloud computing
Chen Platform economies: The boss's old and new clothes
CN100403750C (zh) 一种移动代理群组的自分割协作保护方法
Xu et al. A trade-off method for timetable rescheduling considering transfer connections in subway networks
Kovacevic et al. Authentication and Identity Management Based on Zero Trust Security Model in Micro-cloud Environment
US11677682B1 (en) Reactive throttle infrastructure
CN118317147B (zh) 一种分布式音视频文件处理系统及处理方法

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
RJ01 Rejection of invention patent application after publication
RJ01 Rejection of invention patent application after publication

Application publication date: 20171222