CN119583473B

CN119583473B - Industrial message processing methods, devices, and storage media for C2F scenarios

Info

Publication number: CN119583473B
Application number: CN202510118612.9A
Authority: CN
Inventors: 刘超; 王卓耀; 徐光侠; 周瀚; 钟国祥; 徐恒梅
Original assignee: Peng Cheng Laboratory
Current assignee: Peng Cheng Laboratory
Filing date: 2025-01-24
Publication date: 2026-03-24
Anticipated expiration: 2045-01-24

Abstract

The embodiment of the application provides an industrial message processing method, device and storage medium oriented to a C2F scene, and belongs to the technical field of industrial message processing. The method comprises the steps of obtaining an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, determining multi-layer transmission priority information of the initial industrial message, adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain a target industrial message, and sending the target industrial message to an arbitrator, wherein the arbitrator is used for determining transmission sequences of a plurality of target industrial messages based on the multi-layer transmission priority information, and sending the target industrial message to a corresponding target transmission pipeline according to the transmission sequences so as to transmit the target industrial message to a corresponding receiving end in the target transmission pipeline based on the corresponding industrial communication protocol. The application can improve the real-time property of industrial message transmission in the Ethernet.

Description

Industrial message processing method and device oriented to C2F scene and storage medium

Technical Field

The present application relates to the field of industrial message processing technologies, and in particular, to a method and an apparatus for processing an industrial message in a C2F scene, and a storage medium.

Background

With the continuous development of the internet, the conventional control system cannot meet the interaction requirement between the user and the industrial platform, so that an electronic commerce mode (Customer to Factory, C2F) from a consumer to a factory is gradually developed, the C2F mode enables a terminal client to directly interact with an industrial system related to a manufacturing enterprise, so that the personalized interaction requirement of the user is greatly met, and the C2F scene requires the industrial system to rely on the ethernet for communication.

In the related art, the transmission requirement of the industrial message transmitted by the industrial equipment on the channel is high, so that the industrial message can only be transmitted through the local area network currently. When industrial equipment under different protocols communicate through the Ethernet, because the industrial equipment in the industrial system is more in quantity, the different industrial equipment corresponds to different industrial communication protocols, so that the Ethernet is difficult to process industrial messages from the different industrial equipment efficiently, and the real-time performance of industrial message transmission is reduced.

Disclosure of Invention

The embodiment of the application mainly aims to provide an industrial message processing method, an industrial message processing device and a storage medium for a C2F scene, which can improve the real-time performance of industrial message transmission in the Ethernet.

To achieve the above objective, a first aspect of an embodiment of the present application provides an industrial message processing method in a C2F-oriented scenario, applied to a transmitting end, including:

Acquiring an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message;

Determining multi-layer transmission priority information of an initial industrial message, and adjusting the initial industrial message based on the transmission priority information and an industrial communication protocol to obtain a target industrial message;

Sending the target industrial message to an arbiter;

The arbiter is used for selecting a target transmission path from a plurality of candidate transmission paths in turn according to transmission priority information of different levels for target industrial messages from different sending ends, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path; determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines;

the receiving end is used for receiving the target industrial message from the arbiter, analyzing the target industrial message to obtain an initial industrial message, and processing the initial industrial message.

In some embodiments, determining transmission priority information for multiple layers of an initial industrial message includes:

Configuring first priority information based on the attribute of the initial industrial message on the path, configuring second priority information based on the attribute of the initial industrial message on the pipeline, and configuring third priority information based on the version to which the initial industrial message belongs;

and splicing the first priority information, the second priority information and the third priority information to obtain multi-level transmission priority information, so that the arbiter sequentially analyzes and processes the target industrial message according to the sequence of the first priority information, the second priority information and the third priority information.

In some embodiments, adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message includes:

Adding the transmission priority information and the industrial communication protocol into an initial industrial message to obtain an adjusted initial industrial message;

And configuring Gray code delimiters for the transmission priority information, and adding the Gray code delimiters to positions corresponding to the transmission priority information in the adjusted initial industrial message to obtain the target industrial message.

In some embodiments, adding the gray code delimiter to the adjusted position corresponding to the transmission priority information in the initial industrial message to obtain the target industrial message includes:

sequentially taking the industrial communication protocol, the Gray code delimiter and the transmission priority information as the message header of the adjusted initial industrial message;

And carrying out message encapsulation according to the industrial communication protocol, the Gray code delimiter, the transmission priority information and the sequence of the adjusted initial industrial message to obtain the target industrial message.

To achieve the above objective, a second aspect of the embodiments of the present application provides an industrial message processing method in a C2F-oriented scenario, which is applied to an arbiter, and includes:

Receiving target industrial messages sent by different sending terminals, wherein the target industrial messages are obtained by the sending terminals after obtaining initial industrial messages to be transmitted and industrial communication protocols corresponding to the initial industrial messages, determining multi-layer transmission priority information of the initial industrial messages, and adjusting the initial industrial messages based on the transmission priority information and the industrial communication protocols;

extracting corresponding transmission priority information from each target industrial message respectively;

for each target industrial message, based on transmission priority information of different levels, sequentially selecting a target transmission path from a plurality of candidate transmission paths, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path;

Determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines;

In some embodiments, the transmission priority information includes first priority information, second priority information, and third priority information of different levels;

selecting a target transmission path among a plurality of candidate transmission paths, and selecting a target transmission pipe among a plurality of candidate transmission pipes under the target transmission path, comprising:

If the first priority information is smaller than a preset time sequence threshold value, selecting a target transmission path from a plurality of candidate transmission paths according to the value of the first priority information, wherein the transmission speeds of different candidate transmission paths are different;

And selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path according to the value of the second priority information, wherein the transmission speeds of different candidate transmission pipelines are different.

In some embodiments, sending the target industrial message to the corresponding target transmission pipeline in the transmission order includes:

And combining the target industrial messages with the same third priority information aiming at a plurality of target industrial messages belonging to the same target transmission path and the same target transmission pipeline.

In some embodiments, for each target industrial message, selecting a target transmission path among a plurality of candidate transmission paths in turn based on transmission priority information of different levels, and then selecting a target transmission pipe among a plurality of candidate transmission pipes under the target transmission path, includes:

selecting target industrial messages meeting preset conditions from a plurality of target industrial messages according to the numerical value of the multi-level transmission priority information;

And selecting a target transmission path from a plurality of candidate transmission paths in turn according to transmission priority information of different levels for each selected target industrial message, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path.

In some embodiments, selecting a target industrial message satisfying a preset condition from a plurality of target industrial messages according to a numerical value of the multi-level transmission priority information includes:

If the total number of the target industrial messages transmitted under the current round exceeds a preset transmission threshold value, correcting the transmission priority information based on at least one of the first condition, the second condition and the third condition to obtain the target industrial messages with the changed transmission priority information;

The first condition is that the first priority information is matched with a preset first interval value, the second condition is that the second priority information is matched with a preset second interval value, and the third condition is that the third priority information is matched with a preset third interval value.

In some embodiments, the target industrial message includes a gray code delimiter for delimiter identification;

extracting corresponding transmission priority information from each target industrial message respectively, wherein the method comprises the following steps:

locating Gray code delimiters from the target industrial message, and determining starting positions for representing transmission priority information based on the Gray code delimiters;

Based on the start position, transmission priority information is extracted.

To achieve the above objective, a third aspect of the embodiments of the present application provides an industrial message processing method in a C2F-oriented scenario, which is applied to a receiving end, and includes:

Receiving a target industrial message sent by an arbiter;

The method comprises the steps that a target industrial message is obtained by determining multi-layer transmission priority information of an initial industrial message after a sending end obtains the initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol;

and analyzing the target industrial message to obtain an initial industrial message, and processing the initial industrial message.

In some embodiments, processing the initial industrial message includes:

Analyzing the target industrial message to obtain verification information;

and verifying the initial industrial message based on the verification information, and processing the initial industrial message when the verification is passed.

