[go: up one dir, main page]

CN116567035A - Internet of vehicles data uploading and receiving system, method, equipment and medium - Google Patents

Internet of vehicles data uploading and receiving system, method, equipment and medium Download PDF

Info

Publication number
CN116567035A
CN116567035A CN202310618590.3A CN202310618590A CN116567035A CN 116567035 A CN116567035 A CN 116567035A CN 202310618590 A CN202310618590 A CN 202310618590A CN 116567035 A CN116567035 A CN 116567035A
Authority
CN
China
Prior art keywords
data
load balancing
internet
vehicles
switching technology
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
CN202310618590.3A
Other languages
Chinese (zh)
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.)
Chery New Energy Automobile Co Ltd
Original Assignee
Chery New Energy Automobile 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 Chery New Energy Automobile Co Ltd filed Critical Chery New Energy Automobile Co Ltd
Priority to CN202310618590.3A priority Critical patent/CN116567035A/en
Publication of CN116567035A publication Critical patent/CN116567035A/en
Pending legal-status Critical Current

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/12Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/16Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Health & Medical Sciences (AREA)
  • Computing Systems (AREA)
  • General Health & Medical Sciences (AREA)
  • Medical Informatics (AREA)
  • Computer Security & Cryptography (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

本发明属于车联网数据领域,具体涉及一种车联网数据的上收系统、方法、设备和介质。其中负载均衡模块对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器;所述数据处理模块接收到数据,对数据根据类型进行筛选并发送至对应的云端平台;本发明通过第四层交换技术的负载均衡和基于第七层交换技术的负载均衡接收和发出数据,解决了大量车辆连接的并发问题。本发明通过数据处理模块配合负载均衡模块的系统传输,对数据进行进一步的分类处理,已发送至对应模块,实现高效传输。在数据分类之前,进行登录校验和拆包粘包处理,维护数据,提升操作的流畅性和系统的安全性。

The invention belongs to the field of Internet of Vehicles data, and in particular relates to a system, method, device and medium for receiving Internet of Vehicles data. Among them, the load balancing module processes the data from the vehicle, and modifies the target address of the data to the seventh-layer switching technology load balancing cluster machine; the data processing module receives the data, filters the data according to the type and sends it to the corresponding cloud Platform; the invention solves the concurrency problem of a large number of vehicle connections through the load balancing of the fourth layer switching technology and the load balancing based on the seventh layer switching technology to receive and send data. In the present invention, through the system transmission of the data processing module and the load balancing module, the data is further classified and processed, and the data is sent to the corresponding module to realize efficient transmission. Before data classification, login verification and unpacking and sticking processing are performed to maintain data and improve operational fluency and system security.

Description

一种车联网数据的上收系统、方法、设备和介质A system, method, device and medium for uploading data of Internet of Vehicles

技术领域technical field

本发明属于车联网数据领域,具体涉及一种车联网数据的上收系统、方法、设备和介质。The invention belongs to the field of Internet of Vehicles data, and in particular relates to a system, method, device and medium for receiving Internet of Vehicles data.

背景技术Background technique

车联网(Internet of Vehicle,LOV),是以行驶中的车辆为信息感知对象,借助新一代信息通信技术,实现车与车、人、路、服务平台之间的网络连接,提升车辆整体的智能驾驶水平,为用户提供安全、舒适、智能、高效的驾驶感受与交通服务。The Internet of Vehicles (LOV) is based on the moving vehicle as the object of information perception. With the help of a new generation of information and communication technology, it realizes the network connection between vehicles, people, roads and service platforms, and improves the overall intelligence of the vehicle. Driving level, to provide users with safe, comfortable, intelligent and efficient driving experience and traffic services.

而云端平台获取车联网数据的过程,是指前端传感器采集到的车辆信息,通过网络传输,传递到后端的云端平台的过程。The process of the cloud platform obtaining the Internet of Vehicles data refers to the process in which the vehicle information collected by the front-end sensors is transmitted through the network to the back-end cloud platform.

一般情况下,以上所述的车辆数量和传感器数量可能存在几千个,且在车辆行驶过程中,因此采集到的数据数量可能非常庞大,数据一起进入同一传输系统,由此可能会造成网络堵塞及其他并发问题,阻碍获取有效数据的高效性和稳定性。Under normal circumstances, the number of vehicles and sensors mentioned above may exist in the thousands, and during the driving process of the vehicle, the amount of collected data may be very large, and the data enters the same transmission system together, which may cause network congestion And other concurrency issues hinder the efficiency and stability of obtaining valid data.

发明内容Contents of the invention

本发明提出一种车联网数据的上收系统、方法、设备和介质,以解决现有技术中,大量车辆连接导致并发问题、且不能高效采集处理数据车联网数据的问题。The present invention proposes a system, method, device and medium for collecting data from the Internet of Vehicles, so as to solve the problems in the prior art that a large number of vehicle connections cause concurrency problems and cannot efficiently collect and process data from the Internet of Vehicles.

为达上述目的,本发明提出技术方案如下:For reaching above-mentioned purpose, the present invention proposes technical scheme as follows:

一种车联网数据的上收系统,包括负载均衡模块和数据处理模块;A system for collecting data from the Internet of Vehicles, including a load balancing module and a data processing module;

所述负载均衡模块,用于对来自车辆的数据进行处理,将数据的目标地址修改为基于第七层交换技术的负载均衡集群机器;所述基于第七层交换技术的负载均衡集群机器向数据处理模块发送数据;The load balancing module is used to process the data from the vehicle, and modify the target address of the data to a load balancing cluster machine based on the seventh layer switching technology; the load balancing cluster machine based on the seventh layer switching technology sends data to the The processing module sends data;

所述数据处理模块,用于接收来自基于第七层交换技术的负载均衡集群机器的数据,对数据根据类型进行筛选,并发送至对应的云端平台。The data processing module is used to receive the data from the load balancing cluster machine based on the seventh layer switching technology, filter the data according to the type, and send the data to the corresponding cloud platform.

优选的,负载均衡模块通过基于第四层交换技术的负载均衡机器将数据的目标地址修改为基于第七层交换技术的负载均衡集群机器。Preferably, the load balancing module modifies the target address of the data to a load balancing cluster machine based on layer 7 switching technology through the load balancing machine based on layer 4 switching technology.

优选的,所述基于第七层交换技术的负载均衡集群机器根据负载均衡规则将数据发往数据处理模块进行处理。Preferably, the load balancing cluster machine based on layer-7 switching technology sends data to the data processing module for processing according to load balancing rules.

优选的,所述负载均衡规则包括数据的发送优先级和目标地址。Preferably, the load balancing rule includes data sending priority and destination address.

优选的,数据处理模块接收到来自基于第七层交换技术的负载均衡集群机器的数据后,对数据进行登陆校验处理,对登录校验成功后的数据进行拆包粘包处理。Preferably, after the data processing module receives the data from the load balancing cluster machine based on the seventh-layer switching technology, it performs login verification processing on the data, and performs unpacking and sticking processing on the data after the login verification succeeds.

优选的,数据处理模块对数据进行登陆校验处理后,Preferably, after the data processing module performs login verification processing on the data,

将登陆校验错误的数据和60秒没有与车联网数据的上收系统进行交互连接的数据进行断开处理。Disconnect the data with login verification error and the data that has not been interactively connected with the Internet of Vehicles data collection system for 60 seconds.

优选的,对数据根据类型进行筛选后,通过消息队列将数据发送至对应类型的云端平台。Preferably, after filtering the data according to the type, the data is sent to the corresponding type of cloud platform through the message queue.

一种车联网数据的上收方法,包括如下步骤:A method for receiving Internet of Vehicles data, comprising the steps of:

步骤1,通过基于第四层交换技术的部署的负载均衡机器对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器;Step 1, process the data from the vehicle through the load balancing machine deployed based on the fourth layer switching technology, and modify the target address of the data to the seventh layer switching technology load balancing cluster machine;

步骤2,第七层交换技术负载均衡集群机器根据配置的负载均衡规则将登陆数据发往数据处理模块进行处理;Step 2, the seven-layer switching technology load balancing cluster machine sends the login data to the data processing module for processing according to the configured load balancing rules;

步骤3,对数据进行登陆校验处理,对登录校验成功后的数据进入步骤4,将登陆校验错误的数据和60秒没有与本系统进行交互连接的数据进行断开处理;Step 3, perform login verification processing on the data, enter step 4 for the data after the login verification is successful, and disconnect the data of the login verification error and the data that has not been interactively connected with the system for 60 seconds;

步骤4,对数据进行拆包粘包处理;Step 4, unpacking and sticking the data;

步骤5,将拆包粘包处理后的数据根据类型进行筛选,之后通过消息队列发送至对应的云端平台。Step 5: Filter the data processed by unpacking and sticking according to the type, and then send it to the corresponding cloud platform through the message queue.

一种车联网数据的上收电子设备,包括存储器,用于存储计算机程序;An electronic device for uploading and receiving data of the Internet of Vehicles, including a memory for storing computer programs;

处理器,用于执行所述计算机程序,所述计算机程序被处理器执行时实现一种车联网数据的上收方法的步骤。The processor is configured to execute the computer program, and when the computer program is executed by the processor, the steps of a method for uploading the Internet of Vehicles data are realized.

一种车联网数据的上收介质,所述计算机程序被处理器执行时实现一种车联网数据的上收方法的步骤。本发明的有益之处在于:A medium for uploading Internet of Vehicles data, when the computer program is executed by a processor, steps in a method for uploading Internet of Vehicles data are realized. The benefits of the present invention are:

本发明提供一种车联网数据的上收系统,其中负载均衡模块对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器;所述数据处理模块接收到数据,对数据根据类型进行筛选并发送至对应的云端平台;本发明通过第四层交换技术的负载均衡和基于第七层交换技术的负载均衡接收和发出数据,解决了大量车辆连接的并发问题。The present invention provides a system for receiving data from the Internet of Vehicles, wherein the load balancing module processes the data from the vehicle, and modifies the target address of the data to a seventh-layer switching technology load balancing cluster machine; the data processing module receives the data , screen the data according to the type and send it to the corresponding cloud platform; the present invention receives and sends data through the load balancing of the fourth layer switching technology and the load balancing based on the seventh layer switching technology, and solves the concurrency problem of a large number of vehicle connections.

本发明通过数据处理模块配合负载均衡模块的系统传输,对数据进行进一步的分类处理,已发送至对应模块,实现高效传输。In the present invention, through the system transmission of the data processing module and the load balancing module, the data is further classified and processed, and the data is sent to the corresponding module to realize efficient transmission.

在数据分类之前,进行登录校验和拆包粘包处理,维护数据,提升操作的流畅性和系统的安全性。Before data classification, login verification and unpacking and sticking processing are performed to maintain data and improve operational fluency and system security.

附图说明Description of drawings

构成本发明的一部分的说明书附图用来提供对本发明的进一步理解,本发明的示意性实施例及其说明用于解释本发明,并不构成对本发明的不当限定。在附图中:The accompanying drawings constituting a part of the present invention are used to provide a further understanding of the present invention, and the schematic embodiments of the present invention and their descriptions are used to explain the present invention and do not constitute improper limitations to the present invention. In the attached picture:

图1为一种车联网数据的上收系统示意图;FIG. 1 is a schematic diagram of a system for receiving data from the Internet of Vehicles;

图2为一种车联网数据的上收方法示意图;Fig. 2 is a schematic diagram of a method for uploading data of the Internet of Vehicles;

图3为一种车联网数据的上收电子设备示意图。Fig. 3 is a schematic diagram of an electronic device for uploading and receiving Internet of Vehicles data.

具体实施方式Detailed ways

下面将参考附图并结合实施例来详细说明本发明。需要说明的是,在不冲突的情况下,本发明中的实施例及实施例中的特征可以相互组合。The present invention will be described in detail below with reference to the accompanying drawings and examples. It should be noted that, in the case of no conflict, the embodiments of the present invention and the features in the embodiments can be combined with each other.

以下详细说明均是示例性的说明,旨在对本发明提供进一步的详细说明。除非另有指明,本发明所采用的所有技术术语与本发明所属领域的一般技术人员的通常理解的含义相同。本发明所使用的术语仅是为了描述具体实施方式,而并非意图限制根据本发明的示例性实施方式。The following detailed descriptions are all exemplary descriptions, and are intended to provide further detailed descriptions of the present invention. Unless otherwise specified, all technical terms used in the present invention have the same meaning as commonly understood by those of ordinary skill in the art to which the present invention belongs. Terms used in the present invention are only for describing specific embodiments, and are not intended to limit exemplary embodiments according to the present invention.

实施例1:Example 1:

请参阅图1所示,本发明提供一种车联网数据的上收系统,包括负载均衡模块和数据处理模块。Please refer to FIG. 1 , the present invention provides a system for receiving data from the Internet of Vehicles, including a load balancing module and a data processing module.

所述负载均衡模块用于通过基于第四层交换技术的部署的负载均衡机器,对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器;所述第七层交换技术负载均衡集群机器会根据配置的负载均衡规则将登陆数据发往数据处理模块进行处理;所述负载均衡规则包括数据的权重、优先级和地址等信息。The load balancing module is used to process the data from the vehicle through the load balancing machine deployed based on the fourth layer switching technology, and modify the target address of the data to the seventh layer switching technology load balancing cluster machine; the seventh Layer switching technology load balancing cluster machine will send the login data to the data processing module for processing according to the configured load balancing rules; the load balancing rules include information such as data weight, priority and address.

所述数据处理模块接收到来自第七层交换技术负载均衡集群机器的数据之后,对数据进行登陆校验处理,对登录校验成功后的数据进行拆包粘包处理,将登陆校验错误的数据和60秒没有与本系统进行交互连接的数据进行断开处理。After the data processing module receives the data from the seventh-layer switching technology load balancing cluster machine, it performs login verification processing on the data, unpacks and sticks the data after the login verification succeeds, and unpacks and sticks the data after the login verification error. Data and data that have not been interactively connected to the system for 60 seconds are disconnected.

将拆包粘包处理后的数据根据类型进行筛选,之后通过消息队列发送至对应的云端平台。The data processed by unpacking and sticking is screened according to the type, and then sent to the corresponding cloud platform through the message queue.

实施例2:Example 2:

如图2所示,本发明提供一种车联网数据的上收方法,具体包括:As shown in FIG. 2, the present invention provides a method for receiving data from the Internet of Vehicles, which specifically includes:

步骤1,通过基于第四层交换技术的部署的负载均衡机器对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器。Step 1, process the data from the vehicle through the load balancing machine deployed based on the fourth layer switching technology, and modify the target address of the data to the seventh layer switching technology load balancing cluster machine.

步骤2,第七层交换技术负载均衡集群机器根据配置的负载均衡规则将登陆数据发往数据处理模块进行处理;所述负载均衡规则包括数据的权重、优先级和地址等信息。Step 2, the layer-7 switching technology load balancing cluster machine sends the login data to the data processing module for processing according to the configured load balancing rules; the load balancing rules include information such as data weight, priority and address.

步骤3,对数据进行登陆校验处理,对登录校验成功后的数据进入步骤4,将登陆校验错误的数据和60秒没有与本系统进行交互连接的数据进行断开处理。Step 3, perform login verification processing on the data, and proceed to step 4 for the data after the login verification is successful, and disconnect the data with the login verification error and the data that has not been interactively connected with the system for 60 seconds.

步骤4,对数据进行拆包粘包处理。Step 4, unpacking and sticking the data.

步骤5,将拆包粘包处理后的数据根据类型进行筛选,之后通过消息队列发送至对应的云端平台。Step 5: Filter the data processed by unpacking and sticking according to the type, and then send it to the corresponding cloud platform through the message queue.

实施例3:Example 3:

如图3所示,本发明提供一种车联网数据的上收电子设备100,所述电子设备100包括存储器101、至少一个处理器102、存储在所述存储器101中并可在所述至少一个处理器102上运行的计算机程序103及至少一条通讯总线104。As shown in FIG. 3 , the present invention provides an electronic device 100 for uploading Internet of Vehicles data. The electronic device 100 includes a memory 101, at least one processor 102, is stored in the memory 101 and can be used in the at least one A computer program 103 running on the processor 102 and at least one communication bus 104 .

存储器101可用于存储所述计算机程序103,所述处理器102通过运行或执行存储在所述存储器101内的计算机程序,以及调用存储在存储器101内的数据,实现实施例1所述的获取停车场空位的方法的步骤。所述存储器101可主要包括存储程序区和存储数据区,其中,存储程序区可存储操作系统、至少一个功能所需的应用程序(比如声音播放功能、图像播放功能等)等;存储数据区可存储根据电子设备100的使用所创建的数据(比如音频数据)等。此外,存储器101可以包括非易失性存储器,例如硬盘、内存、插接式硬盘,智能存储卡(Smart Media Card,SMC),安全数字(Secure Digital,SD)卡,闪存卡(Flash Card)、至少一个磁盘存储器件、闪存器件、或其他非易失性固态存储器件。The memory 101 can be used to store the computer program 103, and the processor 102 realizes the acquisition of the parking lot described in Embodiment 1 by running or executing the computer program stored in the memory 101 and calling the data stored in the memory 101. The steps of the field vacancy method. The memory 101 can mainly include a program storage area and a data storage area, wherein the program storage area can store an operating system, at least one application program required by a function (such as a sound playback function, an image playback function, etc.); Data created according to use of the electronic device 100 such as audio data and the like are stored. In addition, the memory 101 may include non-volatile memory, such as hard disk, internal memory, plug-in hard disk, smart memory card (Smart Media Card, SMC), secure digital (Secure Digital, SD) card, flash memory card (Flash Card), At least one disk storage device, flash memory device, or other non-volatile solid-state storage device.

所述至少一个处理器102可以是中央处理单元(Central Processing Unit,CPU),还可以是其他通用处理器、数字信号处理器(Digital Signal Processor,DSP)、专用集成电路(Application Specific Integrated Circuit,ASIC)、现场可编程门阵列(Field-Programmable Gate Array,FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。处理器102可以是微处理器或者该处理器102也可以是任何常规的处理器等,所述处理器102是所述电子设备100的控制中心,利用各种接口和线路连接整个电子设备100的各个部分。The at least one processor 102 can be a central processing unit (Central Processing Unit, CPU), and can also be other general-purpose processors, digital signal processors (Digital Signal Processor, DSP), application specific integrated circuits (Application Specific Integrated Circuit, ASIC ), Field-Programmable Gate Array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, etc. The processor 102 can be a microprocessor or the processor 102 can also be any conventional processor, etc., the processor 102 is the control center of the electronic device 100, using various interfaces and lines to connect the entire electronic device 100 various parts.

所述电子设备100中的所述存储器101存储多个指令以实现一种车联网数据的上收方法,所述处理器102可执行所述多个指令从而实现:The memory 101 in the electronic device 100 stores a plurality of instructions to implement a method for uploading Internet of Vehicles data, and the processor 102 can execute the plurality of instructions to implement:

步骤1,通过基于第四层交换技术的部署的负载均衡机器对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器。Step 1, process the data from the vehicle through the load balancing machine deployed based on the fourth layer switching technology, and modify the target address of the data to the seventh layer switching technology load balancing cluster machine.

步骤2,第七层交换技术负载均衡集群机器根据配置的负载均衡规则将登陆数据发往数据处理模块进行处理;所述负载均衡规则包括数据的权重、优先级和地址等信息。Step 2, the layer-7 switching technology load balancing cluster machine sends the login data to the data processing module for processing according to the configured load balancing rules; the load balancing rules include information such as data weight, priority and address.

步骤3,对数据进行登陆校验处理,对登录校验成功后的数据进入步骤4,将登陆校验错误的数据和60秒没有与本系统进行交互连接的数据进行断开处理。Step 3, perform login verification processing on the data, and proceed to step 4 for the data after the login verification is successful, and disconnect the data with the login verification error and the data that has not been interactively connected with the system for 60 seconds.

步骤4,对数据进行拆包粘包处理。Step 4, unpacking and sticking the data.

步骤5,将拆包粘包处理后的数据根据类型进行筛选,之后通过消息队列发送至对应的云端平台。Step 5: Filter the data processed by unpacking and sticking according to the type, and then send it to the corresponding cloud platform through the message queue.

实施例4:Example 4:

本发明提供一种车联网数据的上收介质,所述电子设备100集成的模块/单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本发明实现上述实施例方法中的全部或部分流程,也可以通过计算机程序来指令相关的硬件来完成,所述的计算机程序可存储于一计算机可读存储介质中,该计算机程序在被处理器执行时,可实现上述各个方法实施例的步骤。其中,所述计算机程序包括计算机程序代码,所述计算机程序代码可以为源代码形式、对象代码形式、可执行文件或某些中间形式等。所述计算机可读介质可以包括:能够携带所述计算机程序代码的任何实体或装置、记录介质、U盘、移动硬盘、磁碟、光盘、计算机存储器及只读存储器(ROM,Read-Only Memory)。The present invention provides a medium for uploading Internet of Vehicles data. If the integrated modules/units of the electronic device 100 are realized in the form of software function units and sold or used as independent products, they can be stored in a computer-readable memory medium. Based on this understanding, the present invention realizes all or part of the processes in the methods of the above embodiments, and can also be completed by instructing related hardware through a computer program. The computer program can be stored in a computer-readable storage medium, and the computer When the program is executed by the processor, the steps in the above-mentioned various method embodiments can be realized. Wherein, the computer program includes computer program code, and the computer program code may be in the form of source code, object code, executable file or some intermediate form. The computer-readable medium may include: any entity or device capable of carrying the computer program code, a recording medium, a USB flash drive, a removable hard disk, a magnetic disk, an optical disk, a computer memory, and a read-only memory (ROM, Read-Only Memory) .

本发明的负载均衡模块与数据处理模块分开,降低之间的耦合性,提高整个系统的健壮性和可维护性,并利用第七层交换技术可支持横向扩展的特性,实现在服务不停止情况实现负载均衡能力的提升。The load balancing module of the present invention is separated from the data processing module, which reduces the coupling between them, improves the robustness and maintainability of the entire system, and utilizes the characteristics of the seventh-layer switching technology to support horizontal expansion, and realizes that the service does not stop Improve load balancing capabilities.

负载均衡机器的主备机制通过Linux系统keepalived服务实现。The active/standby mechanism of the load balancing machine is implemented through the keepalived service of the Linux system.

数据处理模块基于Netty的TCP服务框架的逻辑设计,实现了车辆连接和数据预处理:长连接建立后,通过登陆功能和心跳机制,控制连接的建立和断开和对报文数据进行预处理(粘包和拆包处理),在之后进行进一步的数据处理:通过对数据的解析和筛选,将数据分发到云端平台的不同模块。Based on the logical design of Netty's TCP service framework, the data processing module realizes the vehicle connection and data preprocessing: after the long connection is established, it controls the establishment and disconnection of the connection and preprocesses the message data through the login function and the heartbeat mechanism ( sticky package and unpacking processing), and then further data processing: through data analysis and screening, the data is distributed to different modules of the cloud platform.

由技术常识可知,本发明可以通过其它的不脱离其精神实质或必要特征的实施方案来实现。因此,上述公开的实施方案,就各方面而言,都只是举例说明,并不是仅有的。所有在本发明范围内或在等同于本发明的范围内的改变均被本发明包含。It can be known from common technical knowledge that the present invention can be realized through other embodiments without departing from its spirit or essential features. Accordingly, the above-disclosed embodiments are, in all respects, illustrative and not exclusive. All changes within the scope of the present invention or within the scope equivalent to the present invention are embraced by the present invention.

本领域内的技术人员应明白,本发明的实施例可提供为方法、系统、或计算机程序产品。因此,本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。Those skilled in the art should understand that the embodiments of the present invention may be provided as methods, systems, or computer program products. Accordingly, the present invention can take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present invention may take the form of a computer program product embodied on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing equipment produce a An apparatus for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow chart or blocks of the flowchart and/or the block or blocks of the block diagrams.

最后应当说明的是:以上实施例仅用以说明本发明的技术方案而非对其限制,尽管参照上述实施例对本发明进行了详细的说明,所属领域的普通技术人员应当理解:依然可以对本发明的具体实施方式进行修改或者等同替换,而未脱离本发明精神和范围的任何修改或者等同替换,其均应涵盖在本发明的权利要求保护范围之内。Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention and not to limit them. Although the present invention has been described in detail with reference to the above embodiments, those of ordinary skill in the art should understand that: the present invention can still be Any modification or equivalent replacement that does not depart from the spirit and scope of the present invention shall fall within the protection scope of the claims of the present invention.

Claims (10)

1.一种车联网数据的上收系统,其特征在于,包括负载均衡模块和数据处理模块;1. A collection system for Internet of Vehicles data, characterized in that it includes a load balancing module and a data processing module; 所述负载均衡模块,用于对来自车辆的数据进行处理,将数据的目标地址修改为基于第七层交换技术的负载均衡集群机器;所述基于第七层交换技术的负载均衡集群机器向数据处理模块发送数据;The load balancing module is used to process the data from the vehicle, and modify the target address of the data to a load balancing cluster machine based on the seventh layer switching technology; the load balancing cluster machine based on the seventh layer switching technology sends data to the The processing module sends data; 所述数据处理模块,用于接收来自基于第七层交换技术的负载均衡集群机器的数据,对数据根据类型进行筛选,并发送至对应的云端平台。The data processing module is used to receive the data from the load balancing cluster machine based on the seventh layer switching technology, filter the data according to the type, and send the data to the corresponding cloud platform. 2.如权利要求1所述的一种车联网数据的上收系统,其特征在于,负载均衡模块通过基于第四层交换技术的负载均衡机器将数据的目标地址修改为基于第七层交换技术的负载均衡集群机器。2. A system for receiving data from the Internet of Vehicles as claimed in claim 1, wherein the load balancing module modifies the target address of the data to be based on the seventh layer switching technology through a load balancing machine based on the fourth layer switching technology. The load balancing cluster machines. 3.如权利要求1所述的一种车联网数据的上收系统,其特征在于,所述基于第七层交换技术的负载均衡集群机器根据负载均衡规则将数据发往数据处理模块进行处理。3. A system for receiving data from the Internet of Vehicles as claimed in claim 1, wherein the load balancing cluster machine based on Layer 7 switching technology sends data to the data processing module for processing according to load balancing rules. 4.如权利要求3所述的一种车联网数据的上收系统,其特征在于,所述负载均衡规则包括数据的发送优先级和目标地址。4. A system for sending and receiving Internet of Vehicles data according to claim 3, wherein the load balancing rule includes data sending priority and destination address. 5.如权利要求1所述的一种车联网数据的上收系统,其特征在于,数据处理模块接收到来自基于第七层交换技术的负载均衡集群机器的数据后,对数据进行登陆校验处理,对登录校验成功后的数据进行拆包粘包处理。5. A system for receiving data from the Internet of Vehicles as claimed in claim 1, wherein the data processing module performs login check on the data after receiving the data from the load balancing cluster machine based on the seventh-layer switching technology Processing, unpack and paste the data after the login verification is successful. 6.如权利要求5所述的一种车联网数据的上收系统,其特征在于,数据处理模块对数据进行登陆校验处理后,6. A system for receiving data from the Internet of Vehicles as claimed in claim 5, characterized in that, after the data processing module performs login verification processing on the data, 将登陆校验错误的数据和60秒没有与车联网数据的上收系统进行交互连接的数据进行断开处理。Disconnect the data with login verification error and the data that has not been interactively connected with the Internet of Vehicles data collection system for 60 seconds. 7.如权利要求1所述的一种车联网数据的上收系统,其特征在于,对数据根据类型进行筛选后,通过消息队列将数据发送至对应类型的云端平台。7. A system for uploading and receiving Internet of Vehicles data according to claim 1, characterized in that, after the data is screened according to the type, the data is sent to the cloud platform of the corresponding type through the message queue. 8.一种车联网数据的上收方法,其特征在于,包括如下步骤:8. A method for receiving data from the Internet of Vehicles, comprising the steps of: 步骤1,通过基于第四层交换技术的部署的负载均衡机器对来自车辆的数据进行处理,将数据的目标地址修改为第七层交换技术负载均衡集群机器;Step 1, process the data from the vehicle through the load balancing machine deployed based on the fourth layer switching technology, and modify the target address of the data to the seventh layer switching technology load balancing cluster machine; 步骤2,第七层交换技术负载均衡集群机器根据配置的负载均衡规则将登陆数据发往数据处理模块进行处理;Step 2, the seven-layer switching technology load balancing cluster machine sends the login data to the data processing module for processing according to the configured load balancing rules; 步骤3,对数据进行登陆校验处理,对登录校验成功后的数据进入步骤4,将登陆校验错误的数据和60秒没有与本系统进行交互连接的数据进行断开处理;Step 3, perform login verification processing on the data, enter step 4 for the data after the login verification is successful, and disconnect the data of the login verification error and the data that has not been interactively connected with the system for 60 seconds; 步骤4,对数据进行拆包粘包处理;Step 4, unpacking and sticking the data; 步骤5,将拆包粘包处理后的数据根据类型进行筛选,之后通过消息队列发送至对应的云端平台。Step 5: Filter the data processed by unpacking and sticking according to the type, and then send it to the corresponding cloud platform through the message queue. 9.一种车联网数据的上收电子设备,其特征在于,包括存储器(101),用于存储计算机程序;9. An electronic device for uploading and receiving Internet of Vehicles data, characterized in that it includes a memory (101) for storing computer programs; 处理器(102),用于执行所述计算机程序,所述计算机程序被处理器执行时实现如权利要求7所述的一种车联网数据的上收方法的步骤。The processor (102) is configured to execute the computer program, and when the computer program is executed by the processor, the steps of the method for receiving Internet of Vehicles data according to claim 7 are implemented. 10.一种车联网数据的上收介质,其特征在于,所述计算机程序被处理器执行时实现如权利要求7所述的一种车联网数据的上收方法的步骤。10. A medium for uploading Internet of Vehicles data, characterized in that, when the computer program is executed by a processor, the steps of the method for uploading Internet of Vehicles data according to claim 7 are implemented.
CN202310618590.3A 2023-05-26 2023-05-26 Internet of vehicles data uploading and receiving system, method, equipment and medium Pending CN116567035A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202310618590.3A CN116567035A (en) 2023-05-26 2023-05-26 Internet of vehicles data uploading and receiving system, method, equipment and medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202310618590.3A CN116567035A (en) 2023-05-26 2023-05-26 Internet of vehicles data uploading and receiving system, method, equipment and medium

Publications (1)

Publication Number Publication Date
CN116567035A true CN116567035A (en) 2023-08-08

Family

ID=87501790

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202310618590.3A Pending CN116567035A (en) 2023-05-26 2023-05-26 Internet of vehicles data uploading and receiving system, method, equipment and medium

Country Status (1)

Country Link
CN (1) CN116567035A (en)

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103023797A (en) * 2011-09-23 2013-04-03 百度在线网络技术(北京)有限公司 Data center system and device and method for providing service
CN112839081A (en) * 2020-12-31 2021-05-25 深圳市赛宇景观设计工程有限公司 Load balancing method of cloud cluster
US20230033272A1 (en) * 2020-04-14 2023-02-02 Samsung Electronics Co., Ltd. Method and apparatus for dynamic and efficient load balancing in mobile communication network

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103023797A (en) * 2011-09-23 2013-04-03 百度在线网络技术(北京)有限公司 Data center system and device and method for providing service
US20230033272A1 (en) * 2020-04-14 2023-02-02 Samsung Electronics Co., Ltd. Method and apparatus for dynamic and efficient load balancing in mobile communication network
CN112839081A (en) * 2020-12-31 2021-05-25 深圳市赛宇景观设计工程有限公司 Load balancing method of cloud cluster

Similar Documents

Publication Publication Date Title
CN112183395A (en) Road scene recognition method and system based on multi-task learning neural network
WO2018148931A1 (en) Map drawing method, and cloud platform and server therefor
CN112182289B (en) Data deduplication method and device based on Flink frame
CN113497955B (en) Video processing system
CN109636304B (en) Method and device for publishing business system, storage medium, and electronic device
CN111105054A (en) System and method for authenticating ride-sharing requests
CN111462515A (en) Vehicle-road cooperative management method, MEC server, terminal and system
JP2018170719A (en) Information processing apparatus, information processing method, and program
CN105847231A (en) Service publishing method, device and system
CN110087041B (en) Video data processing and transmitting method and system based on 5G base station
CN105513360B (en) A kind of method and device of vehicle data processing
CN116567035A (en) Internet of vehicles data uploading and receiving system, method, equipment and medium
CN108305476A (en) A kind of method, system and ambulance obtaining illegal vehicle information
CN116248836A (en) A video transmission method, device and medium for remote driving
CN111696368A (en) Overspeed illegal data generation method and illegal server
CN115294775A (en) Emergency vehicle permission obtaining method, device, equipment and storage medium
CN115514633A (en) API gateway dynamic configuration method, device, and electronic equipment
CN112052780A (en) Face verification method, device and system and storage medium
CN104407920B (en) A kind of data processing method and system based on interprocess communication
CN115129605B (en) A data closed-loop automated testing method, device, electronic device, and storage medium
CN114842435B (en) A method, device, electronic device and storage medium for determining a target vehicle
CN117193253A (en) Real-time online fault monitoring method and related system
CN117831000A (en) Traffic light detection method and device, electronic equipment and storage medium
CN116152763A (en) A method and system for image desensitization and image data cleaning based on intelligent driving
KR102342811B1 (en) Parking lot management device and method to provide discount of parking fees for playing or performing cultural content

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