[go: up one dir, main page]

CN113162942A - 一种自适应协议的转发方法 - Google Patents

一种自适应协议的转发方法 Download PDF

Info

Publication number
CN113162942A
CN113162942A CN202110462300.1A CN202110462300A CN113162942A CN 113162942 A CN113162942 A CN 113162942A CN 202110462300 A CN202110462300 A CN 202110462300A CN 113162942 A CN113162942 A CN 113162942A
Authority
CN
China
Prior art keywords
data
protocol
terminal
module
platform
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
CN202110462300.1A
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.)
Shenzhen Yiqi Technology Co ltd
Original Assignee
Shenzhen Yiqi Technology 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 Shenzhen Yiqi Technology Co ltd filed Critical Shenzhen Yiqi Technology Co ltd
Priority to CN202110462300.1A priority Critical patent/CN113162942A/zh
Publication of CN113162942A publication Critical patent/CN113162942A/zh
Pending legal-status Critical Current

Links

Images

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/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
    • 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/01—Protocols
    • H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
    • 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/55—Push-based network services
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/08—Protocols for interworking; Protocol conversion

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer Security & Cryptography (AREA)
  • Health & Medical Sciences (AREA)
  • Computing Systems (AREA)
  • General Health & Medical Sciences (AREA)
  • Medical Informatics (AREA)
  • Small-Scale Networks (AREA)

Abstract

本发明公开了一种自适应协议的转发方法，涉及汽车安全技术领域，包括网关接收多个终端上报的数据，网关对终端上报的数据进行统一管理，并将不同终端的数据发送至协议模块进行协议转换，转换成对应的平台所需的数据，由分布式系统将协议转换成功的数据推送至各个平台的数据存储的中间插件，本发明能够避免各个终端搭建自己的网关，且不必改动终端上报的数据格式，因此降低了各个终端的维护管理费用及减少部分服务器资源消耗，大大降低了终端的运营成本，并且可以统一管理和监控转发业务的状态和转发的具体信息，在节省服务器资源的同时，降低了运维管理升级监控的难度。

Description

