CN111818136B - Data processing method, device, electronic device, and computer-readable medium - Google Patents

Abstract

Embodiments of the present application provide a data processing method, device, computer-readable medium, and electronic equipment. The data processing method includes detecting the communication link type between the intermediate server and the target intelligent logistics equipment in response to the data packet from the target intelligent logistics equipment; according to the communication link type between the intermediate server and the target intelligent logistics equipment, determining the data The target communication protocol adopted by the packet during transmission; the data packet is analyzed based on the target communication protocol to obtain the analyzed data; the analyzed data is processed according to the communication protocol corresponding to the communication link type between the intermediate server and the logistics data server Encapsulation processing, generating encapsulated data packets. The technical solution of the embodiment of the present application enables the logistics data server to support various types of intelligent logistics equipment, as well as various communication link types between the intelligent logistics equipment and the logistics data server, and at the same time reduce the cost of the logistics data service platform. system load.

Description

Data processing method, device, electronic device, and computer-readable medium

technical field

The present application relates to the field of computer technology, in particular, to a data processing method, device, computer readable medium and electronic equipment.

Background technique

The logistics data server is used to provide corresponding business services for the intelligent logistics equipment, so that users can better control the intelligent logistics equipment through the logistics data server.

In order to better serve various types of intelligent logistics equipment, the logistics data server needs to support various types of intelligent logistics equipment and multiple communication link types between each type of intelligent logistics equipment and the logistics data server. In related technologies, the logistics data server generally develops functional modules that support various intelligent logistics equipment. As the types of intelligent logistics equipment increase, the functional modules of the logistics data server become redundant, which will seriously increase the system load of the logistics data server. In addition, when a new type of intelligent logistics equipment is added, it will make it necessary to update and maintain the intelligent logistics equipment from time to time, which will affect the normal use of other types of intelligent logistics equipment.

Contents of the invention

The embodiment of the present application provides a data processing method, device, computer-readable medium, and electronic equipment, which can enable the logistics data server to support various types of intelligent logistics equipment, and multiple communication between the intelligent logistics equipment and the logistics data server. At the same time, it can reduce the system load of the logistics data service platform.

Other features and advantages of the present application will become apparent from the following detailed description, or in part, be learned by practice of the invention.

According to an aspect of the embodiments of the present application, there is provided a data processing method, including: detecting the communication link type between the intermediate server and the target intelligent logistics equipment in response to a data packet from the target intelligent logistics equipment; According to the communication link type between the intermediate server and the target intelligent logistics equipment, determine the target communication protocol used by the data packet during transmission; analyze the data packet based on the target communication protocol, and obtain the resolved according to the communication protocol corresponding to the communication link type between the intermediate server and the logistics data server, the analyzed data is encapsulated to generate an encapsulated data packet; through the intermediate server and the logistics data server The communication link between the logistics data servers sends the encapsulated data packets to the logistics data servers.

According to an aspect of the embodiment of the present application, there is provided a data processing device, including: a detection unit, configured to detect the communication between the intermediate server and the target intelligent logistics equipment in response to a data packet from the target intelligent logistics equipment The communication link type; the execution unit is used to determine the target communication protocol adopted by the data packet during transmission according to the communication link type between the intermediate server and the target intelligent logistics equipment; the analysis unit is used to Parsing the data packet based on the target communication protocol to obtain the parsed data; an encapsulation unit configured to parse the parsing according to a communication protocol corresponding to a communication link type between the intermediate server and the logistics data server The encapsulated data is processed to generate an encapsulated data packet; the sending unit is used to send the encapsulated data packet to the logistics data server through the communication link between the intermediate server and the logistics data server .

In some embodiments of the present application, based on the foregoing solution, the detection unit includes: a detection subunit, configured to detect the receiving port number of the target receiving the data packet; a first execution subunit, configured to Receive the port number, and the corresponding relationship between the port number and the communication link type, and determine the communication link type between the intermediate server and the target intelligent logistics device.

In some embodiments of the present application, based on the foregoing solution, the execution unit includes: an acquisition subunit, configured to acquire the equipment type of the target intelligent logistics equipment; a first generating subunit, configured to The device type of the device and the communication link type between the intermediate server and the target intelligent logistics device generate target environment configuration information; the second execution subunit is configured to generate target environment configuration information based on the target environment configuration information and the environment configuration information The corresponding relationship with the communication protocol determines the target communication protocol adopted by the data packet during transmission.