In order to achieve the above object, a fourth aspect of the present application provides an industrial message processing apparatus in a C2F-oriented scenario, which is applied to a transmitting end, and includes:

The acquisition module is used for acquiring an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message;

The adjusting module is used for determining the multi-level transmission priority information of the initial industrial message and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain a target industrial message;

The system comprises a first sending module, an arbiter, a plurality of target industrial messages, a plurality of initial industrial messages, a plurality of target industrial message receiving modules, a plurality of target industrial messages, a plurality of target industrial message receiving modules and a plurality of receiving modules, wherein the first sending module is used for sending the target industrial messages to the arbiter, the arbiter is used for sequentially selecting a target transmission path among a plurality of candidate transmission paths based on transmission priority information of different levels for the target industrial messages from different sending ends, then selecting a target transmission pipeline among a plurality of candidate transmission pipelines under the target transmission path, determining the transmission sequence of the plurality of target industrial messages based on the transmission priority information of the multiple levels, sending the target industrial messages to the corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to the corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines, and the receiving ends are used for analyzing the target industrial messages from the arbiter to obtain initial industrial messages and processing the initial industrial messages.

To achieve the above object, a fifth aspect of the embodiments of the present application provides an industrial message processing apparatus in a C2F-oriented scenario, which is applied to an arbiter terminal, and includes:

The first receiving module is used for receiving target industrial messages sent by different sending terminals, wherein the target industrial messages are obtained by the sending terminal after acquiring initial industrial messages to be transmitted and industrial communication protocols corresponding to the initial industrial messages, determining multi-layer transmission priority information of the initial industrial messages and adjusting the initial industrial messages based on the transmission priority information and the industrial communication protocols;

the extraction module is used for extracting corresponding transmission priority information from each target industrial message respectively;

The arbitration processing module is used for selecting a target transmission path from a plurality of candidate transmission paths in turn according to transmission priority information of different levels for each target industrial message, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path;

the second sending module is used for determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines, wherein the receiving ends are used for analyzing the target industrial messages from the arbitrator to obtain initial industrial messages and processing the initial industrial messages.

To achieve the above object, a sixth aspect of the present application provides an industrial message processing apparatus in a C2F-oriented scenario, which is applied to a receiving end, and includes:

The system comprises a first receiving module, a second receiving module, an arbiter and a plurality of candidate transmission paths, wherein the first receiving module is used for receiving target industrial messages sent by the arbiter, the target industrial messages are obtained by the arbiter after a sending end obtains initial industrial messages to be transmitted and industrial communication protocols corresponding to the initial industrial messages, multi-level transmission priority information of the initial industrial messages is determined, the initial industrial messages are regulated based on the transmission priority information and the industrial communication protocols, the arbiter is used for sequentially selecting target transmission paths from a plurality of candidate transmission paths based on the transmission priority information of different levels for the target industrial messages from different sending ends, and then selecting target transmission pipelines from a plurality of candidate transmission pipelines under the target transmission paths;

and the receiving and processing module is used for analyzing the target industrial message to obtain an initial industrial message and processing the initial industrial message.

To achieve the above object, a seventh aspect of the embodiments of the present application proposes an electronic device, including a memory and a processor, the memory storing a computer program, the processor implementing the method of the first aspect, the method of the second aspect, or the method of the third aspect when executing the computer program.

To achieve the above object, an eighth aspect of the embodiments of the present application provides a computer readable storage medium, where a computer program is stored, where the computer program when executed by a processor implements the industrial message processing method in the C2F-oriented scene of the first aspect, the industrial message processing method in the C2F-oriented scene of the second aspect, or the industrial message processing method in the C2F-oriented scene of the third aspect.

The application provides an industrial message processing method and device, electronic equipment and storage medium for a C2F scene, the method comprises the steps of obtaining initial industrial messages to be transmitted and industrial communication protocols corresponding to the initial industrial messages, determining multi-level transmission priority information of the initial industrial messages, adjusting the initial industrial messages based on the transmission priority information and the industrial communication protocols to obtain target industrial messages, sending the target industrial messages to an arbitrator, wherein the arbitrator is used for sequentially selecting target transmission paths from a plurality of candidate transmission paths for the target industrial messages from different sending ends based on the transmission priority information of different levels, then selecting target transmission pipelines from a plurality of candidate transmission pipelines under the target transmission paths, determining the transmission sequence of the target industrial messages based on the transmission priority information of multiple levels, sending the target industrial messages to the corresponding target transmission pipelines according to the transmission sequence, so as to obtain target industrial messages from the corresponding industrial transmission pipelines to the corresponding industrial communication protocols from the initial industrial message receiving end to the industrial message receiving end, and analyzing the target industrial messages from the initial industrial message receiving end. The application can improve the real-time property of industrial message transmission in the Ethernet.

Drawings

Fig. 1 is a schematic diagram of an application scenario of an industrial message processing device in a C2F-oriented scenario provided in an embodiment of the present application;

FIG. 2 is an optional flowchart of an industrial message processing method in a C2F-oriented scenario provided in an embodiment of the present application;

FIG. 3 is another alternative flow chart of an industrial message processing method in a C2F-oriented scenario provided by an embodiment of the present application;

FIG. 4 is a flowchart of another alternative method for processing industrial messages in a C2F-oriented scenario provided by an embodiment of the present application;

FIG. 5 is a schematic diagram of an alternative module of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application;

FIG. 6 is a schematic diagram of another alternative module of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application;

FIG. 7 is a schematic diagram of another alternative module of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application;

fig. 8 is a schematic diagram of a hardware structure of an electronic device according to an embodiment of the present application.

Detailed Description

The present application will be described in further detail with reference to the drawings and examples, in order to make the objects, technical solutions and advantages of the present application more apparent. It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the application.

It should be noted that although functional block division is performed in a device diagram and a logic sequence is shown in a flowchart, in some cases, the steps shown or described may be performed in a different order than the block division in the device, or in the flowchart. The terms first, second and the like in the description and in the claims and in the above-described figures, are used for distinguishing between similar elements and not necessarily for describing a particular sequential or chronological order.

Unless defined otherwise, all technical and scientific terms used herein have the same meaning as commonly understood by one of ordinary skill in the art to which this application belongs. The terminology used herein is for the purpose of describing embodiments of the application only and is not intended to be limiting of the application.

First, the relative terms appearing herein will be explained.

The e-commerce mode refers to that advanced information technology and communication technology are utilized to enable terminal clients to directly interact with manufacturing enterprises, so that rapid delivery of personalized customized products and services is realized. In this mode, customers can submit specific product requirements, specifications or designs through the online platform, and manufacturing enterprises flexibly adjust the production line according to the information so as to meet unique requirements of the customers.

With the continuous development of the internet, the conventional control system cannot meet the interaction requirement between the user and the industrial platform, so that the electronic commerce mode from the consumer to the factory is gradually raised, the C2F mode enables the terminal client to directly interact with the industrial system related to the manufacturing enterprise, so that the personalized interaction requirement of the user is greatly met, and the C2F scene requires the industrial system to rely on the Ethernet for communication.

Among them, as industrial systems continue to expand with development of industrial technologies, the limitation of the industrial systems to cover smaller local area networks has not been able to meet the message transmission requirements of the new industrial systems. With the development of the internet, an industrial system needs to monitor and manage a plurality of industrial devices with a wider distribution range by means of the internet, and compared with the traditional local area network for transmitting industrial messages, the ethernet coverage is larger, supports almost all popular network protocols, and can be conveniently connected to the internet, so that the industrial system can be well assisted in upgrading by transmitting related industrial messages through the ethernet. However, the increase of the message transceiving range causes that the related technology cannot determine the processing priority sequence of a large number of industrial messages in time, so that the real-time performance of industrial message transmission is reduced.

Based on the above, the embodiment of the application provides an industrial message processing method, an industrial message processing device and a storage medium for a C2F scene, which can improve the real-time performance of industrial message transmission in the Ethernet.