一种自适应协议的转发方法
技术领域
本发明涉及汽车安全技术领域，具有来说，涉及一种自适应协议的转发方法。
背景技术
随着汽车的普及，人们出行对汽车的依靠也越来越大，汽车安全方面的关注也随之提高。汽车的行程记录、位置监控、安全控制等管理性平台、产品也逐渐增加。
但是，由于这类平台性工具太多，终端上报的数据量过大，若想要管理这些数据就需要各自的平台都需要包含自己的网关，且需要终端支持自己平台的终端数据解析模块，造成较大量的服务资源浪费，各个平台都需要用较大的代价来处理这些问题，若有多个客户的转发业务，需要单独分开管理和部署，增加了运维的工作量及管理难度，同时对转发业务的状态、情况很难进行监控和管理。
发明内容
为了克服现有技术的不足，本发明的一种自适应协议的转发方法，能够统一管理和监控转发业务的状态以及转发发具体信息，在节省服务器资源的同时，降低运维管理升级监控的难度。
本发明解决其技术问题所采用的技术方案是：
一种自适应协议的转发方法，其改进之处在于，包括网关接收多个终端上报的数据，网关对终端上报的数据进行统一管理，并将不同的终端的数据发送至协议模块进行协议转换，转换成对应的平台所需的数据，由分布式系统将协议转换成功的数据推送至各个平台的数据存储的中间插件。
作为上述技术方案的改进，网关包括多个存储模块，终端向网关上报的数据，网关将数据分类，并分别存储到多个存储模块中。
作为上述技术方案的进一步改进，网关包括多个推送数据结构，协议转换平台从存储模块指定类别的数据结构读取数据，将其转换格式后，存储到推送数据结构中。
作为上述技术方案的进一步改进，分布式系统实时从推送结构读取数据，获取的数据直接推送至各个平台的数据存储的中间插件。
作为上述技术方案的进一步改进，协议包括转发数据类型、转发终端列表、数据格式、数据对接方式以及数据对接的各个平台的数据存储的中间插件，分布式系统设有读取程序，读取程序根据协议的转发数据类型，从数据结构中读取数据后，将数据传送至协议模块，并读取协议中的转发终端列表，判断数据是否需要转发，如果数据需要转发，则将数据格式进行转换，并将转换的数据格式推送到KAFKA，如果数据不需要转发，则将数据丢弃。
作为上述技术方案的进一步改进，分布式系统从KAFKA中读取数据，按照协议判断数据是否需要定时发送，如果需要定时转发，启动定时任务，并将这段时间内读取到的数据按照协议格式打包，根据数据对接方式推送至各个平台的数据存储的中间插件，如果不需要定时转发，则读取到数据后直接通过数据对接方式推送至各个平台的数据存储的中间插件。
作为上述技术方案的进一步改进，所述的终端包括短信型终端，短信型终端包括短信发送模块、一级信息接收模块、一级触发模块和一级信息处理模块，所述的一级信息接收模块、一级信息处理模块、一级触发模块和短信发送模块依次电性连接。
作为上述技术方案的进一步改进，所述的终端包括流量型终端，流量型终端包括数据流量接入模块、二级触发模块和二级信息处理模块，所述的数据流量接入模块、二级信息处理模块以及二级触发模块依次连接。
作为上述技术方案的进一步改进，数据包括终端轨迹数据、平台报警数据以及终端报警数据。
作为上述技术方案的进一步改进，所述的平台包括汽车的行车记录、位置监控以及安全管控任意一种或多种的管理性平台
本发明的有益效果是：避免各个终端搭建自己的网关，且不必改动终端上报的数据格式，因此降低了各个终端的维护管理费用及减少部分服务器资源的消耗，大大降低了终端的运营成本，并且可以统一管理和监控转发业务的状态和转发的具体信息，在节省服务器资源的同时，降低了运维管理升级监控的难度。
附图说明
图1为本发明的流程图。
具体实施方式
下面结合附图和实施例对本发明进一步说明。
以下将结合实施例和附图对本发明的构思、具体结构及产生的技术效果进行清楚、完整地描述，以充分地理解本发明的目的、特征和效果。显然，所描述的实施例只是本发明的一部分实施例，而不是全部实施例，基于本发明的实施例，本领域的技术人员在不付出创造性劳动的前提下所获得的其他实施例，均属于本发明保护的范围。另外，专利中涉及到的所有联接/连接关系，并非单指构件直接相接，而是指可根据具体实施情况，通过添加或减少联接辅件，来组成更优的联接结构。本发明创造中的各个技术特征，在不互相矛盾冲突的前提下可以交互组合。
参考图1，本发明揭示了一种自适应协议的转发方法，包括网关接收多个终端上报的数据，网关对终端上报的数据进行统一管理，并将不同的终端的数据发送至协议模块进行协议转换，转换成对应的平台所需的数据，由分布式系统将协议转换成功的数据推送至各个平台的数据存储的中间插件，所述的平台包括汽车的行车记录、位置监控以及安全管控任意一种或多种的管理性平台。
在上述实施例中，本发明的网关包括多个存储模块和多个推送结构，终端向网关上报的数据，网关将数据分类，并分别存储到多个存储模块中，协议转换平台从存储模块指定类别的数据结构读取数据，将其转换格式后，存储到推送数据结构中，分布式系统实时从推送结构读取数据，获取的数据直接推送至各个平台的数据存储的中间插件。本发明可以避免各个平台搭建自己的网关，以及不必改动终端上报的数据格式，可以降低各个平台维护管理的费用及减少部分服务器资源，大大降低了平台运营成本。
再进一步的，协议包括转发数据类型、转发终端列表、数据格式、数据对接方式以及数据对接的各个平台的数据存储的中间插件，分布式系统设有读取程序，读取程序根据协议的转发数据类型，从数据结构中读取数据后，将数据传送至协议模块，并读取协议中的转发终端列表，判断数据是否需要转发，如果数据需要转发，则将数据格式进行转换，并将转换的数据格式推送到KAFKA，如果数据不需要转发，则将数据丢弃。
在上述实施例中，分布式系统从KAFKA中读取数据，按照协议判断数据是否需要定时发送，如果需要定时转发，启动定时任务，并将这段时间内读取到的数据按照协议格式打包，根据数据对接方式推送至各个平台的数据存储的中间插件，如果不需要定时转发，则读取到数据后直接通过数据对接方式推送至各个平台的数据存储的中间插件。
再进一步的，所述的终端包括短信型终端，短信型终端包括短信发送模块、一级信息接收模块、一级触发模块和一级信息处理模块，所述的一级信息接收模块、一级信息处理模块、一级触发模块和短信发送模块依次电性连接。
在上述实施例中，一级信息接收模块用于接收网关下发的各种指令信号并将指令信号传送给一级信息处理模块，一级信息处理模块识别一级信息接收模块传送的指令信号触发本地数据收集、分析以及整理，并判断是否需要发送给短信发送模块，若需要立即上报数据，则传递一个信号给一级触发模块，一级触发模块收到信号立即触发短信发送模块，将数据通过短信方式发送到网关，如果一级信息处理模块判断不需要立即上报数据，则不用给一级触发模块发送信号，一级触发模块则自动根据终端默认设置30秒钟或1分钟时间定时触发短信发送模块，将本地最终的数据上报到网关。
再进一步的，所述的终端包括流量型终端，流量型终端包括数据流量接入模块、二级触发模块和二级信息处理模块，所述的数据流量接入模块、二级信息处理模块以及二级触发模块依次连接。
在上述实施例中，数据流量接入模块用于接收网关下发的各种指令信号并将指令信号传送给二级信息处理模块，二级信息处理模块通过识别二级信息接收模块传送的指令信号触发本地数据收集、分析、整理，并根据指令信号判断是否需要发送一个数据上报，若需要立即上报数据，则使用链路方式传递一个信号给触发模块，二级触发模块收到信号就立即将最终的数据上报到网关，如果二级信息处理模块判断不需要立即上报数据，则不用二级触发模块发送信号，二级触发模块则自动根据终端默认设置1秒钟或5秒钟定时触发数据流量接入模块，将本地最终的数据上报到网关。
如果网络或信号不好时数据上报失败，数据则会继续保存到终端本地，等待信号和网络稳定后，一级触发模块或二级触发模块再次上报。
再进一步的，数据包括终端轨迹数据、平台报警数据以及终端报警数据。本发明根据实际业务需求，支持网关横向集群分布式部署。如一部分网关接入终端轨迹上报数据，一部分网关接入终端报警数据等。由于本发明的系统使用插件模式开发，当有新需求要进行转发业务，只需要扩展对应的插件程序，根据协议配置好转发，上传插件程序后，整个业务就接入完成了，并不需要重启服务或者是购买新的服务器，且所有的业务均能通过主程序进行监控，节省了不少资源。
另外，每一种数据可以只使用单一的数据读取程序，但根据数据量的产生速度、稳定性、读取的速度可以部署多套数据读取程序，每个读取程序读取一个区块的数据。每增加一个数据读取程序相应的需要增加转换程序。每增加一个不同的转发平台业务，需要整体扩展数据读取、转换、推送服务及转发数据存储结构。若多个转发平台业务间的协议格式相同仅需要重新扩展转换、推送服务及转发数据存储结构。
本发明的有益效果是：避免各个终端搭建自己的网关，且不必改动终端上报的数据格式，因此降低了各个终端维护管理费用及减少部分服务器资源的消耗，大大降低了终端的运营成本，并且可以统一管理和监控转发业务的状态和转发的具体信息，在节省服务器资源的同时，降低了运维管理升级监控的难度。
以上是对本发明的较佳实施进行了具体说明，但本发明创造并不限于所述实施例，熟悉本领域的技术人员在不违背本发明精神的前提下还可做出种种的等同变形或替换，这些等同的变形或替换均包含在本申请权利要求所限定的范围。