In some embodiments of the present application, based on the foregoing solution, the sending unit includes: a second generating subunit, configured to generate a write message packet according to the encapsulated data packet; an adding subunit, configured to The write message package is added to the message sending queue; the sending subunit is used to send the write message package contained in the message sending queue through the communication link between the intermediate server and the logistics data server to the logistics data server.

In some embodiments of the present application, based on the foregoing solution, the sending subunit is configured to determine the priority of each written message packet in the message sending queue according to the content of the written message packet; The priority of the message packets determines the sending order of each written message packet in the message sending queue; based on the sending order, sequentially sends the written message packets in the message sending queue to the logistics data server.

According to an aspect of the embodiments of the present application, an electronic device is provided, including: one or more processors; a storage device for storing one or more programs, when the one or more programs are executed by the one or more When executed by multiple processors, the one or more processors implement the data processing method as described in the foregoing embodiments.

According to one aspect of the embodiments of the present application, a computer-readable medium is provided, on which a computer program is stored, and when the computer program is executed by a processor, the data processing method as described in the above-mentioned embodiments is implemented.

In the technical solution provided by some embodiments of the present application, the logistics data server can support various intelligent logistics equipment and various types of communication link types between different intelligent logistics equipment and the logistics data server, And while being able to support various types of intelligent logistics equipment and various types of communication links between different intelligent logistics equipment and logistics data servers, it can also effectively reduce the system load of the logistics data service platform.

It is to be understood that both the foregoing general description and the following detailed description are exemplary and explanatory only and are not restrictive of the application.

Description of drawings

The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the application and together with the description serve to explain the principles of the application. Apparently, the drawings in the following description are only some embodiments of the present application, and those skilled in the art can obtain other drawings according to these drawings without creative efforts. In the attached picture:

FIG. 1 shows a schematic diagram of an exemplary system architecture to which the technical solutions of the embodiments of the present application can be applied;

Fig. 2 schematically shows a flow chart of a data processing method according to an embodiment of the present application;

Fig. 3 schematically shows a flow chart of a data processing method according to an embodiment of the present application;

Fig. 4 schematically shows a flow chart of a data processing method according to an embodiment of the present application;

FIG. 5 schematically shows a specific flowchart of step S250 according to an embodiment of the present application;

Fig. 6 schematically shows a flow chart of a data processing method according to an embodiment of the present application;

Fig. 7 schematically shows a block diagram of a data processing device according to an embodiment of the present application;

FIG. 8 shows a schematic structural diagram of a computer system suitable for implementing the electronic device of the embodiment of the present application.

Detailed ways

Example embodiments will now be described more fully with reference to the accompanying drawings. Example embodiments may, however, be embodied in many forms and should not be construed as limited to the examples set forth herein; rather, these embodiments are provided so that this application will be thorough and complete, and will fully convey the concepts of example embodiments to those skilled in the art.

Furthermore, the described features, structures, or characteristics may be combined in any suitable manner in one or more embodiments. In the following description, numerous specific details are provided in order to give a thorough understanding of the embodiments of the application. However, those skilled in the art will appreciate that the technical solutions of the present application may be practiced without one or more of the specific details, or other methods, components, devices, steps, etc. may be employed. In other instances, well-known methods, apparatus, implementations, or operations have not been shown or described in detail to avoid obscuring aspects of the invention.

The block diagrams shown in the drawings are merely functional entities and do not necessarily correspond to physically separate entities. That is, these functional entities may be implemented in software, or in one or more hardware modules or integrated circuits, or in different networks and/or processor devices and/or microcontroller devices entity.

The flow charts shown in the drawings are only exemplary illustrations, and do not necessarily include all contents and operations/steps, nor must they be performed in the order described. For example, some operations/steps can be decomposed, and some operations/steps can be combined or partly combined, so the actual order of execution may be changed according to the actual situation.

Fig. 1 shows a schematic diagram of an exemplary system architecture to which the technical solutions of the embodiments of the present application can be applied.