As shown in fig. 1, fig. 1 is a schematic view of an application scenario of an industrial message processing device in a C2F-oriented scenario provided by an embodiment of the present application, and it should be noted that, for convenience of description, the industrial message processing device in a C2F-oriented scenario applied to a transmitting end may be hereinafter referred to as a "transmitting end device", the industrial message processing device in a C2F-oriented scenario applied to an arbitrator end may be referred to as an "arbitrator device", and the industrial message processing device in a C2F-oriented scenario applied to a receiving end may be referred to as a "receiving end device". In an optional application scenario, a client 11 (transmitting end), an ethernet and a terminal 12 (receiving end) are involved, where the number of clients 11 is multiple, the transmitting end device proposed by the embodiment of the present application is provided in the client 11, the ethernet includes the arbiter device proposed by the embodiment of the present application, and the receiving end is provided with the receiving end device proposed by the embodiment of the present application.

Further, after acquiring an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, a transmitting end device in the client 11 determines multi-layer transmission priority information of the initial industrial message, adjusts the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain a target industrial message, then sends the target industrial message to a switching device (such as an arbitrator) between the transmitting end and the receiving end, and an arbitrator device arranged in the arbitrator can perform priority judgment on different protocol messages from different transmitting ends and sequentially sends the target industrial message to corresponding receiving ends according to the determined priority sequence of each target industrial message, so that each receiving end can timely receive and process the required target industrial message. Therefore, industrial messages of different industrial devices can be transmitted in the same Ethernet, so that industrial message transmission, especially industrial message transmission instantaneity under different protocols, is improved.

It should be noted that, in the embodiment of the present application, when information related to user characteristics, such as user basic information or user identity, is involved, permission or consent of the user is obtained first, and the collection, use, processing, etc. of these data obeys relevant laws and regulations and standards. In addition, when the embodiment of the application needs to acquire the sensitive personal information of the user, the embodiment of the application firstly acquires the independent permission or independent consent of the user, and then acquires the necessary data for enabling the embodiment of the application to normally operate after the independent permission or independent consent of the user is definitely acquired, for example, when the embodiment of the application acquires the initial industrial message, the embodiment of the application firstly acquires the authorization or consent of related personnel at the sending end of the management message, otherwise, acquires the initial industrial message which cannot be applied to the embodiment of the application. In addition, other related data acquired by the method are all authorized data, and are not described in detail herein.

In the embodiment of the present application, description will be made from the dimension of a transmitting-end apparatus, which may be integrated in a computer device, such as a server of a client. As shown in fig. 2, fig. 2 is an optional flowchart of an industrial message processing method in a C2F-oriented scenario provided by the embodiment of the present application, where the method in fig. 2 may include, but is not limited to, the following steps 101 to 103, and when the transmitting end device executes the industrial message processing method in the C2F-oriented scenario deployed at the transmitting end, the specific flow is as follows, and it should be noted first that, in this embodiment, the order of steps 101 to 103 in fig. 2 is not limited specifically, and the order of steps may be adjusted or some steps may be reduced or added according to actual needs.

Step 101, acquiring an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message.

Step 101 is described in detail below.

In some embodiments, the enterprise system in which clients interact directly in the C2F mode is typically an industrial system. Industrial systems refer to complex systems consisting of a plurality of different industrial devices for carrying out industrial tasks of production, manufacturing, monitoring and control. Because each industrial device needs to realize real-time control according to the received instruction in the process of executing the task so as to ensure that the high-precision cooperative work among a plurality of industrial devices can be realized, an industrial system needs to reasonably manage and schedule messages bearing different importance and emergency degrees, thereby improving the execution efficiency, safety and reliability of the industrial system.

Where the initial industrial message is from any one of the industrial devices of the industrial system, in which the initial industrial message refers to raw data or instructions generated from the industrial device for communication between the different industrial devices. The industrial equipment can be a sensor, a lathe, a motor, a controller, an actuator and the like, namely the industrial equipment is a transmitting end, and the industrial equipment is in communication connection with the arbiter.

The industrial communication protocol specifies standards or specifications of the contents of the format, the transmission mode, the error detection mechanism and the like of the initial industrial message to be transmitted. Because the technical fields related to different industrial devices are usually different, and the technical fields have great differences, different industrial communication protocols are required to be used for data exchange and communication. For example, some industrial devices may employ serial communication protocols, while some industrial devices employ parallel communication protocols or network communication protocols.

Step 102, determining multi-level transmission priority information of the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message.

Step 102 is described in detail below.

In some embodiments, in order to solve the problems of network congestion and delay increase caused when messages of different protocols are transmitted through an ethernet, the embodiments of the present application further acquire multi-layer transmission priority information of an initial industrial message under the condition of acquiring the initial industrial message and a corresponding industrial communication protocol. The multi-level transmission priority information comprises a plurality of transmission priority information with different priority levels, and the message is subjected to higher-granularity priority division. Furthermore, the embodiment of the application can adjust the initial industrial message by utilizing the obtained industrial communication protocol and the determined multi-level transmission priority information so as to enable the subsequent arbiter to carry out finer priority determination on the message.

Further, how to obtain the multi-level transmission priority information and how to obtain the target industrial message by adjusting the initial industrial message are explained in detail below:

In some embodiments, determining transmission priority information for multiple layers of an initial industrial message comprises the steps of:

(102. A.1) configuring first priority information based on the attributes of the initial industrial message on the path, configuring second priority information based on the attributes of the initial industrial message on the pipe, and configuring third priority information based on the version to which the initial industrial message belongs.

And (102. A.2) splicing the first priority information, the second priority information and the third priority information to obtain multi-level transmission priority information, so that the arbiter sequentially analyzes and processes the target industrial message according to the sequence of the first priority information, the second priority information and the third priority information.

Steps (102. A.1) to (102. A.2) are described in detail below.

Where a path refers to a communication path from a sender to a receiver, multiple intermediate nodes (e.g., switches, routers, gateways, etc.) may be included between the paths. The transmission characteristics of different paths are different, for example, the path transmission characteristics comprise protocol type, delay and the like, and further, the speed of transmitting different protocol messages by different paths is different, and the speed of transmitting the same protocol message by different paths is also different.

Further, the transmitting end device may perform comprehensive scoring of the path priority for each path transmission characteristic of each initial industrial packet, and determine the first priority information of the corresponding packet according to the path priority score. Illustratively, for initial industrial message a and initial industrial message B, the following respective path priority scores a and B are obtained, respectively:

a=protocol type requirement evaluation value (high timeliness) +delay requirement evaluation value (low delay);

B=protocol type requirement evaluation value (general) +delay requirement evaluation value (general);

furthermore, a path priority score a > and a path priority score B may be obtained, and accordingly, the first priority information of the initial industrial message a is greater than the initial industrial message B.

Further, corresponding feature weights can be given to the transmission features of each path, and the priority order of each message can be obtained through comprehensive evaluation based on a plurality of feature weights. It should be noted that, the path transmission characteristics considered by the transmitting end device may be set according to the actual situation, which is not limited in the embodiment of the present application.

Wherein, the pipeline refers to a logic channel used for transmitting different types of messages on the same path. The transmission characteristics of different pipes are different, for example, the transmission characteristics of the pipes include bandwidths, etc., and further, the transmission speeds of different pipes are different, and the speeds of different pipes for transmitting the same data amount messages are different.

Further, the transmitting end device may perform comprehensive scoring of the path priority for each path transmission characteristic of each initial industrial packet, and determine the first priority information of the corresponding packet according to the path priority score. Illustratively, for initial industrial message C and initial industrial message D, the following corresponding path priority scores C and D are obtained, respectively:

C=bandwidth requirement evaluation value (general);

D=bandwidth requirement evaluation value (high bandwidth);

Furthermore, a path priority score C < path priority score D may be obtained, and correspondingly, the second priority information of the initial industrial message D is greater than the initial industrial message C. When the first priority information of the plurality of initial industrial messages is the same, judging the priority sequence of the corresponding message transmission according to the second priority information.