Claims (10)

1.一种自适应协议的转发方法，其特征在于，包括网关接收多个终端上报的数据，网关对终端上报的数据进行统一管理，并将不同的终端数据发送至协议模块进行协议转换，转换成对应的平台所需的数据，由分布式系统将协议转换成功的数据推送至各个平台的数据存储的中间插件。
2.根据权利要求1所述的一种自适应协议的转发方法，其特征在于，网关包括多个存储模块，终端向网关上报的数据，网关将数据分类，并分别存储到多个存储模块中。
3.根据权利要求2所述的一种自适应协议的转发方法，其特征在于，网关包括多个推送数据结构，协议转换平台从存储模块指定类别的数据结构读取数据，将其转换格式后，存储到推送数据结构中。
4.根据权利要求3所述的一种自适应协议的转发方法，其特征在于，分布式系统实时从推送结构读取数据，获取的数据直接推送至各个平台的数据存储的中间插件。
5.根据权利要求1所述的一种自适应协议的转发方法，其特征在于，协议包括转发数据类型、转发终端列表、数据格式、数据对接方式以及数据对接的各个平台的数据存储的中间插件，分布式系统设有读取程序，读取程序根据协议的转发数据类型，从数据结构中读取数据后，将数据传送至协议模块，并读取协议中的转发终端列表，判断数据是否需要转发，如果数据需要转发，则将数据格式进行转换，并将转换的数据格式推送到KAFKA，如果数据不需要转发，则将数据丢弃。
6.根据权利要求5所述的一种自适应协议的转发方法，其特征在于，分布式系统从KAFKA中读取数据，按照协议判断数据是否需要定时发送，如果需要定时转发，启动定时任务，并将这段时间内读取到的数据按照协议格式打包，根据数据对接方式推送至各个平台的数据存储的中间插件，如果不需要定时转发，则读取到数据后直接通过数据对接方式推送至各个平台的数据存储的中间插件。
7.根据权利要求2所述的一种自适应协议的转发方法，其特征在于，所述的终端包括短信型终端，短信型终端包括短信发送模块、一级信息接收模块、一级触发模块和一级信息处理模块，所述的一级信息接收模块、一级信息处理模块、一级触发模块和短信发送模块依次电性连接。
8.根据权利要求2所述的一种自适应协议的转发方法，其特征在于，所述的终端包括流量型终端，流量型终端包括数据流量接入模块、二级触发模块和二级信息处理模块，所述的数据流量接入模块、二级信息处理模块以及二级触发模块依次连接。
9.根据权利要求1-8任意一项所述的一种自适应协议的转发方法，其特征在于，数据包括终端轨迹数据、平台报警数据以及终端报警数据。
10.根据权利要求1-8任意一项所述的一种自适应协议的转发方法，其特征在于，所述的平台包括汽车的行车记录、位置监控以及安全管控任意一种或多种的管理性平台。
CN202110462300.1A 2021-04-27 2021-04-27 一种自适应协议的转发方法 Pending CN113162942A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202110462300.1A CN113162942A (zh) 2021-04-27 2021-04-27 一种自适应协议的转发方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202110462300.1A CN113162942A (zh) 2021-04-27 2021-04-27 一种自适应协议的转发方法