As shown in FIG. 1 , the system architecture 100 may include an intelligent logistics device 101 , an intermediate server 102 , a logistics data server 103 and a network 104 . The network 104 is used as a medium for providing communication links between the intelligent logistics equipment 101 , the intermediate server 102 and the logistics data server 103 . Network 102 may include various connection types, such as wires, wireless communication links, or fiber optic cables, among others. It should be understood that the numbers of intelligent logistics equipment, intermediate servers, logistics data servers and networks in Fig. 1 are only illustrative. According to the realization requirements, there can be any number of intelligent logistics equipment, networks and servers. For example, the intermediate server 102 or the logistics data server 103 may be a server cluster composed of multiple servers.

In the intermediate server 102, the intermediate server 102 responds to the data packet from the target intelligent logistics equipment 101, and detects the communication link type between the intermediate server 102 and the target intelligent logistics equipment 101; The type of communication link between 101 determines the target communication protocol adopted by the data packet during transmission; parses the data packet based on the target communication protocol to obtain the analyzed data; according to the communication between the intermediate server 102 and the logistics data server 103 The communication protocol corresponding to the communication link type encapsulates the analyzed data to generate an encapsulated data packet; sends the encapsulated data packet to the logistics data server through the communication link between the intermediate server 102 and the logistics data server 103 103.

It can be seen that the technical solution of the embodiment of the present application can enable the logistics data server to support various types of intelligent logistics equipment and various types of communication links between the intelligent logistics equipment and the logistics data server, while reducing the number of logistics data. The system load of the service platform.

The data processing method provided by the embodiment of the present application is generally executed by the intermediate server 102 . However, those skilled in the art can easily understand that the data processing method provided in the embodiment of the present application may also be implemented by the logistics data server 103 in the data processing method in this exemplary embodiment, which is not specifically limited.

The implementation details of the technical solutions of the embodiments of the present application are described in detail below:

FIG. 2 schematically shows a flow chart of a data processing method according to an embodiment of the present application. The data processing method can be executed by the intermediate server 102 shown in FIG. 1 , and this embodiment takes the execution of the intermediate server as an example Be explained. Referring to Fig. 2, the data processing method includes at least step S210 to step S230, described in detail as follows:

In step S210, in response to the data packet from the target smart logistics device, the type of the communication link between the intermediate server and the target smart logistics device is detected.

In one embodiment, the intelligent logistics equipment is a logistics equipment that can be intelligently controlled, specifically, it can be a logistics equipment that realizes certain specific functions such as sorting, handling, and storage. Intelligent logistics equipment can receive control instructions or upload its own data to the corresponding intermediate server, and then forward it to the logistics data server by the intermediate server, so as to realize the communication connection with the logistics data server.

The communication link is the link between the intelligent logistics equipment and the intermediate server. The communication link between the intelligent logistics equipment and the intermediate server can include LPWA (Low-Power Wide-Area) cellular communication link, 5G global Mobile communication system communication link, radio frequency identification (RFID, Radio Frequency Identification) communication link and satellite communication link, the satellite communication link may specifically include Orbcomm satellite communication link, Tianqi satellite communication link, Xingyun satellite communication link Low-orbit satellite communication links such as roads, etc., are not limited here. The data packet is the data packet sent by the intelligent logistics equipment to the intermediate server through any one of the above-mentioned communication links.

After the intermediate server receives the data packet of any target intelligent logistics device, it can detect the communication link type between the intermediate server and the target intelligent logistics device.

Referring to FIG. 3, FIG. 3 schematically shows a flow chart of a data processing method according to an embodiment of the present application. Referring to FIG. 3, the steps of detecting the communication link type between the intermediate server and the target intelligent logistics device are specific It may include steps S310 to S320, which are described in detail as follows.

In step S310, the target receiving port number of the received data packet is detected.

In one embodiment, the receiving port is a specific functional module for receiving data packets in the intermediate server. For different types of communication links, the intermediate server will receive data packets from the target intelligent logistics device through different receiving ports. The receiving port number It is certain identification information for uniquely identifying different receiving ports, and the identification information may specifically be the number of the receiving port or the device identifier of the receiving port, which is not limited herein. When determining the communication link type between the intermediate server and the target intelligent logistics device, the target receiving port that receives the data packet can be monitored first, and the receiving port number corresponding to the target receiving port can be obtained.

In step S320, based on the target receiving port number and the corresponding relationship between the port number and the communication link type, the communication link type between the intermediate server and the target intelligent logistics device is determined.