The version refers to a specific version of a communication protocol or a data format followed by the message, and includes a data format version, a protocol version and the like. Generally, the earlier the version indicates the earlier the corresponding message was generated, and therefore the priority order of transmission should be earlier.

Further, after the first priority information, the second priority information and the third priority information of the initial industrial message are determined, the first priority information, the second priority information and the third priority information are spliced in sequence according to the sequence of the first priority information, the second priority information and the third priority information, and multi-level transmission priority information is obtained. The subsequent arbitrator can accurately find the transmission path, pipeline and sending sequence of the corresponding message according to the transmission priority information of the multiple layers and the sequence of the first priority information, the second priority information and the third priority information in sequence, so as to realize centralized and unified priority management of the messages under different protocols.

In some embodiments, the initial industrial message is adjusted based on the transmission priority information and the industrial communication protocol to obtain the target industrial message, comprising the steps of:

and (102. B.1) adding the transmission priority information and the industrial communication protocol to the initial industrial message to obtain an adjusted initial industrial message.

And (102. B.2) configuring Gray code delimiters for the transmission priority information, and adding the Gray code delimiters to positions corresponding to the transmission priority information in the adjusted initial industrial message to obtain the target industrial message.

Steps (102. B.1) to (102. B.2) are described in detail below.

The gray code delimiter is a code generated in a binary coding mode, and any two adjacent codes of the gray code delimiter are different in one-bit binary number, so that the arbiter can easily position the gray code delimiter from a received message without complex analysis logic. Furthermore, gray code demarcation is configured for the transmission priority information, so that the arbiter can easily distinguish the transmission priority information from other message contents, and the receiving end which needs to correspondingly transmit the current processing message is determined in the shortest time.

Further, the transmitting end device configures a gray code delimiter for the transmission priority information in the process of adjusting the initial industrial message so as to obtain the target industrial message. Under the condition that the target industrial message is generated according to a preset format, the speed of processing the target industrial message by a subsequent arbiter is further improved by adding the Gray code delimiter easy to locate and identify.

In some embodiments, the method includes adding the gray code delimiter to the adjusted position corresponding to the transmission priority information in the initial industrial message to obtain the target industrial message, including the following steps:

and (A.1) sequentially taking the industrial communication protocol, the Gray code delimiter and the transmission priority information as the message header of the adjusted initial industrial message.

And (A.2) carrying out message encapsulation according to the industrial communication protocol, the Gray code delimiter, the transmission priority information and the sequence of the adjusted initial industrial message to obtain the target industrial message.

The steps (a.1) to (a.2) are described in detail below.

The message header is an information segment encapsulated at the beginning of the message, and contains some control information for transmitting and managing the message, and can provide necessary routing information and error detection and correction mechanism for the message to ensure that the message can be correctly sent and received.

The message encapsulation refers to encapsulating information data according to a certain format and specification so as to transmit the information data in a network. According to the embodiment of the application, message encapsulation is carried out according to the industrial communication protocol, the Gray code delimiter, the transmission priority information and the sequence of the adjusted initial industrial message, so that the target industrial messages sent by different industrial devices have uniform message encapsulation formats. The unified message packaging format enables the arbiter to be compatible with processing industrial messages under different protocols, so that interconnection and interworking of messages of different protocols are realized.

Step 103, the target industrial message is sent to the arbiter.

Step 103 is described in detail below.

In the industrial system, the arbiter is used for transmitting priority orders of messages when a plurality of industrial devices send requests or receive messages simultaneously, so that resource conflict and competition can be avoided on one hand, and more urgent messages can be transmitted to corresponding receiving ends more quickly on the other hand.

Further, the arbiter may be a router or a switch. Depending on the specific network architecture, application scenario and communication requirements of the industrial system, the arbiter may have the following deployment:

(1) The core switch/router is suitable for a scene of deployment of large-scale distributed industrial equipment or multi-region collaborative work, and can provide a global view and centralized management;

(2) The convergence layer exchanger/router is suitable for workshop-level communication or inter-vehicle communication, can perform local optimization and reduce the burden of a core layer;

(3) An access layer switch/router adapted for communication or localized control of small industrial equipment groups capable of providing low latency and fine granularity control;

(4) The edge computing equipment is suitable for scenes of edge intelligence and localization decision;

(5) And the mixed deployment is suitable for a scene of complex network structure or multi-protocol coexistence.

It should be noted that, the embodiment of the present application has good compatibility with the existing protocol, does not affect the architecture of the applied industrial system, and can realize a wider transmission range than the lan.

The arbiter is used for selecting a target transmission path from a plurality of candidate transmission paths in turn according to transmission priority information of different levels for target industrial messages from different sending ends, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path. And determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines.

Further, the receiving end is used for receiving the target industrial message from the arbiter, analyzing the target industrial message to obtain an initial industrial message, and processing the initial industrial message. The receiving end may be one of multiple industrial devices, so that the receiving end that receives the target industrial message performs a corresponding control action, that is, the industrial device may be a transmitting end or a receiving end, or the receiving end may be a server end different from the industrial device, where the server end may perform analysis processing on the received target industrial message, generate a relevant analysis report, and so on.

It should be noted that, the specific type of the receiving end and the specific processing action executed by the receiving end after receiving the target industrial message may be set according to the actual situation, which is not limited in the embodiment of the present application.

In the embodiment of the present application, the dimensions of the arbiter-side device will be described. As shown in fig. 3, fig. 3 is another optional flowchart of an industrial message processing method in a C2F-oriented scenario provided by the embodiment of the present application, where the method in fig. 3 may include, but is not limited to, the following steps 201 to 204, and when a sender device executes the industrial message processing method in the C2F-oriented scenario deployed at the sender, the specific flow is as follows, and it should be noted first that, in this embodiment, the order of steps 201 to 204 in fig. 3 is not limited specifically, and the order of steps may be adjusted or some steps may be reduced or added according to actual needs.

Step 201, receiving target industrial messages sent by different sending ends.

Step 201 is described in detail below.

The target industrial message is obtained by determining multi-layer transmission priority information of the initial industrial message after the transmitting end acquires the initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol.

Step 202, extracting corresponding transmission priority information from each target industrial message.

Step 202 is described in detail below.

In some embodiments, to accomplish complex, sophisticated processing tasks for industrial systems, the arbiter receives target industrial messages from a plurality of different senders at each time. After receiving a plurality of target industrial messages at the same time, the arbiter firstly extracts the transmission priority information added by the sending end from each target industrial message, so as to analyze and process the transmission priority information later and determine the receiving end and the transmission priority sequence of the corresponding target industrial message.

In some embodiments, extracting corresponding transmission priority information from each target industrial message includes the following steps:

(202. A.1) locating a gray code delimiter from the target industrial message, determining a starting position characterizing the transmission priority information based on the gray code delimiter.

(202. A.2) extracting transmission priority information based on the start position.

Steps (202. A.1) to (202. A.2) are described in detail below.

In some embodiments, the Gray code delimiter for delimiter identification is already included in the target industrial message transmitted from the sender. Therefore, the arbiter can quickly locate the starting position of the transmission priority information from the target industrial message through the Gray code delimiter, thereby greatly shortening the priority order determining time of the target industrial message.

Further, transmission priority information is extracted from the start position. In general, the transmission priority information has a fixed field length, and when the extracted information amount reaches a preset field length, it is determined that the transmission priority information is extracted, or the transmitting end may insert gray code delimiters at both the start position and the end position of the transmission priority information, so that the arbiter can determine the start position of the transmission priority information according to the gray code delimiter identified for the first time, and determine that the transmission priority information is extracted based on the gray code delimiter identified for the second time in the process of extracting the transmission priority information based on the start position.

Step 203, for each target industrial message, selecting a target transmission path from a plurality of candidate transmission paths in turn based on transmission priority information of different levels, and then selecting a target transmission pipe from a plurality of candidate transmission pipes under the target transmission path.

Step 203 is described in detail below.

