CN108173902A - Data transmission, publication and method for subscribing and device - Google Patents

Abstract

This application discloses a kind of data transmission, publication and method for subscribing, for solving the problems, such as that the data transmission in the prior art between data publication side and subscriber does not ensure reliability.This method includes：Receive the first data that data publication side is sent；Determine the data type of first data；According to the mapping relations between the data publication side, data subscription side and the data type pre-established, data subscription side corresponding with the data type of first data is determined；First data are sent to the data subscription side.Disclosed herein as well is a kind of data transmission, publication and subscribe to device.

Description

Data transmission, publication and subscription method and device

technical field

The present application relates to the technical field of wireless communication, and in particular to a data transmission, publishing and subscribing method and device.

Background technique

With the rapid development of Internet of Things technology, various types of sensors are spread in every corner of the real world. These sensors can detect earthquakes, electromagnetics, temperature, humidity, noise, light intensity, pressure, soil composition, size, speed and Various physical quantities in the surrounding environment such as directions. These physical quantities detected by sensors have a wide range of application backgrounds in military detectives, environmental detection, industrial monitoring, activity perception, and health care.

At present, with the development of the mobile Internet, the network formed by these sensors can serve as a data publisher and provide these data for data subscribers who need to use these data. When the data subscriber wants to obtain some sensory data, it can send a subscription request to the data publisher to obtain the data detected by these sensors.

In the above scenario, after receiving the data subscription request from the data subscriber, the data publisher often only sends the data related to the data subscription request to the data subscriber according to the data subscription request of the data subscriber, without guaranteeing data transmission reliability, which will cause some data such as alarm data may not be received by data subscribers.

Contents of the invention

The embodiments of the present application provide methods and devices for data transmission, publication and subscription, which are used to solve the problem in the prior art that data transmission between a data publisher and a data subscriber does not guarantee reliability.

The embodiment of the application adopts the following technical solutions:

A data transmission method, the method being applied to a server, comprising:

receiving the first data sent by the data publisher;

determining the data type of the first data;

determining a data subscriber corresponding to the data type of the first data according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type;

Send the first data to the data subscriber.

A method for publishing data, said method being applied to a data publisher, comprising:

Receive the data subscription request sent by the server;

Sending first data matching the data type included in the data subscription request to the server.

A method for publishing data, said method being applied to a data publisher, comprising:

Receive the data subscription request sent by the server;

Sending first data matching the data type contained in the data subscription request to the server.

A server comprising:

a receiving unit, configured to receive the first data sent by the data publisher;

a first determining unit, configured to determine the data type of the first data;

The second determining unit is configured to determine the data subscriber corresponding to the data type of the first data according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type;

A first sending unit, configured to send the first data to the data subscriber.

A data publishing device, comprising:

a receiving unit, configured to receive a data subscription request sent by the server;

A sending unit, configured to send the first data matching the data type included in the data subscription request to the server.

A data subscription device, comprising:

a sending unit, configured to send a data subscription request to the server;

The receiving unit is configured to receive the first data sent by the server and matching the data type included in the data subscription request.

The above at least one technical solution adopted in the embodiment of the present application can achieve the following beneficial effects:

In this application, the server can first receive the first data sent by the data publisher, determine the data type of the first data, and determine the data type of the first data according to the pre-established mapping relationship between the data publisher, data subscriber and data type. The data subscriber corresponding to the data type, and then send the first data to the data subscriber. Since the first data sent by the data publisher can be forwarded to the data subscriber through the server, the relationship between the data publisher and the data subscriber is guaranteed. Reliability of data transmission.

In this application, the data publisher can receive the data subscription request sent by the server, and then send the first data matching the data type contained in the subscription request to the server, because the server can forward the first data sent by the data publisher to the data The subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

In this application, the data subscriber can send a data subscription request to the server, and then receive the first data sent by the server that matches the data type contained in the data subscription request, because the server can forward the first data sent by the data publisher to the The data subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

Description of drawings