In one embodiment, the intermediate server pre-stores the corresponding relationship between the receiving port numbers of different receiving ports and the corresponding communication link types, and the intermediate server determines the The communication link type between the intermediate server and the target intelligent logistics equipment.

In the technical solution of the embodiment shown in Figure 3, by pre-establishing the corresponding relationship between the receiving port numbers corresponding to the different receiving ports and the communication link type, it is possible to quickly and accurately determine the intermediate server and the target intelligent logistics device The type of communication link between them improves the efficiency of data processing.

In step S220, according to the type of the communication link between the intermediate server and the target intelligent logistics device, determine the target communication protocol used when the data packet is transmitted.

In one embodiment, there is an association between the type of communication link between the intermediate server and the target intelligent logistics device and the target communication protocol used when the data packet is transmitted. After determining the communication link type, the target communication protocol adopted by the data packet during transmission can be determined according to the determined communication link type and the above-mentioned association relationship, so as to analyze and process the data packet. It can be understood that, since the same communication link type may correspond to multiple different communication protocols, the determined target communication protocol may be one or more.

Referring to FIG. 4, FIG. 4 schematically shows a specific flow chart of step S220 according to an embodiment of the present application. Referring to FIG. 4, step S220 may specifically include steps S410 to S4230, which are described in detail as follows.

In step S410, the device type of the target intelligent logistics device is acquired.

In one embodiment, since the same type of communication link can correspond to a variety of different communication protocols, when the smart logistics equipment of different equipment types uses the same type of communication link to communicate with the intermediate server, the smart logistics Under the premise of different equipment types, the corresponding communication protocols will also be different. Therefore, it is necessary to transmit data packets based on the equipment type of the intelligent logistics equipment and the communication link type between the two types of information of the intelligent logistics equipment and the intermediate server. To determine the target communication protocol used by the data packet during transmission.

Optionally, the device identification of the target intelligent logistics device may be obtained, and the device type of the target intelligent logistics device may be determined according to the device identification of the target intelligent logistics device.

In step S420, target environment configuration information is generated according to the device type of the target smart logistics device and the communication link type between the intermediate server and the target smart logistics device.

In one embodiment, after acquiring the device type of the target smart logistics device and the communication link type between the intermediate server and the target smart logistics device, the target environment configuration information corresponding to the target smart logistics device can be generated according to these two pieces of information, And based on the environment configuration information, the target communication protocol adopted by the data packet during transmission is determined. It can be understood that the intermediate server may pre-store the corresponding relationship between the environment configuration information corresponding to different types of intelligent logistics equipment and the communication protocol adopted by the data packet during transmission, so as to determine the information used during transmission according to the environment configuration information. The communication protocol used.

In step S430, based on the target environment configuration information and the corresponding relationship between the environment configuration information and the communication protocol, the target communication protocol adopted by the data packet during transmission is determined.

In one embodiment, the intermediate server can use the generated target environment configuration information as an index to search in the corresponding relationship between the pre-stored environment configuration information and the communication protocol, and determine the data packets from the target intelligent logistics equipment during transmission. The target communication protocol used.

In the technical solution of the embodiment shown in Figure 4, by storing the corresponding relationship between different environment configuration information and the communication protocol adopted by the data packet during transmission, the intermediate server can support intelligent logistics equipment of different equipment types, The target communication protocol used by the data packet to be determined more quickly during transmission improves the efficiency of data processing.

In step S230, the data packet is analyzed based on the target communication protocol to obtain the analyzed data.

In one embodiment, after determining the target communication protocol adopted by the data packet of the target intelligent logistics device during transmission, in order to enable the logistics data server to receive and analyze the data packet smoothly, it needs to be analyzed according to the determined target communication protocol The data packet, get the parsed data.

Optionally, specifically, the data packet may be parsed according to a parsing function corresponding to the target communication protocol to obtain parsed data.

In step S240, the analyzed data is encapsulated according to the communication protocol corresponding to the communication link type between the intermediate server and the logistics data server, and an encapsulated data packet is generated.