The candidate transmission paths refer to paths between a transmitting end and a receiving end, wherein the paths are composed of different intermediate nodes, each path is composed of a series of nodes (such as a router, a switch and the like), and a target industrial message can be forwarded to the target receiving end through the nodes. And candidate transmission pipelines refer to a plurality of different "logical" or "physical" channels that exist on each candidate transmission path.

Further, in the conventional industrial message transmission, the priority order of different industrial messages is differentiated only by the path attribute, and compared with the local area network, the network topology structure of the ethernet is complex, and the number of transmitting end devices in communication connection with the arbiter is increased. Therefore, when the burst traffic is faced, a situation that a large amount of messages are suddenly generated on the same path occurs, so that the load of the path is increased sharply, and the conventional industrial message transmission cannot effectively cope with the situation, wherein the burst traffic may be caused by reasons including but not limited to equipment starting, periodic task synchronization, event triggering and the like. The embodiment of the application can further divide the priority of the plurality of target industrial messages based on the transmission priority information of different levels, so that the transmission priority order of each target industrial message can be more accurately determined in a complex network structure, and the industrial system can still efficiently and accurately transmit the plurality of target industrial messages in an Ethernet environment.

In some embodiments, selecting a target transmission path from among a plurality of candidate transmission paths, and selecting a target transmission pipe from among a plurality of candidate transmission pipes under the target transmission path, comprises the steps of:

And (203. A.1) if the first priority information is smaller than the preset time sequence threshold, selecting a target transmission path from the plurality of candidate transmission paths according to the value of the first priority information, wherein the transmission speeds of different candidate transmission paths are different.

And (203. A.2) selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path according to the value of the second priority information, wherein the transmission speeds of different candidate transmission pipelines are different.

Steps (203. A.1) to (203. A.2) are described in detail below.

The time sequence threshold value represents an expected value of the first priority information, and because the real-time transmission requirement of the industrial system on the message is high, under the multi-message transmission scene, the arbiter can preferentially forward the target industrial message with high priority sequence, and the message exceeding the time sequence threshold value can be regarded as the message with low emergency degree, and the arbiter can identify the message to be processed later.

Further, if the first priority information is greater than the preset time sequence threshold, the arbiter may update the first priority information of the corresponding target industrial message, and typically, the first priority information is subtracted to obtain updated first priority information, so that the arbiter puts the message to the next transmission round for processing, and does not transmit the message in the current round. In this way, among a plurality of messages to be processed, the arbiter can filter out the message with higher emergency degree through the first priority information, if the first priority information does not meet the transmission requirement of the current transmission round, the arbiter does not need to continuously analyze the second priority information and the third priority information, and further the transmission efficiency of the industrial message is improved.

In some embodiments, for each target industrial message, based on transmission priority information of different levels, selecting a target transmission path among a plurality of candidate transmission paths in turn, and then selecting a target transmission pipe among a plurality of candidate transmission pipes under the target transmission path, including the steps of:

(203. B.1) selecting a target industrial message satisfying a preset condition from a plurality of target industrial messages according to the numerical value of the multi-level transmission priority information.

(203. B.2) for each selected target industrial message, selecting a target transmission path among the plurality of candidate transmission paths in turn based on transmission priority information of different levels, and then selecting a target transmission pipe among the plurality of candidate transmission pipes under the target transmission path.

Steps (203. B.1) to (203. B.2) are described in detail below.

In some embodiments, a large number of packets may be transmitted simultaneously, which may cause network congestion, thereby causing transmission delay and even packet loss. Based on this, after receiving a plurality of target industrial messages, the arbiter of the embodiment of the application also firstly screens the received plurality of target industrial messages, then analyzes and processes the multi-level transmission priority information of the messages passing through the primary screen, and reasonably screens and corrects part of the target industrial messages under the conditions of increased network jitter and large transmission delay fluctuation caused by network congestion so as to ensure the transmission accuracy and efficiency of the messages.

In some embodiments, selecting a target industrial message satisfying a preset condition from a plurality of target industrial messages according to the numerical value of the multi-level transmission priority information, including the steps of:

and (B.1) if the total number of the target industrial messages transmitted under the current round exceeds a preset transmission threshold value, correcting the transmission priority information based on at least one of the first condition, the second condition and the third condition to obtain the target industrial message with the transmission priority information changed.

Step (b.1) is described in detail below.

The transmission threshold value refers to the maximum number of messages that the arbiter can process in the current round. Aiming at a certain target industrial message, a first condition is that first priority information is in a preset first interval value, a second condition is that second priority information is in a preset second interval value, a third condition is that third priority information is in a preset third interval value, if the multi-layer transmission priority information of the message meets at least one of the three conditions, the transmission priority information of the message is corrected, and then an arbiter processes the target industrial message after the correction of the transmission priority information, so that under a complex Ethernet environment, the important message can be ensured to be transmitted preferentially, and meanwhile, the accurate transmission of each message can be ensured.

Illustratively, the total number of target industrial messages received by the arbiter for the current round is 150, and the preset transmission threshold is 100. The first interval value is [9,10], if the first priority information of a certain target industrial message is 9, it is indicated that the first priority information is matched with the first interval value, which means that the first priority information of the message is wrong in the current round of transmission scene, so that the number of the currently transmitted messages is suddenly increased, and therefore, when at least one of three conditions occurs, the message needs to be corrected.

Further, if the first priority information is matched with the first interval value, the first priority information of the corresponding message is corrected so that the corresponding message does not belong to the current round of transmission, then, in order to meet the load balance of each path, other messages are sequentially adjusted, specifically, for paths exceeding the load, the first priority information of part of the messages is adjusted, and generally, an arbiter performs an addition process on the first priority information of part of the messages, so that the corresponding message selects another suboptimal path until the number of the messages transmitted under the current round meets the transmission threshold quantity requirement, and meanwhile, the load of each path is balanced.

Further, if the total number of messages transmitted in the current round still exceeds the preset transmission threshold after part of the target industrial messages are screened based on the first priority information, the remaining messages which meet the second condition can be continuously judged, and the messages which meet the second condition are further corrected. In an exemplary case where the first interval value is [9,10], the second interval value is [9,10], and a part of messages are screened out, judging which message meets a second condition for the messages with the corrected first priority information still matched with the first interval value, correcting the priority information of the messages meeting the second condition so that the corresponding messages do not belong to the current round transmission, and then adjusting other messages in turn to meet the load balancing of each pipeline, specifically, adjusting the second priority information of the part of messages for the pipeline exceeding the load, and generally, adding a process to the second priority information by an arbiter so that the corresponding message selects another suboptimal pipeline until the number of the messages transmitted under the current round meets the transmission threshold quantity requirement, and meanwhile, balancing the load of each pipeline.

Further, if the total number of messages transmitted in the current round still exceeds the preset transmission threshold after part of the target industrial messages are screened based on the first priority information, the remaining messages which meet the second condition can be continuously judged, and the messages which meet the second condition are further corrected. In an exemplary embodiment, the first interval value is [9,10], the second interval value is [9,10], and the third interval value is [9,10], and when a part of the messages are screened out, for the messages with the corrected first priority information still matched with the first interval value, the second priority information still matched with the second interval value, and the third priority information still matched with the third interval value, determining which message meets the third condition, and correcting the priority information of the message meeting the third condition so that the corresponding message does not belong to the current round of transmission.

It should be noted that, specific values of the first interval value, the second interval value and the third interval value may be adjusted according to actual conditions, which may be preset, or may be dynamically estimated according to the total number of messages transmitted in the current round, which is not limited in the embodiment of the present application. By correcting the messages layer by layer, the priority order of each target industrial message is reevaluated, so that the high-priority messages can be transmitted preferentially, and the low-priority messages can be transmitted gradually without influencing the critical tasks.

Step 204, determining a transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence, so as to transmit the target industrial messages to corresponding receiving ends in the target transmission pipelines based on corresponding industrial communication protocols.

Step 204 is described in detail below.