Publications (1)

Publication Number Publication Date
CN113162942A true CN113162942A (zh) 2021-07-23

Family

ID=76871712

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202110462300.1A Pending CN113162942A (zh) 2021-04-27 2021-04-27 一种自适应协议的转发方法

Country Status (1)

Country Link
CN (1) CN113162942A (zh)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114500648A (zh) * 2022-01-17 2022-05-13 徐工汉云技术股份有限公司 一种塔机数据多形式转换转发方法及系统
CN115883678A (zh) * 2023-03-08 2023-03-31 国网瑞嘉(天津)智能机器人有限公司 一种数据处理系统、方法、装置、设备及介质

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111131348A (zh) * 2018-10-31 2020-05-08 顺丰科技有限公司 一种车联网系统及其运行方法
CN111740952A (zh) * 2020-05-13 2020-10-02 南斗六星系统集成有限公司 一种车辆监管平台数据管理方法及系统
CN111787047A (zh) * 2020-04-22 2020-10-16 宁波小遛共享信息科技有限公司 一种车辆信息处理方法及装置
CN112261062A (zh) * 2020-11-03 2021-01-22 郑州信大捷安信息技术股份有限公司 支持多协议转换的物联网安全接入方法及网关、系统
CN112637366A (zh) * 2021-01-14 2021-04-09 江苏徐工信息技术股份有限公司 基于微服务的车辆网车辆数据采集方法

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111131348A (zh) * 2018-10-31 2020-05-08 顺丰科技有限公司 一种车联网系统及其运行方法
CN111787047A (zh) * 2020-04-22 2020-10-16 宁波小遛共享信息科技有限公司 一种车辆信息处理方法及装置
CN111740952A (zh) * 2020-05-13 2020-10-02 南斗六星系统集成有限公司 一种车辆监管平台数据管理方法及系统
CN112261062A (zh) * 2020-11-03 2021-01-22 郑州信大捷安信息技术股份有限公司 支持多协议转换的物联网安全接入方法及网关、系统
CN112637366A (zh) * 2021-01-14 2021-04-09 江苏徐工信息技术股份有限公司 基于微服务的车辆网车辆数据采集方法

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
刘静: "智能车载终端接入平台与高并发处理技术的研究与实现", 《中国优秀硕士论文全文数据库信息科技辑》 *