In one embodiment, the communication link type between the intermediate server and the logistics data server is a certain type of communication link agreed in advance between the intermediate server and the logistics data server. After the intermediate server obtains the parsed data, in order to facilitate sending the parsed data to the logistics data server and enable the logistics data server to read the parsed information, it can follow the communication link between the intermediate server and the logistics data server The communication protocol corresponding to the type encapsulates the analyzed data to generate an encapsulated data packet.

In step S250, the encapsulated data packet is sent to the logistics data server through the communication link between the intermediate server and the logistics data server.

In one embodiment, the intermediate server sends the encapsulated data packet to the logistics data server through the communication link between the intermediate server and the logistics data server. Specifically, it can be based on the communication link between the intermediate server and the logistics data server. The corresponding sending port is used to send the encapsulated data packet to the logistics data server.

FIG. 5 schematically shows a specific flow chart of step S250 according to an embodiment of the present application. Referring to FIG. 5 , step S250 may include steps S510 to S530, which are described in detail as follows.

In step S510, a write message packet is generated according to the encapsulated data packet.

In step S520, the write message package is added to the message sending queue.

In step S530, the write message package contained in the message sending queue is sent to the logistics data server through the communication link between the intermediate server and the logistics data server.

In one embodiment, when the intermediate server sends the encapsulated data packet to the logistics data server, it will generate a corresponding write message packet according to the encapsulated data packet as the data packet to be sent. The intermediate server adds all the generated message packets to the message sending queue, and sends all the written message packets in the message sending queue to the logistics data server through the message sending thread.

Specifically, the intermediate server sends the write message package contained in the message sending queue to the logistics data server through a communication link that communicates with the logistics data server.

By generating a write message packet based on the encapsulated data packet, and adding the generated write message packet to the message sending queue, the intermediate server can effectively send the write messages corresponding to multiple intelligent logistics devices to the Logistic data server, to avoid missing write message packets.

FIG. 6 schematically shows a flow chart of a data processing method according to an embodiment of the present application. Referring to FIG. 6, the step of sending the write message package contained in the message sending queue to the logistics data server may specifically be It includes step S610 to step S630, which is described in detail as follows.

In step S610, the priority of each written message packet in the message sending queue is determined according to the content of the written message packet.

In one embodiment, when the intermediate server sends the write message packets contained in the message sending queue to the logistics data server, it will determine the priority of each write message packet in the message sending queue according to the content of the write message packets. For the write message packets that use different function types, their corresponding priorities are different. For example, the priority corresponding to the write message packets of the warning prompt type or the device maintenance type is high, such as the write message packets of the data storage type. low priority. Optionally, the priority of writing message packets can be specifically divided into three levels: high priority, medium priority, and low priority. Of course, it can also be divided into three or more levels of priority according to requirements.

Optionally, when determining the priority of each written message packet in the message sending queue according to the content of the written message packet, it may be based on the specific field contained in the content of the written message packet, and the specific field and priority The corresponding relationship determines the priority of each write message packet.

In step S620, based on the priority of each written message packet, the sending order of each written message packet in the message sending queue is determined.

In one embodiment, based on the priority of each written message packet, when determining the sending sequence of each written message packet in the message sending queue, the corresponding sending sequence of the written message packet with higher priority is higher. It should be pointed out that for two write message packages with the same priority, the sending order can be determined according to the time when the write message package is added to the message sending queue, such as the write message package added to the message sending queue earlier The corresponding sending order comes first.

In step S630, the write message packets in the message sending queue are sequentially sent to the logistics data server based on the sending order.

In one embodiment, the intermediate server sequentially sends the write message packets in the message sending queue to the logistics data server based on the sending order, so as to realize sending the write message packets in the message sending queue to the logistics data server.

In the technical solution of the embodiment shown in Figure 6, based on the priority of each written message packet, the sending order of each written message packet in the message sending queue is determined, and it can be realized that according to the importance of each written message packet, priority will be given to the important A high-level write message package is sent to the logistics data server to meet more complex business scenarios and improve the applicable scenarios of the solution.

The following introduces device embodiments of the present application, which can be used to implement the data processing method in the above-mentioned embodiments of the present application. For the details not disclosed in the device embodiments of the present application, please refer to the above-mentioned embodiments of the data processing method in the present application.

Fig. 7 schematically shows a block diagram of a data processing device according to an embodiment of the present application. Referring to FIG. 7 , a data processing device 700 according to an embodiment of the present application includes: a detection unit 710 , an execution unit 720 , an analysis unit 730 , an encapsulation unit 740 and a sending unit 750 .