In some embodiments, where the target transmission path and the target transmission pipe are determined based on the multi-level transmission priority information, then a transmission order of the plurality of target industrial messages is determined based on the third priority information, such that the arbiter sends each target industrial message into the target transmission pipe where the target transmission path is located based on the transmission order. The receiving end is used for receiving the target industrial message from the arbiter, analyzing the target industrial message to obtain an initial industrial message, and processing the initial industrial message.

In some embodiments, the target industrial message is sent to the corresponding target transmission pipeline according to the transmission sequence, including the following steps:

(204. A.1) merging target industrial messages having the same third priority information for a plurality of target industrial messages belonging to the same target transmission path and the same target transmission pipe.

Step (204. A.1) is described in detail below.

In some embodiments, if two target industrial messages belong to the same target transmission path and the same target transmission pipeline, determining the transmission sequence of the two messages according to the size of the third priority information, and if the third priority information of the two target industrial messages is the same, combining and transmitting the two messages can be performed so as to obviously reduce the number of transmitted messages, reduce the processing burden of an arbiter and reduce the occupation of network bandwidth.

In the embodiment of the present application, description will be made from the dimension of a receiving end device, which may be integrated in a terminal server. As shown in fig. 4, fig. 4 is a flowchart of another alternative method for processing an industrial message in a C2F-oriented scenario provided by the embodiment of the present application, where the method in fig. 4 may include, but is not limited to, the following steps 301 to 302, and the specific flow of the sending end device when executing the industrial message processing method in the C2F-oriented scenario deployed at the sending end is as follows, and it should be noted first that the order of steps 301 to 302 in fig. 4 is not limited specifically, and the order of steps may be adjusted or some steps may be reduced or added according to actual needs.

Step 301, a target industrial message sent from an arbiter is received.

Step 302, parsing the target industrial message to obtain an initial industrial message, and processing the initial industrial message.

Steps 301 to 302 are described in detail below.

In some embodiments, the receiving end is configured to, when receiving the target industrial message from the arbiter, parse the target industrial message to obtain an initial industrial message, and process the initial industrial message. The receiving end may be one of multiple industrial devices, so that the receiving end that receives the target industrial message performs a corresponding control action, that is, the industrial device may be a transmitting end or a receiving end, or the receiving end may be a server end different from the industrial device, where the server end may perform analysis processing on the received target industrial message, generate a relevant analysis report, and so on.

The arbiter is configured to sequentially select, for the target industrial packets from different sending ends, a target transmission path from among the multiple candidate transmission paths based on transmission priority information of different levels, and then select a target transmission pipe from among multiple candidate transmission pipes under the target transmission path. And determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines.

In some embodiments, processing an initial industrial message includes the steps of:

and (302. A.1) analyzing the target industrial message to obtain the verification information.

And (302. A.2) verifying the initial industrial message based on the verification information, and processing the initial industrial message when the verification is passed.

Steps (302. A.1) to (302. A.2) are described in detail below.

In some embodiments, in order to ensure that no error or tampering occurs in the message in the transmission process, when the transmitting end adjusts the initial industrial message, verification information may be added, the receiving end analyzes the target industrial message obtained by forwarding by the arbiter after receiving the target industrial message, so as to obtain the verification information, and the initial industrial message is verified based on the verification information. If the checking result is inconsistent, the message is erroneous or tampered in the transmission process, or other error processing measures such as retransmission request, error log recording and the like can be selected to be discarded by the receiving end.

The check information may be hash value information, cyclic redundancy check code information, etc., and may be specifically adjusted according to actual situations, which is not limited in the embodiment of the present application.

As shown in fig. 5, fig. 5 is an optional block diagram of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application, where the apparatus applied to a transmitting end includes:

The acquiring module 401 is configured to acquire an initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message.

The adjustment module 402 is configured to determine transmission priority information of multiple layers of the initial industrial message, and adjust the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message.

A first sending module 403, configured to send the target industrial message to the arbiter. The arbiter is used for selecting a target transmission path from a plurality of candidate transmission paths in turn according to transmission priority information of different levels for target industrial messages from different sending ends, and then selecting a target transmission pipeline from a plurality of candidate transmission pipelines under the target transmission path. The method comprises the steps of determining the transmission sequence of a plurality of target industrial messages based on multi-level transmission priority information, sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence, transmitting the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines, wherein the receiving ends are used for analyzing the target industrial messages from an arbitrator to obtain initial industrial messages and processing the initial industrial messages when receiving the target industrial messages from the arbitrator.

The specific implementation manner of the industrial message processing device applied to the sending end in the C2F-oriented scene is basically the same as the specific embodiment of the industrial message processing method applied to the sending end in the C2F-oriented scene, and is not described herein again.

As shown in fig. 6, fig. 6 is a schematic diagram of another optional module of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application, where the apparatus applied to an arbiter side includes:

The first receiving module 501 is configured to receive target industrial messages sent by different sending ends, where the target industrial messages are obtained by the sending end determining transmission priority information of multiple layers of the initial industrial message after obtaining the initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol.

And the extracting module 502 is configured to extract corresponding transmission priority information from each target industrial packet respectively.

The arbitration processing module 503 is configured to sequentially select, for each target industrial packet, a target transmission path from among a plurality of candidate transmission paths based on transmission priority information of different levels, and then select a target transmission pipe from among a plurality of candidate transmission pipes under the target transmission path.

The second sending module 504 is configured to determine a transmission order of the multiple target industrial messages based on the multi-level transmission priority information, send the target industrial messages to corresponding target transmission pipes according to the transmission order, so as to transmit the target industrial messages to corresponding receiving ends in the target transmission pipes based on corresponding industrial communication protocols, where the receiving ends are configured to parse the target industrial messages from the target industrial messages to obtain initial industrial messages and process the initial industrial messages when receiving the target industrial messages from the arbitrator.

The specific implementation of the industrial message processing device applied to the arbiter end in the C2F-oriented scene is basically the same as the specific embodiment of the industrial message processing method applied to the arbiter end in the C2F-oriented scene, and will not be described herein.

As shown in fig. 7, fig. 7 is a schematic block diagram of another alternative module of an industrial message processing apparatus in a C2F-oriented scenario according to an embodiment of the present application, where the apparatus applied to a receiving end includes:

The second receiving module 601 is configured to receive the target industrial message sent from the arbiter. The target industrial message is obtained by determining multi-layer transmission priority information of the initial industrial message after the transmitting end acquires the initial industrial message to be transmitted and an industrial communication protocol corresponding to the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol. The arbiter is configured to sequentially select, for the target industrial packets from different sending ends, a target transmission path from among the multiple candidate transmission paths based on transmission priority information of different levels, and then select a target transmission pipe from among multiple candidate transmission pipes under the target transmission path. And determining the transmission sequence of a plurality of target industrial messages based on the multi-level transmission priority information, and sending the target industrial messages to corresponding target transmission pipelines according to the transmission sequence so as to transmit the target industrial messages to corresponding receiving ends based on corresponding industrial communication protocols in the target transmission pipelines.

The receiving processing module 602 is configured to parse the target industrial message to obtain an initial industrial message, and process the initial industrial message.

The specific implementation manner of the industrial message processing device applied to the receiving end in the C2F-oriented scene is basically the same as the specific embodiment of the industrial message processing method applied to the receiving end in the C2F-oriented scene, and is not described herein again.

The embodiment of the application also provides electronic equipment, which comprises a memory and a processor, wherein the memory stores a computer program, and the processor realizes the industrial message processing method under the C2F-oriented scene when executing the computer program. The electronic equipment can be any intelligent terminal including a tablet personal computer, a vehicle-mounted computer and the like.

As shown in fig. 8, fig. 8 is a schematic hardware structure of an electronic device according to an embodiment of the present application, where the electronic device includes:

The processor 701 may be implemented by a general-purpose CPU (Central Processing Unit ), a microprocessor, an Application SPECIFIC INTEGRATED Circuit (ASIC), or one or more integrated circuits, etc. for executing related programs, so as to implement the technical solution provided by the embodiments of the present application;