Cited By (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN114500648A (zh) * 2022-01-17 2022-05-13 徐工汉云技术股份有限公司 一种塔机数据多形式转换转发方法及系统
CN114500648B (zh) * 2022-01-17 2024-11-15 徐工汉云技术股份有限公司 一种塔机数据多形式转换转发方法及系统
CN115883678A (zh) * 2023-03-08 2023-03-31 国网瑞嘉(天津)智能机器人有限公司 一种数据处理系统、方法、装置、设备及介质
CN115883678B (zh) * 2023-03-08 2023-06-16 国网瑞嘉(天津)智能机器人有限公司 一种数据处理系统、方法、装置、设备及介质

Similar Documents

Publication Publication Date Title
CN112947372A (zh) 一种基于故障码主动上报的远程诊断方法
CN113452486B (zh) 车辆信息的上传方法、装置、设备和存储介质
CN113162942A (zh) 一种自适应协议的转发方法
EP2544406A1 (en) Method and management agent for event notifications correlation
CN109067491B (zh) 列车广播音频监控方法、平台及系统
CN110752943A (zh) 一种输电线路分布式故障诊断系统及方法
CN108183811B (zh) 基于业务分类的车联网接入连通系统及其控制方法
CN113691623A (zh) 车载Tbox的软件配置方法、装置及云端平台
CN111049673A (zh) 一种服务网关中api调用统计和监控的方法及系统
CN112671839A (zh) 数据处理的方法、装置、云系统及存储介质
CN113452667A (zh) 一种适用于多种协议类型的边缘物联终端接入方法
CN109343488A (zh) 基于微信和fdt技术的现场总线监控预警系统和方法
CN118890269A (zh) 车辆信息处理方法、装置、车辆及存储介质
JP2001292467A (ja) リモートプロシージャコールを利用した基地局の運用及び保全方法
CN113335018A (zh) 一种基于some/ip的车载空调服务调用系统
CN112235195A (zh) 上报数据处理方法及相关设备
CN112140936A (zh) 充电监控方法、系统和存储介质
CN208654637U (zh) 一种基于车载can总线的汽车台架试验的远程监控系统
CN115273271B (zh) 一种基于车辆娱乐主机采集车辆数据的系统及方法
CN116256546A (zh) 一种能耗监测方法及能耗监测系统
CN110708195B (zh) 物联网设备无线信号故障上报方法及系统
CN108989467B (zh) 集中式寻址方法
CN113407611A (zh) 一种数据集成分发平台和系统
CN110225070B (zh) 基于新能源车辆的实时数据处理方法及网关
CN112347157A (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: 20210723