Wherein, the detection unit 710 is configured to detect the communication link type between the intermediate server and the target intelligent logistics device in response to the data packet from the target intelligent logistics device; the execution unit 720 is configured to The type of the communication link between the target intelligent logistics equipment, and determine the target communication protocol adopted by the data packet during transmission; the parsing unit 730 is used to parse the data packet based on the target communication protocol, and obtain the parsed data The encapsulation unit 740 is used to encapsulate the analyzed data according to the communication protocol corresponding to the communication link type between the intermediate server and the logistics data server, and generate an encapsulated data packet; the sending unit 750 and sending the encapsulated data packet to the logistics data server through the communication link between the intermediate server and the logistics data server.

In one embodiment of the present application, the detection unit 710 includes: a detection subunit, configured to detect the target receiving port number that receives the data packet; a first execution subunit, configured to , and the corresponding relationship between the port number and the communication link type, determine the communication link type between the intermediate server and the target intelligent logistics device.

In one embodiment of the present application, the execution unit 720 includes: an acquisition subunit, configured to acquire the equipment type of the target intelligent logistics equipment; a first generation subunit, configured to obtain the equipment type of the target intelligent logistics equipment; type and the type of communication link between the intermediate server and the target intelligent logistics equipment, generate target environment configuration information; the second execution subunit is used to generate target environment configuration information based on the target environment configuration information, environment configuration information and communication protocol The corresponding relationship among them determines the target communication protocol adopted by the data packet during transmission.

In one embodiment of the present application, the sending unit 750 includes: a second generating subunit, configured to generate a write message packet according to the encapsulated data packet; an adding subunit, configured to write The message package is added to the message sending queue; the sending subunit is configured to send the write message package contained in the message sending queue to the Logistics data server.

In one embodiment of the present application, the sending unit 750 includes: the sending subunit is specifically configured to determine the priority of each written message packet in the message sending queue according to the content of the written message packet; the priority of incoming message packets, and determine the sending order of each written message packet in the message sending queue; based on the sending order, send the written message packets in the message sending queue to the logistics data server in turn

FIG. 8 shows a schematic structural diagram of a computer system suitable for implementing the electronic device of the embodiment of the present application.

It should be noted that the computer system 800 of the electronic device shown in FIG. 8 is only an example, and should not limit the functions and scope of use of the embodiments of the present application.

As shown in FIG. 8, a computer system 800 includes a central processing unit (Central Processing Unit, CPU) 801, which can be stored in a program in a read-only memory (Read-Only Memory, ROM) 802 or loaded from a storage part 808 to a random It accesses the programs in the memory (Random Access Memory, RAM) 803 to execute various appropriate actions and processes, for example, executes the methods described in the above-mentioned embodiments. In RAM 803, various programs and data necessary for system operation are also stored. The CPU 801 , ROM 802 , and RAM 803 are connected to each other via a bus 1504 . An input/output (Input/Output, I/O) interface 805 is also connected to the bus 804 .

The following components are connected to the I/O interface 805: an input section 806 including a keyboard, a mouse, etc.; an output section 807 including a cathode ray tube (Cathode Ray Tube, CRT), a liquid crystal display (Liquid Crystal Display, LCD), etc., and a speaker ; a storage section 808 including a hard disk or the like; and a communication section 809 including a network interface card such as a LAN (Local Area Network) card, a modem, or the like. The communication section 809 performs communication processing via a network such as the Internet. A drive 810 is also connected to the I/O interface 805 as needed. A removable medium 811, such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, etc., is mounted on the drive 810 as necessary so that a computer program read therefrom is installed into the storage section 808 as necessary.

In particular, according to the embodiments of the present application, the processes described below with reference to the flowcharts can be implemented as computer software programs. For example, the embodiments of the present application include a computer program product, which includes a computer program carried on a computer-readable medium, where the computer program includes program codes for executing the methods shown in the flowcharts. In such an embodiment, the computer program may be downloaded and installed from a network via communication portion 809 and/or installed from removable media 811 . When this computer program is executed by a central processing unit (CPU) 801, various functions defined in the system of the present application are performed.