The drawings described here are used to provide a further understanding of the application and constitute a part of the application. The schematic embodiments and descriptions of the application are used to explain the application and do not constitute an improper limitation to the application. In the attached picture:

FIG. 1 is a schematic diagram of the implementation flow of the data transmission method provided by the embodiment of the present application;

Fig. 2 is a schematic diagram of the application of the data transmission method provided by this application in an actual scene;

FIG. 3 is a schematic diagram of the implementation flow of the data release method provided by the embodiment of the present application;

FIG. 4 is a schematic diagram of the implementation flow of the data subscription method provided by the embodiment of the present application;

5 is a schematic diagram of the process of data transmission in the method provided by the embodiment of the present application;

6 is a schematic diagram of the process of data transmission with service level 0 in the method provided by the embodiment of the present application;

7 is a schematic diagram of the process of data transmission with service level 1 in the method provided by the embodiment of the present application;

FIG. 8 is a schematic diagram of the process of data transmission with service level 2 in the method provided by the embodiment of the present application;

FIG. 9 is a schematic structural diagram of a server provided by an embodiment of the present application;

FIG. 10 is a schematic structural diagram of a data release device provided by an embodiment of the present application;

FIG. 11 is a schematic structural diagram of a data subscription device provided by an embodiment of the present application;

FIG. 12 is a schematic structural diagram of the data subscription and publishing system provided by the embodiment of the present application.

Detailed ways

In order to make the purpose, technical solution and advantages of the present application clearer, the technical solution of the present application will be clearly and completely described below in conjunction with specific embodiments of the present application and corresponding drawings. Apparently, the described embodiments are only some of the embodiments of the present application, rather than all the embodiments. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the scope of protection of this application.

The technical solutions provided by various embodiments of the present application will be described in detail below in conjunction with the accompanying drawings.

In order to solve the problem in the prior art that the reliability of data transmission between the data publisher and the subscriber is not guaranteed, this embodiment of the application provides a data transmission method, the execution subject of this method can be a server, or any Applies to the means provided by the method. In the following, taking the execution subject of the method as an example, the implementation of the method will be introduced in detail. It can be understood that the execution subject of the method is a server is only an exemplary description, and should not be understood as an explanation of the method. limited.

As shown in Figure 1, it is a schematic diagram of the implementation process of the data transmission method provided by the embodiment of the present application applied to the server, including:

Step 11, receiving the first data sent by the data publisher;

As mentioned in the background technology, in the prior art, the reliability of data transmission is not guaranteed during the data transmission process between the data publisher and the data subscriber, which will cause some important data may not be subscribed by the data The party received, in order to solve this problem, the data subscription and publishing method provided by the embodiment of the present application can receive the first data sent by the data publishing through the server, which ensures the reliability of the first data transmission.