The Memory 702 may be implemented in the form of a Read Only Memory (ROM), a static storage device, a dynamic storage device, or a random access Memory (Random Access Memory, RAM). The memory 702 may store an operating system and other application programs, and when the technical solution provided in the embodiments of the present disclosure is implemented by software or firmware, relevant program codes are stored in the memory 702, and the processor 701 invokes an industrial message processing method in a C2F-oriented scenario to execute the embodiments of the present disclosure;

An input/output interface 703 for implementing information input and output;

The communication interface 704 is configured to implement communication interaction between the device and other devices, and may implement communication in a wired manner (e.g. USB, network cable, etc.), or may implement communication in a wireless manner (e.g. mobile network, WIFI, bluetooth, etc.);

a bus 705 for transferring information between various components of the device (e.g., the processor 701, memory 702, input/output interfaces 703, and communication interfaces 704);

wherein the processor 701, the memory 702, the input/output interface 703 and the communication interface 704 are in communication connection with each other inside the device via a bus 705.

The embodiment of the application also provides a computer readable storage medium, wherein the computer readable storage medium stores a computer program which realizes the industrial message processing method under the C2F-oriented scene when being executed by a processor.

The memory, as a non-transitory computer readable storage medium, may be used to store non-transitory software programs as well as non-transitory computer executable programs. In addition, the memory may include high-speed random access memory, and may also include non-transitory memory, such as at least one magnetic disk storage device, flash memory device, or other non-transitory solid state storage device. In some embodiments, the memory optionally includes memory remotely located relative to the processor, the remote memory being connectable to the processor through a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.

The embodiments described in the embodiments of the present application are for more clearly describing the technical solutions of the embodiments of the present application, and do not constitute a limitation on the technical solutions provided by the embodiments of the present application, and those skilled in the art can know that, with the evolution of technology and the appearance of new application scenarios, the technical solutions provided by the embodiments of the present application are equally applicable to similar technical problems.

It will be appreciated by persons skilled in the art that the embodiments of the application are not limited by the illustrations, and that more or fewer steps than those shown may be included, or certain steps may be combined, or different steps may be included.

The above described apparatus embodiments are merely illustrative, wherein the units illustrated as separate components may or may not be physically separate, i.e. may be located in one place, or may be distributed over a plurality of network elements. Some or all of the modules may be selected according to actual needs to achieve the purpose of the solution of this embodiment.

Those of ordinary skill in the art will appreciate that all or some of the steps of the methods, systems, functional modules/units in the devices disclosed above may be implemented as software, firmware, hardware, and suitable combinations thereof.

The terms "first," "second," "third," "fourth," and the like in the description of the application and in the above figures, if any, are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order. It is to be understood that the data so used may be interchanged where appropriate such that the embodiments of the application described herein may be implemented in sequences other than those illustrated or otherwise described herein. Furthermore, the terms "comprises," "comprising," and "having," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of steps or elements is not necessarily limited to those steps or elements expressly listed but may include other steps or elements not expressly listed or inherent to such process, method, article, or apparatus.

It should be understood that in the present application, "at least one (item)" means one or more, and "a plurality" means two or more. "and/or" is used to describe an association relationship of an associated object, and indicates that three relationships may exist, for example, "a and/or B" may indicate that only a exists, only B exists, and three cases of a and B exist simultaneously, where a and B may be singular or plural. The character "/" generally indicates that the context-dependent object is an "or" relationship. "at least one of" or the like means any combination of these items, including any combination of single item(s) or plural items(s). For example, at least one of a, b or c may represent a, b, c, "a and b", "a and c", "b and c", or "a and b and c", wherein a, b, c may be single or plural.

In the several embodiments provided by the present application, it should be understood that the disclosed apparatus and method may be implemented in other manners. For example, the above-described apparatus embodiments are merely illustrative, and for example, the above-described division of units is merely a logical function division, and there may be another division manner in actual implementation, for example, a plurality of units or components may be combined or may be integrated into another system, or some features may be omitted, or not performed. Alternatively, the coupling or direct coupling or communication connection shown or discussed with each other may be an indirect coupling or communication connection via some interfaces, devices or units, which may be in electrical, mechanical or other form.

The units described above as separate components may or may not be physically separate, and components shown as units may or may not be physical units, may be located in one place, or may be distributed over a plurality of network units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in the embodiments of the present application may be integrated in one processing unit, or each unit may exist alone physically, or two or more units may be integrated in one unit. The integrated units may be implemented in hardware or in software functional units.

The integrated units, if implemented in the form of software functional units and sold or used as stand-alone products, may be stored in a computer readable storage medium. Based on such understanding, the technical solution of the present application may be embodied in essence or a part contributing to the prior art or all or part of the technical solution in the form of a software product stored in a storage medium, including multiple instructions to cause a computer device (which may be a personal computer, a server, or a network device, etc.) to perform all or part of the steps of the method of the various embodiments of the present application. The storage medium includes various media capable of storing programs, such as a U disk, a removable hard disk, a Read-Only Memory (ROM), a random access Memory (Random Access Memory RAM), a magnetic disk, or an optical disk.

The preferred embodiments of the present application have been described above with reference to the accompanying drawings, and are not thereby limiting the scope of the claims of the embodiments of the present application. Any modifications, equivalent substitutions and improvements made by those skilled in the art without departing from the scope and spirit of the embodiments of the present application shall fall within the scope of the claims of the embodiments of the present application.

Claims

1. An industrial message processing method for C2F scenarios, characterized in that it is applied at the sending end and includes:

Acquire the initial industrial message to be transmitted and the industrial communication protocol corresponding to the initial industrial message, wherein the initial industrial message refers to raw data or instructions generated from industrial equipment, which are used for communication between different industrial equipment;

Determine the multi-level transmission priority information of the initial industrial message, and adjust the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message;

The target industrial message is sent to the arbitrator;

The arbitrator is configured to, for target industrial messages from different sending ends, sequentially select a target transmission path from multiple candidate transmission paths based on the transmission priority information of the target industrial messages at different levels, and then select a target transmission channel from multiple candidate transmission channels under the target transmission path; determine the transmission order of multiple target industrial messages based on the multi-level transmission priority information, and send the target industrial messages to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol in the target transmission channels;

The receiving end is used to receive the target industrial message from the arbitrator, parse the initial industrial message from the target industrial message, and process the initial industrial message;

The determination of the multi-level transmission priority information of the initial industrial message includes:

The first priority information is configured based on the attributes of the initial industrial message on the path, the second priority information is configured based on the attributes of the initial industrial message on the pipeline, and the third priority information is configured based on the version to which the initial industrial message belongs. The third priority information is related to the version characteristics of the initial industrial message. The earlier the version, the earlier the initial industrial message was generated, and the earlier the order of the third priority information is.

By concatenating the first priority information, the second priority information, and the third priority information, a multi-level transmission priority information is obtained, so that the arbitrator can analyze and process the target industrial message in the order of the first priority information, the second priority information, and the third priority information.

The step of adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message includes:

The transmission priority information and the industrial communication protocol are added to the initial industrial message to obtain the adjusted initial industrial message;

Configure a Gray code delimiter for the transmission priority information, and add the Gray code delimiter to the position corresponding to the transmission priority information in the adjusted initial industrial message to obtain the target industrial message;

The transmission priority information includes first priority information, second priority information, and third priority information at different levels;

The step of selecting a target transmission path from multiple candidate transmission paths, and then selecting a target transmission pipe from multiple candidate transmission pipes under the target transmission path, includes:

If the first priority information is less than a preset timing threshold, the target transmission path is selected from multiple candidate transmission paths according to the value of the first priority information, wherein the transmission speeds of different candidate transmission paths are different.

Then, based on the value of the second priority information, the target transmission channel is selected from the multiple candidate transmission channels under the target transmission path, wherein the transmission speeds of different candidate transmission channels are different;

Sending the target industrial message to the corresponding target transmission channel according to the transmission order includes:

For multiple target industrial messages belonging to the same target transmission path and the same target transmission channel, merge and transmit the target industrial messages with the same third priority information;

For each target industrial message, based on the transmission priority information at different levels, a target transmission path is sequentially selected from multiple candidate transmission paths, and then a target transmission channel is selected from multiple candidate transmission channels under the target transmission path, including:

Based on the numerical values of the transmission priority information at multiple levels, select the target industrial message that meets the preset conditions from a plurality of target industrial messages;

For each selected target industrial message, based on the transmission priority information at different levels, a target transmission path is selected from multiple candidate transmission paths in sequence, and a target transmission channel is selected from multiple candidate transmission channels under the target transmission path.

The step of selecting target industrial messages that meet preset conditions from a plurality of target industrial messages based on the numerical values of the multi-level transmission priority information includes:

If the total number of target industrial messages transmitted in the current round exceeds a preset transmission threshold, the transmission priority information is corrected layer by layer based on at least one of the first, second, and third conditions to obtain the target industrial messages with the changed transmission priority information.

Wherein, the first condition is that the first priority information matches a preset first interval value, the second condition is that the second priority information matches a preset second interval value, and the third condition is that the third priority information matches a preset third interval value.

2. The industrial message processing method for C2F scenarios according to claim 1, characterized in that, adding the Gray code delimiter to the position corresponding to the transmission priority information in the adjusted initial industrial message to obtain the target industrial message includes:

The industrial communication protocol, the Gray code delimiter, and the transmission priority information are sequentially used as the header of the adjusted initial industrial message;

The target industrial message is obtained by encapsulating the message according to the order of the industrial communication protocol, the Gray code delimiter, the transmission priority information, and the adjusted initial industrial message.

3. An industrial message processing method for C2F scenarios, characterized in that it is applied to an arbitrator and includes:

The system receives target industrial messages from different sending ends. The target industrial message is obtained by the sending end after acquiring the initial industrial message to be transmitted and the industrial communication protocol corresponding to the initial industrial message, determining the multi-level transmission priority information of the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol. The initial industrial message refers to raw data or instructions generated from industrial equipment, which are used for communication between different industrial equipment.

Extract the corresponding transmission priority information from each of the target industrial messages;

For each target industrial message, based on the transmission priority information of the target industrial message at different levels, a target transmission path is selected sequentially from multiple candidate transmission paths, and then a target transmission channel is selected from multiple candidate transmission channels under the target transmission path.

Based on the multi-level transmission priority information, the transmission order of multiple target industrial messages is determined, and the target industrial messages are sent to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol in the target transmission channels.

The receiving end is configured to receive the target industrial message from the arbitrator, parse the initial industrial message from the target industrial message, and process the initial industrial message.

The target industrial message is determined through the following steps:

4. The industrial message processing method for C2F scenarios according to claim 3, wherein the target industrial message includes a Gray code delimiter for delimitation and identification;

The step of extracting the corresponding transmission priority information from each of the target industrial messages includes:

Locate the Gray code delimiter from the target industrial message, and determine the starting position representing the transmission priority information based on the Gray code delimiter;

Based on the starting position, the transmission priority information is extracted.

5. An industrial message processing method for C2F scenarios, characterized in that it is applied at the receiving end and includes:

Receive target industrial messages sent from the arbitrator;

The target industrial message is obtained by the sending end after acquiring the initial industrial message to be transmitted and the industrial communication protocol corresponding to the initial industrial message, determining the multi-level transmission priority information of the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol. The initial industrial message refers to the raw data or instructions generated from industrial equipment, which are used for communication between different industrial equipment.

Furthermore, the arbitrator is used to select a target transmission path from multiple candidate transmission paths sequentially based on the transmission priority information of the target industrial messages from different sending ends, and then select a target transmission channel from multiple candidate transmission channels under the target transmission path; determine the transmission order of multiple target industrial messages based on the multi-level transmission priority information, and send the target industrial messages to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol in the target transmission channels;

The initial industrial message is obtained by parsing the target industrial message, and the initial industrial message is processed.

The target industrial message is determined through the following steps:

6. The industrial message processing method for C2F scenarios according to claim 5, characterized in that processing the initial industrial message includes:

Verification information is obtained by parsing the target industrial message;

The initial industrial message is verified based on the verification information, and the initial industrial message is processed when the verification passes.

7. An industrial message processing device for C2F scenarios, applied at the sending end, characterized in that, applied at the sending end, it includes:

The acquisition module is used to acquire the initial industrial message to be transmitted and the industrial communication protocol corresponding to the initial industrial message, wherein the initial industrial message refers to the raw data or instructions generated from the industrial equipment, which are used for communication between different industrial equipment.

An adjustment module is used to determine the multi-level transmission priority information of the initial industrial message, and adjust the initial industrial message based on the transmission priority information and the industrial communication protocol to obtain the target industrial message;

A first sending module is configured to send the target industrial message to an arbitrator; wherein the arbitrator is configured to, for the target industrial messages from different sending ends, sequentially select a target transmission path from multiple candidate transmission paths based on the transmission priority information of the target industrial messages at different levels, and then select a target transmission channel from multiple candidate transmission channels under the target transmission path; determine the transmission order of multiple target industrial messages based on the multi-level transmission priority information, and send the target industrial messages to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol in the target transmission channels; the receiving end is configured to receive the target industrial message from the arbitrator, parse the initial industrial message from the target industrial message, and process the initial industrial message;

8. An industrial message processing device for C2F scenarios, characterized in that it is applied at the arbitrator end and includes:

The first receiving module is used to receive target industrial messages sent from different sending ends. The target industrial message is obtained by the sending end after acquiring the initial industrial message to be transmitted and the industrial communication protocol corresponding to the initial industrial message, determining the multi-level transmission priority information of the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol. The initial industrial message refers to raw data or instructions generated from industrial equipment, which are used for communication between different industrial equipment.

The extraction module is used to extract the corresponding transmission priority information from each of the target industrial messages;

The arbitration processing module is used to select a target transmission path from multiple candidate transmission paths in sequence for each target industrial message based on the transmission priority information of the target industrial message at different levels, and then select a target transmission channel from multiple candidate transmission channels under the target transmission path.

The second sending module is configured to determine the transmission order of multiple target industrial messages based on the multi-level transmission priority information, and send the target industrial messages to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol in the target transmission channels; wherein, the receiving end is configured to receive the target industrial messages from the arbitrator, parse the initial industrial message from the target industrial messages, and process the initial industrial message;

The target industrial message is determined through the following steps:

9. An industrial message processing device for C2F scenarios, characterized in that it is applied at the receiving end and includes:

The second receiving module is used to receive target industrial messages sent from the arbitrator. The target industrial message is obtained by the sending end after acquiring the initial industrial message to be transmitted and the corresponding industrial communication protocol, determining the multi-level transmission priority information of the initial industrial message, and adjusting the initial industrial message based on the transmission priority information and the industrial communication protocol. The initial industrial message refers to raw data or instructions generated from industrial equipment for communication between different industrial devices. The arbitrator, for target industrial messages from different sending ends, sequentially selects a target transmission path from multiple candidate transmission paths based on the transmission priority information of the target industrial messages at different levels, and then selects a target transmission channel from multiple candidate transmission channels under the target transmission path. Based on the multi-level transmission priority information, it determines the transmission order of multiple target industrial messages and sends the target industrial messages to the corresponding target transmission channels according to the transmission order, so that the target industrial messages are transmitted to the corresponding receiving end in the correct order based on the corresponding industrial communication protocol within the target transmission channels.

A receiving and processing module is used to parse the initial industrial message from the target industrial message and process the initial industrial message;

The target industrial message is determined through the following steps:

10. A computer-readable storage medium storing a computer program, characterized in that, when executed by a processor, the computer program implements the industrial message processing method for C2F scenarios as described in any one of claims 1 to 2, or the industrial message processing method for C2F scenarios as described in any one of claims 3 to 4, or the industrial message processing method for C2F scenarios as described in any one of claims 5 to 6.