It should be noted that the computer-readable medium shown in the embodiment of the present application may be a computer-readable signal medium or a computer-readable storage medium, or any combination of the two. A computer readable storage medium may be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, device, or device, or any combination thereof. More specific examples of computer-readable storage media may include, but are not limited to, electrical connections with one or more wires, portable computer diskettes, hard disks, random access memory (RAM), read-only memory (ROM), erasable Programmable Read-Only Memory (Erasable Programmable Read Only Memory, EPROM), flash memory, optical fiber, portable compact disk read-only memory (Compact Disc Read-Only Memory, CD-ROM), optical storage device, magnetic storage device, or any suitable The combination. In this application, a computer-readable storage medium may be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device. In this application, however, a computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, in which computer-readable program codes are carried. Such propagated data signals may take many forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A computer-readable signal medium may also be any computer-readable medium other than a computer-readable storage medium, which can send, propagate, or transmit a program for use by or in conjunction with an instruction execution system, apparatus, or device. . Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wired, etc., or any suitable combination of the above.

The flowchart and block diagrams in the Figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present application. In this regard, each block in a flowchart or block diagram may represent a module, program segment, or portion of code that includes one or more logical functions for implementing specified executable instructions. It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or they may sometimes be executed in the reverse order, depending upon the functionality involved. It should also be noted that each block in the block diagrams or flowchart illustrations, and combinations of blocks in the block diagrams or flowchart illustrations, can be implemented by a dedicated hardware-based system that performs the specified function or operation, or can be implemented by a A combination of dedicated hardware and computer instructions.

The units described in the embodiments of the present application may be implemented by software or by hardware, and the described units may also be set in a processor. Wherein, the names of these units do not constitute a limitation of the unit itself under certain circumstances.

As another aspect, the present application also provides a computer-readable medium. The computer-readable medium may be included in the electronic device described in the above embodiments; it may also exist independently without being assembled into the electronic device. middle. The above-mentioned computer-readable medium carries one or more programs, and when the above-mentioned one or more programs are executed by an electronic device, the electronic device is made to implement the methods described in the above-mentioned embodiments.

It should be noted that although several modules or units of the device for action execution are mentioned in the above detailed description, this division is not mandatory. Actually, according to the embodiment of the present application, the features and functions of two or more modules or units described above may be embodied in one module or unit. Conversely, the features and functions of one module or unit described above can be further divided to be embodied by a plurality of modules or units.

Through the description of the above implementations, those skilled in the art can easily understand that the example implementations described here can be implemented by software, or by combining software with necessary hardware. Therefore, the technical solutions according to the embodiments of the present application can be embodied in the form of software products, which can be stored in a non-volatile storage medium (which can be CD-ROM, U disk, mobile hard disk, etc.) or on the network , including several instructions to make a computing device (which may be a personal computer, server, touch terminal, or network device, etc.) execute the method according to the embodiment of the present application.

Other embodiments of the application will be readily apparent to those skilled in the art from consideration of the specification and practice of the application disclosed herein. This application is intended to cover any modification, use or adaptation of the present invention, these modifications, uses or adaptations follow the general principles of the application and include common knowledge or conventional technical means in the technical field not disclosed in the application .

It should be understood that the present application is not limited to the precise constructions which have been described above and shown in the accompanying drawings, and various modifications and changes may be made without departing from the scope thereof. The scope of the application is limited only by the appended claims.

Claims (6)

1. A data processing method applied to an intermediate server connected with a logistics data server, comprising:

detecting a communication link type between the intermediate server and the target intelligent logistics equipment in response to a data packet from the target intelligent logistics equipment; the target intelligent logistics equipment comprises logistics equipment for realizing sorting, carrying or storing functions;

acquiring the equipment identifier of the target intelligent logistics equipment, and determining the equipment type of the target intelligent logistics equipment according to the equipment identifier of the target intelligent logistics equipment;

generating target environment configuration information according to the equipment type of the target intelligent logistics equipment and the communication link type between the intermediate server and the target intelligent logistics equipment;

searching in a corresponding relation between pre-stored environment configuration information and a communication protocol according to the target environment configuration information as an index, and determining a target communication protocol adopted by the data packet from the target intelligent logistics equipment during transmission;

analyzing the data packet based on an analysis function corresponding to the target communication protocol to obtain analyzed data;