Specifically, the first data may be data that a data subscriber requests to subscribe, for example, may include sensory data in a network formed by sensors, such as sensory data such as temperature, humidity, and light intensity. As shown in Figure 2, it is a schematic diagram of the application of the data subscription and publishing method provided by the embodiment of the present application in the actual scene, including the data publisher: on-site intelligent monitoring unit 1 ~ on-site intelligent monitoring unit 3, server (storage publisher status table also It is the status table of the data publisher, the subscription/publishing relationship table (that is, the mapping relationship and service level filtering table described below), and the data subscriber: centralized monitoring center 1 and centralized monitoring center 2.

In Fig. 2, the data publishers, that is, the on-site intelligent monitoring unit 1 to the on-site intelligent monitoring unit 3 are responsible for the collection and monitoring of sensing data in the network formed by monitoring sensors, and the server is responsible for the data transmission between the data subscriber and the data publisher , the data subscribers, that is, the centralized monitoring center 1 and the centralized monitoring center 2 are responsible for monitoring the sensory data they care about, that is, monitoring the sensory data they request to subscribe to.

Step 12, determining the data type of the first data;

It should be understood that the types of data requested by different data subscribers are often different. For example, in a network formed by multiple sensors, some data subscribers may mainly focus on temperature and humidity, while others may mainly focus on whether Therefore, after receiving the first data, the data type of the first data can also be determined. The data type of the first data can be various types of sensor data, such as temperature sensor data collected by a temperature sensor. The data, or the humidity sensing data collected by the humidity sensor, can also be the light intensity sensing data collected by the light intensity sensor, etc., and other types of sensing data.

Step 13, according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type, determine the data subscriber corresponding to the data type of the first data;

As mentioned above, the data types requested by different data subscribers are often different. Therefore, after the data type of the first data is determined, it can be based on the pre-established mapping between data publishers, data subscribers and data types. relationship, and determine the data subscriber corresponding to the data type of the first data, so as to provide different data subscribers with the data they request to subscribe to.

Optionally, the establishment of the mapping relationship between the data publisher, the data subscriber and the data type can firstly receive the subscription request sent by the data subscriber; then, according to the subscription request, determine the data type and data contained in the subscription request Subscriber's address information; then according to the data type, determine the data publisher that matches the data type; finally establish the mapping relationship between the data publisher, data subscriber and data type. In some cases, when the data subscriber no longer requests to subscribe to a certain type of data, it can also send a subscription request to the server to unsubscribe from a certain type of data. After receiving the unsubscribe request, the server can cancel the previous The established mapping relationship between the data publisher, the data subscriber and the data type.

Optionally, usually, when monitoring the environment, in order to reduce the energy consumption of the data publisher, the data publisher in the embodiment of the present application may include two states: an offline state and an online state, where the offline state may be The data publisher is in a dormant state, and the online state may be that the data publisher is in a working state. When the status of the data publisher includes an offline status and an online status, before receiving the first data sent by the data publisher, if it is determined that the status of the data publisher is an online status, a subscription request is sent to the data publisher to Causes the data publisher to send data corresponding to the data type contained in the subscription request.

Step 14, sending the first data to the data subscriber;

After the data subscriber requesting to subscribe to the first data is determined, the first data may be sent to the data subscriber to satisfy the data subscription request of the data subscriber.

In addition, in order to release the space of the server in time, if it is determined that the service level of the first data is a preset service level, a data publishing completion message is sent to the data publisher to prompt the data publisher to delete the first data. Wherein, the preset service level includes the first level and the second level. When it is determined that the preset service level is the first level, after receiving the first data sent by the data publisher, the first data can also be stored; After the first data is sent to the data subscriber, in order to ensure the reliability of the first data transmission, the first data publishing message can also be sent to the data publisher; optionally, in order to release the space of the server in time, if the data publisher receives If the release message is sent, the first data is deleted.

The first-level data may be some alarm data in the embodiment of the present application. For example, when the data publisher determines that the data it collects is greater than or less than a preset threshold value, it can send the alarm data to the server. After receiving the alarm data, the service level of the alarm data can be determined according to the service level identifier contained in the alarm data. In order to ensure that the data subscriber can receive the alarm data, the server can first store the alarm data, and After the alarm data is sent to the data subscriber, first send the alarm data publishing message to the data publisher to indicate that the alarm data has been sent to the data subscriber, and then delete the first alarm data when receiving the release message sent by the data publisher. data to free up storage space on the server.

It should be understood that, in order to reduce the data redundancy of the data publisher, when it is determined that the preset service level is the second level, it only needs to send a data publishing completion message to the data publisher, so that the data publisher deletes the first data. The second level of data may be the status change data of the data publisher in this embodiment of the application, for example, when the status of the data publisher changes from offline to online or from online to offline, in order to facilitate the server to Obtain its state change, and the data publisher can send its state change data to the server.

In this application, the server can first receive the first data sent by the data publisher, determine the data type of the first data, and determine the data type of the first data according to the pre-established mapping relationship between the data publisher, data subscriber and data type. The data subscriber corresponding to the data type, and then send the first data to the data subscriber. Since the first data sent by the data publisher can be forwarded to the data subscriber through the server, the relationship between the data publisher and the data subscriber is guaranteed. Reliability of data transmission.

As shown in Figure 3, it is a schematic diagram of the implementation flow of the data release method provided by the embodiment of the present application, including:

Step 21, receiving the data subscription request sent by the server;

As mentioned above, in order to reduce the power consumption of the data publisher, the status of the data publisher can include offline status and online status. When the status of the data publisher includes offline status and online status, the data subscription sent by the server is received. The request, specifically, may receive a data subscription request sent by the server when the status of the data publisher is online.

Step 22, sending the first data matching the data type included in the data subscription request to the server;

Optionally, after sending the first data that matches the data type contained in the data subscription request to the server, if a data release message sent by the server is received, send a release message to the server to prompt the server Delete the first data.

In addition, in order to reduce excessive data redundancy generated by the data publisher, if the message that the data publishing is completed is received from the server, the first data is deleted.

In this application, the data publisher can receive the data subscription request sent by the server, and then send the first data matching the data type contained in the subscription request to the server, because the server can forward the first data sent by the data publisher to the data The subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

As shown in Figure 4, it is a schematic diagram of the implementation flow of the data subscription method provided by the embodiment of this application, including:

Step 31, sending a data subscription request to the server;

Step 32, receiving the first data sent by the server and matching the data type contained in the data subscription request.

In this application, the data subscriber can send a data subscription request to the server, and then receive the first data sent by the server that matches the data type contained in the data subscription request, because the server can forward the first data sent by the data publisher to the The data subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

The following is a schematic diagram of the application of the data subscription and publishing method provided by the application shown in Figure 2 as an example to introduce the method in detail. The server shown in Figure 2 stores the publisher status table, which is the data The publisher's status table, subscription/publishing relationship table is the above-mentioned mapping relationship and service level filtering table. In practical applications, the server can be a message based on the Message Queuing Telemetry Transport (MQTT) protocol Proxy server, in which the MQTT protocol adopts a lightweight subscription/publishing mode for message transmission.

MQTT is specially optimized for low bandwidth, low computing power, and unstable network environments. It can be applied to message push for embedded smart terminals and mobile terminals, and can effectively save terminal power consumption and traffic. There are three Message data publishing service quality:

(1) "At most one time", message data publishing completely depends on the underlying TCP/IP network. Message data loss or duplication can occur. This level can be used in the following situations, environmental sensor data, it does not matter if a read record is lost, because there will be a second send in the near future. In the embodiment of the present application, the "at most one time" may be the environmental sensing data collected periodically by the data issuer.

(2) "at least once", to ensure that the message arrives, but message duplication may occur. In this embodiment of the application, the data of the service level may be status change data of the data issuer.

(3) "Only once", to ensure that the message arrives once. This level can be used in cases where duplicate or missing messages can lead to incorrect results in billing systems. In this embodiment of the present application, the data of the service level may be the alarm data sent by the data issuer.

As shown in Figure 5, it is a schematic diagram of the process of data transmission in the data subscription and publishing method provided by the embodiment of the present application, including the following steps:

Step a, the data publishing direction sends the state change data to the server;

Step b, after the server receives the state change data, it modifies the state table of the data issuer;

Step c, the server receives the data subscription request sent by the data subscriber;

Step d, the server verifies the data subscription request, and after the data subscription request is verified, adds the data subscription request to the subscription list, which stores the address information of the data subscriber, the type of data to be subscribed, and The mapping relationship between data publishers that can provide the data type;

Step e, the server sends a subscription request response to the data subscriber to remind the data subscriber that the data subscription request has been successfully sent and passed the verification;

Step f, the server queries the status list of the data publisher;

Step g, when the server determines that the status of the data publisher corresponding to the data requested by the data subscriber is online, send its data subscription request to the data publisher corresponding to the data requested by the data subscriber;

Step h, the data publisher sends the first data to the server, and the first data is the data corresponding to the data requested by the data subscriber;

Step i, the server receives the first data, and queries the subscription list to determine which data subscribers request to subscribe to the first data;

Step j, the server sends the first data to the data subscriber who requests to subscribe to the first data;

Step k, when the data subscriber wants to cancel the data subscription request sent before, it can send an unsubscribe request to the server, and the unsubscribe request includes the address information of the data subscriber and the type of data to be unsubscribed ;

Step 1, after the server receives the request for unsubscribing, according to the address information of the data subscriber included in the request for unsubscribing and the type of data to be unsubscribed, the server can store the information in the subscription list that is related to the data subscriber. The mapping relationship between the address information, the data type that you want to unsubscribe, and the data publisher that can provide the data type is released;

In step m, the server sends an unsubscribe response to the data subscriber to prompt the data subscriber that the unsubscribe request takes effect.

Since the data transmitted between the data publisher and the data subscriber in the embodiment of the present application may include three service levels, that is, periodic sensing data (the service level of this type of data may be set to 0 in this application), The status change data of the data publisher (the service level of this type of data can be set to 1 in this application) and the alarm data of the data publisher (the service level of this type of data can be set to 2 in this application).

As shown in Figure 6, it is a schematic diagram of the data transmission process with a service level of 0. During the data transmission process, after the data publisher sends the data with a service level of 0 to the server, the server only needs to send the data to the request to subscribe to the The data subscriber of the data, and the data publisher can discard the data after sending the data to reduce data redundancy.

Figure 7 is a schematic diagram of the data transmission process with service level 1. During the data transmission process, the data publisher first stores the data to be sent locally, and then sends the data with service level 1 to the server, and the server sends the data to the server. After the data is sent to the data subscriber who requested to subscribe to the data, in order to ensure the reliability of data transmission, it can also send a release data response to the data publisher to remind that the data has been sent to the data subscriber. The data it stores is discarded only after the Publish Data Response.

Figure 8 is a schematic diagram of the process of data transmission with service level 2. During the data transmission process, the data publisher first stores the data to be sent locally, and then sends the data with service level 2 to the server. After receiving the data, first store the data locally, and then send the data to the data subscriber who requests to subscribe to the data, in order to ensure the reliability of data transmission, you can also send the received message to the data publisher to Prompt that the data has been sent to the data subscriber. After receiving the message received by the publication, the data publisher sends a release message to the server to remind the server that it can discard the stored data. After the server receives the release message Afterwards, the stored data is discarded, and after discarding the stored data, a release completion message is sent to the data publisher, and the data publisher discards the stored data only after receiving the release completion message.

In order to solve the problem in the prior art that the data transmission between the data publisher and the subscriber does not guarantee reliability, the embodiment of the present application also provides a server 40, as shown in FIG. 9 , including the following functional units:

a receiving unit 41, configured to receive the first data sent by the data publisher;

A first determining unit 42, configured to determine the data type of the first data;

The second determination unit 43 is configured to determine the data subscriber corresponding to the data type of the first data according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type;

The first sending unit 44 is configured to send the first data to the data subscriber.

In one embodiment, the server also includes:

The second sending unit 45 is configured to send a data publishing completion message to the data publisher if it is determined that the service level of the first data is a preset service level, so that the data publisher deletes the first data. data.

In one embodiment, the preset service level includes a first level and a second level, and when it is determined that the preset service level is the first level, the receiving unit 41 receives the After the first data, the apparatus further includes:

The storage unit 46 is configured to store the first data.

After the first sending unit 44 sends the first data to the data subscriber, the device further includes:

A third sending unit 47, configured to send a first data publishing message to the data publishing party;

A deleting unit 48, configured to delete the first data if the release release message sent by the data publisher is received.

In one embodiment, the mapping relationship between the data publisher, the data subscriber and the data type is established through the following functional units:

The first receiving unit 49 is configured to receive a subscription request sent by a data subscriber;

The third determining unit 410 is configured to determine the type of data contained in the subscription request and the address information of the data subscriber according to the subscription request;

A fourth determining unit 411, configured to determine a data publisher matching the data type according to the data type;

The establishment unit 412 is configured to establish a mapping relationship between the data publisher, the data subscriber and the data type.

In one embodiment, when the state of the data publisher includes an offline state and an online state, before the receiving unit 41 receives the first data sent by the data publisher, the device further includes:

The fourth sending unit 413 is configured to send the subscription request to the data publisher if it is determined that the status of the data publisher is online, so that the data publisher sends the subscription request contained in the subscription request. The corresponding data of the data type.

In this application, the server can first receive the first data sent by the data publisher, determine the data type of the first data, and determine the data type of the first data according to the pre-established mapping relationship between the data publisher, data subscriber and data type. The data subscriber corresponding to the data type, and then send the first data to the data subscriber. Since the first data sent by the data publisher can be forwarded to the data subscriber through the server, the relationship between the data publisher and the data subscriber is guaranteed. Reliability of data transmission.

In order to solve the problem in the prior art that the data transmission between the data publisher and the subscriber does not guarantee reliability, the embodiment of the present application also provides a data publishing device 50, as shown in FIG. 10 , including the following functional units:

A receiving unit 51, configured to receive a data subscription request sent by the server;

A sending unit 52, configured to send first data matching the data type included in the data subscription request to the server.

In one embodiment, the device also includes:

The deleting unit 53 is configured to delete the first data if receiving the message that the data publishing is completed sent by the server.

In one embodiment, the device also includes:

The first sending unit 54 is configured to send a release release message to the server if the data release received message sent by the server is received, so that the server deletes the first data.

In one embodiment, when the state of the data publisher includes an offline state and an online state, the receiving unit 51 is configured to:

When the status of the data publisher is the online status, the data subscription request sent by the server is received.

In this application, the data publisher can receive the data subscription request sent by the server, and then send the first data matching the data type contained in the subscription request to the server, because the server can forward the first data sent by the data publisher to the data The subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

In order to solve the problem in the prior art that the data transmission between the data publisher and the subscriber does not guarantee reliability, the embodiment of the present application also provides a data subscription device 60, as shown in Figure 11, including the following functional units:

A sending unit 61, configured to send a data subscription request to a server;

The receiving unit 62 is configured to receive the first data sent by the server and matching the data type included in the data subscription request.

In this application, the data subscriber can send a data subscription request to the server, and then receive the first data sent by the server that matches the data type contained in the data subscription request, because the server can forward the first data sent by the data publisher to the The data subscriber can guarantee the reliability of data transmission between the data publisher and the data subscriber.

In order to solve the problem in the prior art that the data transmission between the data publisher and the subscriber does not guarantee reliability, the embodiment of the present application also provides a data subscription and publishing system 70, as shown in FIG. 12 , including a server 71, a data Publishing means 72 and data subscribing means 73, wherein,

The data subscription device 73 is configured to send a data subscription request to the server 71;

receiving the first data sent by the server 71 that matches the data type contained in the data subscription request;

The data publishing device 72 is configured to receive the data subscription request sent by the server 71;

sending to the server 71 first data matching the data type contained in the data subscription request;

The server 71 is configured to receive the first data sent by the data publishing device 72;

determining the data type of the first data;

Determine the data subscription device 73 corresponding to the data type of the first data according to the pre-established mapping relationship between the data publishing device 72, the data subscription device 73 and the data type;

Send the first data to the data subscription device 73 .

Those skilled in the art should understand that the embodiments of the present application may be provided as methods, systems, or computer program products. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

The present application is described with reference to the flowcharts and/or block diagrams of the methods, devices (systems), and computer program products of the embodiments of the present application. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing equipment produce a An apparatus for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow chart or blocks of the flowchart and/or the block or blocks of the block diagrams.

In a typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.

Memory may include non-permanent storage in computer readable media, in the form of random access memory (RAM) and/or nonvolatile memory such as read only memory (ROM) or flash RAM. Memory is an example of computer readable media.

Computer-readable media, including both permanent and non-permanent, removable and non-removable media, can be implemented by any method or technology for storage of information. Information may be computer readable instructions, data structures, modules of a program, or other data. Examples of computer storage media include, but are not limited to, phase change memory (PRAM), static random access memory (SRAM), dynamic random access memory (DRAM), other types of random access memory (RAM), read only memory (ROM), Electrically Erasable Programmable Read-Only Memory (EEPROM), Flash memory or other memory technology, Compact Disc Read-Only Memory (CD-ROM), Digital Versatile Disc (DVD) or other optical storage, Magnetic tape cartridge, tape magnetic disk storage or other magnetic storage device or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, computer-readable media excludes transitory computer-readable media, such as modulated data signals and carrier waves.

It should also be noted that the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article, or apparatus comprising a set of elements includes not only those elements, but also includes Other elements not expressly listed, or elements inherent in the process, method, commodity, or apparatus are also included. Without further limitations, an element defined by the phrase "comprising a ..." does not preclude the presence of additional identical elements in the process, method, article, or apparatus that includes the element.

The above are only examples of the present application, and are not intended to limit the present application. For those skilled in the art, various modifications and changes may occur in this application. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application shall be included within the scope of the claims of the present application.

Claims (12)

1. A data transmission method, said method being applied to a server, is characterized in that, comprising: receiving the first data sent by the data publisher; determining the data type of the first data; determining a data subscriber corresponding to the data type of the first data according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type; Send the first data to the data subscriber. 2. The method according to claim 1, wherein after sending the first data to the data subscriber, the method further comprises: If it is determined that the service level of the first data is a preset service level, then sending a data publishing completion message to the data publisher to prompt the data publisher to delete the first data. 3. The method according to claim 1, wherein the preset service level includes a first level and a second level, and when it is determined that the preset service level is the first level, After receiving the first data sent by the data publisher, the method further includes: The first data is stored. After the first data is sent to the data subscriber, the method further includes: sending a first data publishing message to the data publishing party; If the release release message sent by the data publisher is received, the first data is deleted. 4. The method according to claim 1, wherein the mapping relationship between the data publisher, the data subscriber and the data type is established by the following method: Receive the subscription request sent by the data subscriber; According to the subscription request, determine the data type contained in the subscription request and the address information of the data subscriber; According to the data type, determine a data publisher matching the data type; A mapping relationship between the data publisher, the data subscriber and the data type is established. 5. The method according to claim 4, wherein when the status of the data publisher includes an offline status and an online status, before receiving the first data sent by the data publisher, the method further comprises: If it is determined that the status of the data publisher is online, the subscription request is sent to the data publisher to prompt the data publisher to send data corresponding to the data type contained in the subscription request . 6. A method for publishing data, said method being applied to a data publishing party, characterized in that, comprising: Receive the data subscription request sent by the server; Sending first data matching the data type included in the data subscription request to the server. 7. The method according to claim 6, characterized in that, after sending the first data matching the data type contained in the data subscription request to the server, the method further comprises: If the data release message sent by the server is received, send a release release message to the server, so that the server deletes the first data; If receiving the message that the data release is completed sent by the server, the first data is deleted. 8. The method according to claim 6, wherein when the status of the data publisher includes an offline status and an online status, receiving the data subscription request sent by the server includes: When the status of the data publisher is the online status, the data subscription request sent by the server is received. 9. A data subscription method, said method being applied to a data subscriber, comprising: Send a data subscription request to the server; receiving first data sent by the server and matching the data type included in the data subscription request. 10. A server, characterized in that, comprising: a receiving unit, configured to receive the first data sent by the data publisher; a first determining unit, configured to determine the data type of the first data; The second determining unit is configured to determine the data subscriber corresponding to the data type of the first data according to the pre-established mapping relationship between the data publisher, the data subscriber and the data type; A first sending unit, configured to send the first data to the data subscriber. 11. A data release device, characterized in that it comprises: a receiving unit, configured to receive a data subscription request sent by the server; A sending unit, configured to send first data matching the data type included in the data subscription request to the server. 12. A data subscription device, comprising: a sending unit, configured to send a data subscription request to the server; The receiving unit is configured to receive the first data sent by the server and matching the data type included in the data subscription request.