encapsulating the parsed data according to a communication protocol corresponding to a pre-agreed communication link type between the intermediate server and the logistics data server to generate an encapsulated data packet;

generating a writing message packet according to the encapsulated data packet;

adding the write message packet to a message sending queue;

transmitting all write message packets in a message transmission queue to the logistics data server through a communication link between the intermediate server and the logistics data server by a thread for transmitting messages;

transmitting all write message packets in the message transmission queue to the logistics data server, including:

determining the priority of each written message packet in the message sending queue according to the content of the written message packet; the writing message packets with different function types have different corresponding priorities, and specifically include: the write-in message packet of the warning prompt type or the equipment maintenance type has high corresponding priority, and the write-in message packet of the data storage type has low corresponding priority;

determining the sending sequence of each written message packet in the message sending queue based on the priority of each written message packet; wherein, the sending sequence corresponding to the writing message packet with high priority is forward; for two writing message packets with the same priority, determining a sending sequence according to the time of adding the writing message packets to a message sending queue, wherein the sending sequence corresponding to the writing message packet with earlier time added to the message sending queue is earlier;

and sequentially transmitting the written message packets in the message transmission queue to the logistics data server based on the transmission sequence.

2. The data processing method according to claim 1, wherein the detecting the type of the communication link between the intermediate server and the target smart logistics device comprises:

detecting a target receiving port number for receiving the data packet;

and determining the communication link type between the intermediate server and the target intelligent logistics equipment based on the target receiving port number and the corresponding relation between the port number and the communication link type.

3. A data processing apparatus, comprising:

the detection unit is used for responding to the data packet from the target intelligent logistics equipment and detecting the type of a communication link between the intermediate server and the target intelligent logistics equipment; the target intelligent logistics equipment comprises logistics equipment for realizing sorting, carrying or storing functions;

the execution unit is used for acquiring the equipment identifier of the target intelligent logistics equipment and determining the equipment type of the target intelligent logistics equipment according to the equipment identifier of the target intelligent logistics equipment; generating target environment configuration information according to the equipment type of the target intelligent logistics equipment and the communication link type between the intermediate server and the target intelligent logistics equipment; searching in a corresponding relation between pre-stored environment configuration information and a communication protocol according to the target environment configuration information as an index, and determining a target communication protocol adopted by the data packet from the target intelligent logistics equipment during transmission;

the analysis unit is used for analyzing the data packet based on an analysis function corresponding to the target communication protocol to obtain analyzed data;

the packaging unit is used for packaging the analyzed data according to a communication protocol corresponding to a preset communication link type between the intermediate server and the logistics data server, and generating a packaged data packet;

a sending unit, configured to generate a write-in message packet according to the encapsulated data packet; adding the write message packet to a message sending queue; transmitting all write message packets in a message transmission queue to the logistics data server through a communication link between the intermediate server and the logistics data server by a thread for transmitting messages;

the transmitting unit is further configured to:

determining the priority of each written message packet in the message sending queue according to the content of the written message packet; the writing message packets with different function types have different corresponding priorities, and specifically include: the write-in message packet of the warning prompt type or the equipment maintenance type has high corresponding priority, and the write-in message packet of the data storage type has low corresponding priority; determining the sending sequence of each written message packet in the message sending queue based on the priority of each written message packet; wherein, the sending sequence corresponding to the writing message packet with high priority is forward; for two writing message packets with the same priority, determining a sending sequence according to the time of adding the writing message packets to a message sending queue, wherein the sending sequence corresponding to the writing message packet with earlier time added to the message sending queue is earlier; and sequentially transmitting the written message packets in the message transmission queue to the logistics data server based on the transmission sequence.

4. A data processing apparatus according to claim 3, wherein the detection unit comprises:

a detection subunit, configured to detect a target receiving port number that receives the data packet;

and the first execution subunit is used for determining the communication link type between the intermediate server and the target intelligent logistics equipment based on the target receiving port number and the corresponding relation between the port number and the communication link type.

5. An electronic device, comprising:

one or more processors;

storage means for storing one or more programs which when executed by the one or more processors cause the one or more processors to implement the data processing method of any of claims 1 to 2.

6. A computer readable medium on which a computer program is stored, characterized in that the computer program, when being executed by a processor, implements the data processing method according to any one of claims 1 to 2.