CN115996215A - Method and device for real-time data push - Google Patents

Abstract

Embodiments of the present application provide a method and device for real-time data push, the method comprising: a received data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in In the header of the data transmission message, the first information is used to describe the recommended data; according to the first information, the recommended data is acquired. In the embodiment of the present application, the first information used to describe the recommended data is encapsulated in the header of the data transmission message, so that the push of data does not require customized development, which helps to improve the timeliness of pushing data and reduce data push the cost of.

Description

Method and device for real-time data push

technical field

The embodiments of the present application relate to the technical field of the Internet, and in particular to a method and device for real-time data push.

Background technique

With the rapid development of Internet technology, Internet live streaming has become the current trend. Generally speaking, the anchor terminal can push the live data to the server, and then the audience terminal can pull the live data from the server. During the live broadcast, the anchor terminal can recommend item information to the audience terminals, and the corresponding audience terminals can display the recommended item information.

In the push-pull streaming process of live data, data transmission protocols can be used, such as Real Time Messaging Protocol (RTMP), Web Real-Time Communication (WebRTC), and User Datagram Protocol (UDP). Protocol, UDP) encapsulated private protocol to transmit streaming media data. When the items recommended in the live broadcast scene include financial products, since financial products do not belong to streaming media data, it is generally through Extensible Messaging and Presence Protocol (XMPP), or Hyper Text Transfer Protocol (Hyper Text Transfer) Protocol, HTTP) for data transmission. Therefore, the data push of financial products requires customized development, and the cost is relatively high. Therefore, there is an urgent need for a low-cost data push solution.

Contents of the invention

The embodiment of the present application provides a method and device for real-time data push, by encapsulating the first information used to describe the recommended data in the head of the data transmission message, so that the data push does not require customized development, which is helpful To improve the timeliness of pushing data and reduce the cost of data pushing.

In a first aspect, an embodiment of the present application provides a method for pushing real-time data, the method comprising:

A received data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in the header of the data transmission message, and the first information is used to describe the recommended The data;

Acquiring the recommended data according to the first information.

In some optional embodiments, the method may be executed by the first device, and the first device may receive the data transmission packet from the second device.

Optionally, the first device includes a viewer terminal, and the second device includes a server. Alternatively, the first device includes a server, and the second device includes an anchor terminal, which is not limited.

In some optional embodiments, the method further includes: sending the recommended data according to the first information, for example, sending the recommended data to a third device.

In some optional embodiments, when the first device includes a server, the second device includes an anchor terminal, and the third device includes an audience terminal.

In some optional embodiments, the recommended data includes financial products.

In a second aspect, the embodiments of the present application provide a method for real-time data push, including:

Get recommended data;

determining first information, the first information being used to describe the recommended data;

Sending a data transmission message, where the data transmission message includes the live data stream and the first information, and the first information is encapsulated in the header of the data transmission message.

In some optional embodiments, the method may be executed by the second device, and the second device may send the data transmission packet to the first device.

Optionally, the first device includes a viewer terminal, and the second device includes a server. Alternatively, the first device includes a server, and the second device includes an anchor terminal, which is not limited.

In the third aspect, a device for pushing real-time data is provided, including:

A transceiver unit, configured to receive a data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in the header of the data transmission message, and the first information Data used to describe recommendations;

A processing unit, configured to acquire the recommended data according to the first information.

In the fourth aspect, a real-time data push device is provided, including:

An acquisition unit, configured to acquire recommended data;

a processing unit configured to determine first information for describing the recommended data;

The transceiver unit is configured to send a data transmission message, the data transmission message includes the live data stream and the first information, and the first information is encapsulated in the header of the data transmission message.

In a fifth aspect, an electronic device is provided, which includes: a processor and a memory;

The memory is used to store computer programs;

The processor is configured to execute the computer program to implement the aforementioned method.

According to a sixth aspect, a chip is provided, including: a processor, configured to invoke and run a computer program from a memory, so that a device installed with the chip executes the aforementioned method.

In a seventh aspect, a computer-readable storage medium is provided, the storage medium includes computer instructions, and when the instructions are executed by a computer, the computer implements the method as described above.

In an eighth aspect, a computer program product is provided, including computer program instructions. When the computer program instructions are run on a computer, the computer is made to execute the aforementioned method.

In this embodiment of the present application, the first information used to describe the recommended data is encapsulated in the header of the data transmission message, that is, the same data transmission protocol as the live data stream is used to push the first information, so that no customized development is required To realize the push of real-time data, on the one hand, it can help to improve the timeliness of pushing data, and on the other hand, it can reduce the cost of pushing real-time data.

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.

FIG. 1 is a schematic diagram of a system architecture applicable to an embodiment of the present application;

FIG. 2 is a schematic flow chart of a live broadcast method provided by an embodiment of the present application;

Fig. 3 is an example of the display interface of the anchor terminal provided by the embodiment of the present application;

Fig. 4 is another example of the display interface of the anchor terminal provided by the embodiment of the present application;

Fig. 5 is an example of the RTMP message that the embodiment of the present application provides;

Figure 6 is an example of the parsed index information provided by the embodiment of this application;

Fig. 7 is an example of the actor cache pool list provided by the embodiment of the present application;

FIG. 8 is a schematic block diagram of a device for pushing real-time data provided by an embodiment of the present application;

FIG. 9 is a schematic block diagram of another device for pushing real-time data provided by an embodiment of the present application;

Fig. 10 is a schematic block diagram of an electronic device provided by an embodiment of the present application.

Detailed ways

The technical solutions in the embodiments of the present application will be described below with reference to the drawings in the embodiments of the present application.

It should be understood that in this embodiment of the present application, "B corresponding to A" means that B is associated with A. In one implementation, B may be determined from A. However, it should also be understood that determining B according to A does not mean determining B only according to A, and B may also be determined according to A and/or other information.

In the description of the present application, unless otherwise specified, "at least one" means one or more, and "plurality" means two or more than two.

In addition, in order to clearly describe the technical solutions of the embodiments of the present application, in the embodiments of the present application, words such as "first" and "second" are used to distinguish the same or similar items with basically the same function and effect. Those skilled in the art can understand that words such as "first" and "second" do not limit the number and execution order, and words such as "first" and "second" do not necessarily limit the difference.

In order to facilitate the understanding of the embodiments of the present application, firstly, the relevant concepts involved in the embodiments of the present application are briefly introduced as follows:

Live streaming: refers to the process of transmitting the packaged content in the acquisition stage to the server, that is, the process of transmitting the live audio and video signals to the network. Specifically, the collected audio and video content can be encoded, and the encoded audio and video content can be uploaded to the server based on a specific data transmission protocol.

Live streaming: refers to the process of pulling the existing live content from the server with a specified address, that is, the process of transmitting the audio and video signals on the network to the playback terminal. Specifically, the audio and video content can be pulled from the server based on a specific data transmission protocol, and the audio and video content can be decoded and played.

Exemplarily, the data transmission protocol, such as RTMP, WebRTC, a private protocol based on UDP encapsulation, etc., is not limited.

Financial Product Data (Financial Product Data, FPD): refers to the financial product data structure in the live broadcast scene. Among them, financial products include securities, funds, stocks, options or their combinations, etc., without limitation. The FPD may include at least one of the identification ID, name, minimum amount, annual interest rate, uniform resource locator (Uniform ResourceLocator, URL) of the landing page and time limit of the financial product. A complete financial product requires a well-configured FPD. In this embodiment of the application, the anchor terminal side and the server side can be configured with a unified FPD package.

RTMP, based on Transmission Control Protocol (TCP), is a protocol family, including RTMP basic protocol and various variants such as RTMPT/RTMPS/RTMPE. RTMP is a network protocol designed for real-time data communication. It is mainly used for audio, video and data communication between the Flash/AIR platform and streaming media/interactive servers that support the RTMP protocol. In the embodiment of the present application, the information used to indicate the financial product or FPD is transmitted in the RTMP protocol header.

Actor object: An actor object refers to the most basic computing unit. It can receive messages and perform calculations based on them. And the actor object has a state, which can be self-controlled or controlled by the message sender. In the embodiment of this application, the actor object is associated with recommended data, such as financial products (such as FPD of financial products), and the sending of recommended data, such as financial product data ( Such as data in FPD).

The following briefly introduces the applicable application scenarios of the technical solutions of the embodiments of the present application. FIG. 1 is a schematic diagram of a network system to which the embodiment of the present application is applicable. As shown in FIG. 1 , the system includes at least one host terminal 101 (one is taken as an example in FIG. 1 ), at least one audience terminal 102 (three are taken as an example in FIG. 1 ) and a server 103 . Wherein, the anchor terminal 101, the audience terminal 102 and the server may be connected through a wireless or wired network. Exemplarily, the anchor terminal 101 or the audience terminal 102 may include computers, mobile phones, tablet phones, smart TVs or other terminals, and the server 103 may be a backend server, or a cloud server that provides cloud computing or cloud storage services, which is not discussed in this application. Do limited.

It should be noted that the embodiment of the present application uses the anchor terminal and the audience terminal as examples to distinguish the terminals implementing the live broadcast method of the embodiment of the present application, but the embodiment of the present application is not limited thereto. For example, the anchor terminal can also be called the first terminal, the audience terminal may also be called a second terminal, or others.

As an example, an application program can be installed on the host terminal 101 or the audience terminal 102, and the host terminal 101 or the audience terminal 102 can implement functions such as data transmission and message interaction through the server 103 through the application program. Optionally, the application program may be an application program in the operating system or an application program provided by a third party, without limitation. For example, the application program may be a live broadcast application, and the live broadcast application has a function of live video broadcasting. Optionally, the live broadcast application program may also have other functions, such as shopping functions, music functions, game functions, etc., which are not limited in this application.

It should be noted that the application scenarios described above are only used to illustrate the embodiments of the present application rather than limit them. During specific implementation, the technical solutions provided by the embodiments of the present application may be flexibly applied according to actual needs. For example, the embodiments of the present application may also be applied to targeted message push or advertisement push scenarios, which are not limited.

In the live broadcast scenario, the anchor terminal 101 and the audience terminal 102 can log in to the live broadcast application program based on the account number, and the corresponding anchor terminal 101 uses the live broadcast application program to perform live broadcast, and uploads the collected live content push stream to the server 103 to realize live push stream, The viewer terminal 102 pulls the live broadcast content from the server 103 through the live broadcast application to realize live streaming. During the live broadcast, the host terminal 101 may push real-time data to the audience terminal 102, such as data of items recommended in the live broadcast, data of financial products, etc., without limitation. At present, when the recommended items include financial products, customized development is required, such as data transmission through XMPP or HTTP protocol, and the maintenance cost is relatively high.

In view of this, the embodiment of the present application provides a method for pushing real-time data, in this method, the first information can be encapsulated in the data transmission message (such as the header) containing the live data stream, and the first information is used It is used to describe the recommended data, so as to realize the push of the real-time data. Since the embodiment of the present application encapsulates the first information used to describe the recommended data in a data transmission message (such as a header), real-time data push can be realized without customized development, and on the one hand, it can help to improve The timeliness of pushing data, on the other hand, helps to reduce the cost of data pushing.

Exemplarily, the recommended data is, for example, items recommended during the live broadcast (such as financial products), or advertising messages, or directional messages, etc., without limitation.

FIG. 2 shows a schematic flowchart of a method 200 for pushing real-time data provided by an embodiment of the present application. The anchor terminal in method 200 may be, for example, the anchor terminal 101 in FIG. 1 , the audience terminal may be, for example, the audience terminal 102 in FIG. 1 , and the server may be, for example, the server 103 in FIG. 1 , without limitation. As shown in FIG. 2 , method 200 includes steps 210 to 250 .

210. The anchor terminal acquires recommended data.

Exemplarily, during the live broadcast, the anchor on the anchor terminal side (an example of the user) can operate the anchor terminal in real time to input pushed (recommended) products according to the content explained in the current live broadcast, or operate the anchor terminal to preview Set the product to push. In response to the host's operation, the host terminal acquires recommended products. As an example, the items recommended by the host may include financial products, and in this case, the recommended data includes financial products.

In some optional embodiments, when the recommended data includes financial products, the anchor terminal can display the financial products according to the FPD of the recommended financial products. Then, a push instruction input by the user is acquired through the first input area, and the push instruction is used to instruct to push the financial product. According to the push instruction, the host terminal can determine to recommend the financial product. Optionally, the host terminal may display the first input area on the interface, and the corresponding user may input push instructions by clicking or touching the first input area.

As shown in Table 1, the FPD may include at least one of the identification ID, name, minimum amount, annual interest rate, Uniform Resource Locator (Uniform Resource Locator, URL) of the landing page and time limit of the financial product.

Table 1

Field Name illustrate productID Product ID productName product name minAmount minimum amount rateOfYear annual interest rate deatailUrl Landing page Url timeLimit time limit

Fig. 3 shows an example of the display interface of the anchor terminal. As shown in Figure 3, the anchor terminal can display at least one (two in Figure 3) financial products according to the pre-stored FPD, for example, the data of each financial product can be displayed, such as product name, minimum amount, annual interest rate, time Restrictions and other information. Optionally, the anchor terminal can also display a "push" button (that is, an example of the input area) for each financial product. When the host recommends a financial product, he can click or touch the "push" button corresponding to the financial product. In response to clicking or touching the "Push" button, the anchor terminal can obtain a push instruction, and determine that the financial product corresponding to the "Push" button is a recommended financial product.

As a possible implementation, the anchor terminal may have a built-in FPD creation tool (tool). When the host terminal is about to start live broadcast, or in the process of live broadcast, it can construct FPD or modify FPD based on the creation of FPDtool. Exemplarily, as shown in Figure 4, the creation of FPDtool can display the names of multiple associated products and/or other information of financial products, such as minimum amount, annual interest rate, time limit, risk level, etc., to the anchor terminal through the interface. A user (such as an anchor) can select one or more financial products from these multiple related products (for example, Shanxi Securities ultra-short bond C is selected in Figure 4). Create FPDtool builds the FPD of the financial product in response to the user's selection.

In some optional embodiments, the host can input the time, type, and recipient groups of the data to be pushed. Exemplarily, the anchor can input event or time information to indicate the time, type or recipients of the data to be pushed. Correspondingly, the anchor terminal can acquire the event or time information. That is to say, when a certain (or some) event or time is reached during the live broadcast, data can be pushed to the audience terminal. Exemplarily, for different audience groups, the server will push different data, such as items or financial products, such as items or financial products currently explained by the anchor.

As an example, event or time information may include one or more of the following:

1) The user has followed the anchor (that is, the account logged in by the user on the live broadcast application of the audience terminal has followed the account logged in by the anchor on the live broadcast application of the anchor terminal);

2) The time for the user to watch the live broadcast reaches a certain length of time (that is, the time for the audience terminal to play the live data stream of the anchor terminal reaches a certain length of time);

3) The number of times the user has watched the live broadcast reaches a certain amount (that is, the number of times the audience terminal plays the live data stream of the anchor terminal)

4) Arrive at a certain point in time.

220. The anchor terminal acquires first information.

Wherein, the first information is used to describe recommended data, that is, the recommended data obtained in step 210, for example, may be items or financial products.

In some optional embodiments, the first information includes at least one of recommended data type information, time information, and service information. Wherein, the type information may be used to indicate the type of the recommended data, the time information may be used to indicate the effective time period of the recommended data, and the service information may be used to indicate the service content of the recommended data.

Exemplarily, when the recommended data includes financial products, the types of financial products include securities, funds, stocks, options or combinations thereof. As an example, the type information may include data communication protocol information, wherein the data communication protocol information corresponds to the type of recommended data. For example, when the transmitted type information starts with codeM://v17, the recommended financial product is securities.

Exemplarily, when the recommended data includes financial products, the service information may indicate data of financial products, such as FPD. As a specific example, the business information may include at least one of information such as ID, name, or index of the financial product (or FPD), which is not limited.

In some optional embodiments, the anchor terminal may also obtain a public key delivered by the server, and encrypt the first information according to the public key. That is to say, the first information may be encrypted information. Optionally, the anchor terminal can obtain the public key issued by the server in advance, and save the public key.

As an example, the anchor terminal can encrypt the index of financial product data, such as a 2-digit hexadecimal data, by means of hash operation message authentication code (Hash-based Message Authentication Code, HMAC), to generate a string and Index information (indexMsg). Exemplarily, the length of the character string may be 64 bits, which is not limited in this application. At this time, the character string and index information may be used as the first information. In the embodiment of the present application, the first information is obtained by encrypting the data of the financial product, which can further improve the security and reliability of pushing the financial product.

In some optional embodiments, the host terminal may also obtain second information, which is used to indicate the conditions that trigger the server to push the financial product to the audience terminal. Exemplarily, the second information may be the above event or time information. That is to say, when the condition indicated by the second information, or the time, or the event is met, the server pushes the corresponding financial product to the audience terminal.

230. The anchor terminal sends a data transmission message to the server. Here, the data transmission message is a streaming data message encapsulated according to the data streaming transmission protocol.

Wherein, the data transmission message includes the live data stream and the above-mentioned first information, and the first information is encapsulated in the header of the data transmission message. As an example, when the data transmission message is an RTMP message, the first information can be encapsulated in the basic header (basic header) of the RTMP message, and/or the message header (message header), for example, can be encapsulated in basicheader or messageheader In the expandable field, there is no limit.

In some embodiments, the data may be formatted to obtain an RTMP message (message) during RTMP protocol transmission. During actual transmission, the sender divides the message into chunks with message IDs. Each chunk may be a separate message or a part of the message. The receiving end can restore the chunk to a complete message according to the message ID contained in the chunk, so as to realize the sending and receiving of information.

FIG. 5 shows an example of a chunk format (chunkformat), wherein a chunk includes a chunk header (chunkheader) and chunk data (chunkdata), and the chunkheader includes a basicheader, a message header, and an extended timestamp (extendedtimestamp). In some optional embodiments, the first information may be encapsulated in the basicheader or the messageheader in the chunkheader, which is not limited in this application.

As an example, when the first information includes index information, when the string and index information obtained by HMAC encryption can be used, the index information can be encapsulated in the basic header in the chunk header, and the string can be placed in the message in the chunk header header.

In some optional embodiments, the data transmission packet may further include second information. Exemplarily, the second information may be encapsulated in the header of the data transmission message, such as the basic header or message header of the RTMP protocol message, which is not limited. For details, please refer to the description of the first information. As a specific example, the second information and the first information may be encapsulated in adjacent fields, which is not limited.

Correspondingly, the server receives the data transmission packet, and obtains the first information from the data transmission packet. For example, after receiving the data transmission message, the server may check the header of the message to obtain the first information. Optionally, the server may also check the header of the packet to obtain the second information.

In some optional embodiments, when the index information is encapsulated in the basic header in the chunk header, and the character string is placed in the message header in the chunk header, the index information in the basic header of the data transmission message can be checked, and the message The string in the header, and according to the HMAC algorithm, the index information is parsed through the string, and the parsed index information is obtained as the first information.

240. The server acquires recommended data according to the first information.

Exemplarily, the server may acquire recommended data according to at least one of type information, time information, and business information included in the first information.

As a specific example, when the type information includes data communication protocol information, such as beginning with codeM://v17, the receiving end (such as the server) according to the agreed protocol information (ie codeM://v17) corresponding to the product type (such as securities type) analyze the first information to determine the recommended financial product.

As another specific example, when the service information can be used to indicate the FPD, for example, it may include at least one of information such as ID, name, or index of the FPD. At this time, the server may determine the FPD of the recommended financial product according to the business information.

As a specific example, FIG. 6 shows an example of index information. Here, the first information includes index information composed of 6-digit hexadecimal data, and may be used to indicate recommended financial products. Exemplarily, the index value of the first 2 digits in the 6-digit hexadecimal data may be used to indicate the FPD of the financial product. For example, the server may store the correspondence between the index value and the FPD, and when the first two bits of the index information are resolved, the FPD may be determined according to the correspondence.

In some optional embodiments, the server may also distribute recommended data to different hosts on the server side for business processing according to business information. For example, when it is determined that the recommended financial product corresponds to the first FPD according to the business information, the first FPD is allocated to the host B for business processing, for example, the host B obtains the recommended first FPD and sends the first FPD to the audience terminal. A FPD data.

In some specific implementation manners of the present application, a data transmission protocol or transmission format may be defined between the anchor terminal and the server, and the transmission protocol or transmission format may correspond to different data types. For example, for securities financial products, the transmission protocol or transmission format of codeM://v17 can be defined. Exemplarily, the server may have a built-in parser for parsing the information describing the recommended product sent by the host terminal, and the parser confirms the communication protocol and data encapsulation format of both parties when establishing a streaming connection between the host terminal and the server . After the server receives the information describing the recommended product, the parser can parse the data according to the agreed protocol format to obtain the recommended data. Specifically, for the parsing process, reference may be made to the description above, and details are not repeated here.

250. The server sends recommended data to the audience terminal.

Exemplarily, when the recommended data is a financial product, the server may send the data of the financial product to the audience terminal according to the first information. Correspondingly, the audience terminal receives the data of the financial product, and then can display the financial product on the screen of the audience terminal, helping the audience understand the product that the anchor is explaining in real time.

Therefore, in the embodiment of the present application, the first information used to describe the recommended data is encapsulated in the header of the data transmission message, that is, the same data transmission protocol as the live data stream is used to push the first information, so that no customization is required. The development of real-time data push can help improve the timeliness of pushing data on the one hand, and reduce the cost of pushing real-time data on the other hand.

In some optional embodiments, the server can acquire the actor object associated with the recommended data according to the first information, and then can determine that the state of the actor object is the execution state, so as to send the recommended data to the audience terminal. In some embodiments, the actor object may hold a status (status) field inside to identify the status information of the data associated with the actor object. That is to say, the state of the recommended data can be controlled according to the state of the actor object. For example, when the actor object is controlled to be in the execution state, the recommendation data associated with the actor can be sent to the audience terminal.

In the embodiment of the present application, by associating the actor object with the recommended data, the sending state of the recommended data can be controlled by controlling the state of the actor object, so as to realize sending the recommended data to the audience terminal, which can help to further improve The timeliness of pushing data improves the efficiency of data transmission.

Exemplarily, the financial product described in the first information (such as the FPD indicated by the business information) may be associated with the actor object, for example, the association between the financial product (or FPD) and the actor object may be pre-stored in the server. The server may determine the actor object according to the first information and the association relationship. Here, the association relationship between the financial product (or FPD) and the actor object is the association relationship between the data of the financial product (or the data contained in the FPD) and the actor object. As a possible implementation, the data of financial products (or the data contained in the FPD) can be associated in the actor object by the index function, that is, through the index function of the actor object, the financial product associated with the actor object can be obtained data (or FPD data). When it is determined that the actor object is in the execution state, the data of the FPD associated with the actor object is sent to the audience terminal.

In some optional embodiments, the server (for example, in the storage) may store a cache pool list, which may contain at least one actor object. When it is determined that the buffer pool list includes an actor object associated with the data described in the first information (ie, the recommended data), the state of the actor object is changed from the reuse state to the waiting state. In some embodiments, the actor object may also be saved in memory. When it is determined that the cache pool list does not include the actor object associated with the data described by the first information (ie recommended data), an actor object of the data described by the first information is established, and the state of the actor object is determined to be a waiting state.

For example, as shown in Figure 7, the server can save the actor cache pool list (for example, it can be saved in the form of an array list), which can contain at least one actor object, such as actor_A, actor_B, actor_C, actor_D, etc., and each actor object can correspond to an index value. In addition, the state of each actor object in the actor buffer pool is the reuse state. Here, the reuse state means that the actor object has been executed and has not been destroyed. Exemplarily, a processing module (such as a processor) in the server may obtain actor objects from the actor cache pool list, or store actor objects in the actor cache pool list, etc., without limitation.

Referring to Fig. 6, when the server receives the streaming data from the host terminal and obtains the index value "05", it can search the actor object corresponding to "05" from the actor cache pool. When the actor cache pool list includes the actor object corresponding to "05", such as actor_B, the state of the actor_B object is changed from the reuse state to the waiting state. Here, the waiting state means that the actor object is waiting to be executed and has associated data (such as data of financial products). When the actor object corresponding to "05" is not included in the actor cache pool list, the actor object associated with "05" is established, and the state of the actor object is determined to be the waiting state.

In some optional embodiments, when the recommended data includes a financial product, the FPD of the financial product may be obtained from the database according to the first information, and an actor object associated with the FPD may be established. Exemplarily, an index field corresponding to the FPD may be determined according to an index function, and then an actor object is created according to the index field, wherein the actor object includes the index field. Here, the index function may be a preset function without limitation. Optionally, after the actor object is created, it can be determined that the state of the actor is waiting. In this way, when it is determined that the state of the actor object is the execution state, the data in the FPD corresponding to the index field of the actor object may be sent to the third device. Exemplarily, after the actor object is in the execution state, the data of the corresponding FPD can be obtained in the database according to the index field and the index function in the actor object, and the data in the FPD can be sent.

Continuing the above example, when creating the actor object corresponding to "05", you can first determine the FPD of the financial product corresponding to "05", and then create the actor object associated with the FPD, such as the index "05", and determine the actor's Status is waiting. For example, the index field corresponding to the FPD corresponding to "05" can be determined according to the index function, and then an actor object including the index field, that is, the actor object corresponding to "05" can be created. After the actor object is in the execution state, the data of the FPD corresponding to the index "05" can be obtained in the database according to the index field and index function in the actor object, and the data in the FPD can be sent.

Therefore, in the embodiment of the present application, the information used to describe the recommended financial product is encapsulated in the header of the data transmission message, that is, the same data transmission protocol as the live data stream is used to push the financial product, so that no customized development is required To realize the push of financial products, on the one hand, it can help to improve the timeliness of pushing financial products, and on the other hand, it can reduce the cost of pushing financial products.

It should be noted that the embodiment of the present application describes the method provided by the embodiment of the present application by taking the first information including the index of the FPD, that is, determining the FPD according to the index of the FPD as an example, but the embodiment of the present application is not limited thereto. For example, A message may also include the FPD's ID, name, or other information.

In some optional embodiments, after it is determined that the state of the actor object is the execution state, the actor object can also be put into the buffer pool list, and the state of the actor object is determined to be the reuse state. In this way, when the recommended data is received again, the actor object associated with the recommended data can be obtained directly from the cache pool list without creating the actor object, which can help to further improve the timeliness of pushing data , improve the efficiency of data transmission.

In some optional embodiments, when the second information is obtained at the head of the data transmission message, the data of the financial product may be sent to the audience terminal when it is determined that the condition indicated by the second information is satisfied, for example, the actor The state of the object is changed from the waiting state to the execution state, so as to send the data in the actor object to the audience terminal, so that the data can be pushed in a targeted manner and the user experience can be improved.

In some optional embodiments, the data of financial products can be sent to the audience terminal together with the live streaming. For example, the server can continue to encapsulate the information describing the recommended data in the header of the data transmission message, and the audience terminal can The data transmission message obtains the live data stream and the first information, and then obtains the recommended data according to the first information.

Similarly, a data transmission protocol or transmission format can be defined between the server and the audience terminal. Exemplarily, a parser may be built in the viewer terminal to parse the information sent by the server to describe the recommended data, and the parser may be initialized when the viewer terminal enters the live broadcast room. After the initialization is successful, the communication protocol and data encapsulation format of both parties can be confirmed when the streaming connection is established between the server and the audience terminal. After the viewer terminal receives the information describing the recommended product, the parser can parse the data according to the agreed protocol format to obtain the recommended data. Specifically, this process is similar to the above process of transmitting information for describing recommended data between the host terminal and the server, and reference may be made to the above description.

In some optional embodiments, the server may also send financial product data to the audience terminal through vendor push or self-built long link, which is not limited in this application.

The specific implementation of the application has been described in detail above in conjunction with the accompanying drawings. However, the application is not limited to the specific details in the above-mentioned implementation. Within the scope of the technical concept of the application, various simple modifications can be made to the technical solution of the application. These simple modifications all belong to the protection scope of the present application. For example, the various specific technical features described in the above specific implementation manners can be combined in any suitable manner if there is no contradiction. Separately. As another example, any combination of various implementations of the present application can also be made, as long as they do not violate the idea of the present application, they should also be regarded as the content disclosed in the present application.

It should also be understood that in the various method embodiments of the present application, the sequence numbers of the above-mentioned processes do not mean the order of execution, and the order of execution of the processes should be determined by their functions and internal logic, and should not be used in this application. The implementation of the examples constitutes no limitation.

The method embodiment of the present application is described in detail above with reference to FIG. 1 to FIG. 7 , and the device embodiment of the present application is described in detail below in conjunction with FIG. 8 to FIG. 10 .

FIG. 8 shows a schematic block diagram of an apparatus 400 for pushing real-time data provided by an embodiment of the present application. As shown in FIG. 8 , the device 400 includes a transceiver unit 410 and a processing unit 420 .

The transceiver unit 410 is configured to receive a data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in the header of the data transmission message, and the first Information is used to describe the recommended data.

The processing unit 420 is configured to acquire the recommended data according to the first information.

Optionally, the transceiver unit 410 may be configured to receive a data transmission packet from the second device.

In some embodiments, the device 400 for pushing real-time data may be a server, or a chip or circuit set in the server. At this time, the second device may be a broadcast terminal. That is to say, real-time data push can be realized between the anchor terminal and the server by encapsulating the information describing the recommended data in the header of the data transmission message.

In some embodiments, the apparatus 400 for pushing real-time data may be an audience terminal, or a chip or a circuit set in an audience terminal. In this case, the second device may be a server. That is to say, real-time data push can be realized between the server and the viewer terminal by encapsulating the information describing the recommended data in the header of the data transmission message.

In some optional embodiments, the first information includes at least one of type information, time information, and service information of the recommended data.

In some optional embodiments, the type information includes data communication protocol information, where the data communication protocol information corresponds to the type of the recommended data.

In some optional embodiments, the data transmission packet includes a real-time messaging protocol RTMP packet, and the first information is encapsulated in a basic header or a message header of the RTMP packet.

In some optional embodiments, the transceiving unit 410 is further configured to send the recommended data according to the first information. Exemplarily, the recommended data may be sent to the third device. In the case where the first device is a server and the second device is a host terminal, the third device is, for example, an audience terminal.

In some optional embodiments, the transceiver unit 410 is specifically configured to:

According to the first information, acquire the actor object associated with the recommended data;

Determine that the state of the actor object is an execution state, so as to send the recommended data.

In some optional embodiments, the processing unit 420 is further configured to put the actor object into a buffer pool list, and determine that the state of the actor object is a reuse state.

In some optional embodiments, the transceiver unit 410 is specifically configured to:

When it is determined that the recommended data-associated actor object is included in the buffer pool list, the state of the actor object is modified from a reuse state to a waiting state;

When it is determined that the recommended data-associated actor object is not included in the buffer pool list, the recommended data-associated actor object is established, and the state of the actor object is determined to be a waiting state.

In some optional embodiments, when the recommended data includes financial products, the transceiving unit 410 is specifically configured to: acquire financial product data FPD from the database according to the first information, and the FPD includes financial product data Identify at least one of ID, name, minimum amount, APR, landing page URL, and time limit;

According to the index function, determine the index field corresponding to the FPD;

Establishing an actor object associated with the FPD, wherein the actor object includes the index field;

Determine that the state of the actor object is an execution state, so as to send the data in the FPD corresponding to the index field of the actor object to the third device.

In some optional embodiments, the data transmission message further includes second information, the first information is encapsulated in the header of the data transmission message, and the second information is used to indicate triggering the server The conditions of the financial product are pushed to the audience terminal.

It should be understood that the device embodiment and the method embodiment may correspond to each other, and similar descriptions may refer to the method embodiment. To avoid repetition, details are not repeated here. Specifically, the device 400 for real-time data recommendation shown in FIG. 8 may correspond to the server executing the method 200 in the embodiment of the present application, or the audience terminal, and the aforementioned and other operations and/or functions of the modules in the device 400 are respectively In order to realize the corresponding process performed by the server or the audience terminal in FIG. 2 , for the sake of brevity, details are not repeated here.

FIG. 9 shows a schematic block diagram of an apparatus 600 for pushing real-time data according to an embodiment of the present application. As shown in FIG. 9 , an apparatus 600 for pushing real-time data includes an acquisition unit 610 , a processing unit 620 and a transceiver unit 630 .

The acquiring unit 610 is configured to acquire recommended data.

The processing unit 620 is configured to determine first information, where the first information is used to describe the recommended data.

The transceiver unit 630 is configured to send a data transmission packet, the data transmission packet includes the live data stream and the first information, and the first information is encapsulated in the header of the data transmission packet.

Optionally, the transceiver unit 630 may be configured to send a data transmission packet to the first device.

In some embodiments, the device 600 for pushing real-time data may be a host terminal, or a chip or circuit provided in the host terminal. At this time, the first device may be a server. That is to say, real-time data push can be realized between the anchor terminal and the server by encapsulating the information describing the recommended data in the header of the data transmission message.

In some embodiments, the device 600 for pushing real-time data may be a server, or a chip or circuit set in the server. At this time, the first device may be a viewer terminal. That is to say, real-time data push can be realized between the server and the viewer terminal by encapsulating the information describing the recommended data in the header of the data transmission message.

In some optional embodiments, the first information includes at least one of type information, time information, and service information of the recommended data.

In some optional embodiments, the type information includes data communication protocol information, where the data communication protocol information corresponds to the type of the recommended data.

In some optional embodiments, the data transmission packet includes a real-time messaging protocol RTMP packet, and the first information is encapsulated in a basic header or a message header of the RTMP packet.

In some optional embodiments, the acquiring unit 610 is specifically configured to:

According to the financial product data FPD of the recommended financial product, display the financial product, the FPD includes at least one of the logo, name, minimum amount, annual interest rate, URL of the landing page uniform resource locator and time limit of the financial product;

Acquiring a push instruction input by a user through the first input area, the push instruction being used to instruct to push the financial product;

According to the push instruction, it is determined to recommend the financial product.

In some optional embodiments, the data transmission message further includes second information, the second information is encapsulated in the header of the data transmission message, and the second information is used to indicate triggering the server The conditions of the financial product are pushed to the audience terminal.

It should be understood that the device embodiment and the method embodiment may correspond to each other, and similar descriptions may refer to the method embodiment. To avoid repetition, details are not repeated here. Specifically, the device 600 for real-time data push shown in FIG. 9 may correspond to the host terminal or server performing the method 200 in the embodiment of the present application, and the aforementioned and other operations and/or functions of each module in the device 600 are respectively for To realize the corresponding flow executed by the host terminal or server in FIG. 2 , for the sake of brevity, details are not repeated here.

The device in the embodiment of the present application is described above from the perspective of functional modules with reference to the accompanying drawings. It should be understood that the functional modules may be implemented in the form of hardware, may also be implemented by instructions in the form of software, and may also be implemented by a combination of hardware and software modules. Specifically, each step of the method embodiment in the embodiment of the present application can be completed by an integrated logic circuit of the hardware in the processor and/or instructions in the form of software, and the steps of the method disclosed in the embodiment of the present application can be directly embodied as hardware The execution of the processor is completed, or the execution is completed by a combination of hardware and software modules in the processor. Optionally, the software module may be located in a mature storage medium in the field such as random access memory, flash memory, read-only memory, programmable read-only memory, electrically erasable programmable memory, and registers. The storage medium is located in the memory, and the processor reads the information in the memory, and completes the steps in the above method embodiments in combination with its hardware.

Fig. 10 is a block diagram of an electronic device involved in an embodiment of the present application. The device may be the server shown in Fig. 1, or an anchor terminal, and is used to execute the method for recommending real-time data described in the above embodiment. For details, refer to the above method embodiment description in .

The electronic device 800 shown in FIG. 10 includes a memory 801 , a processor 802 and a communication interface 803 . The memory 801, the processor 802, and the communication interface 803 are communicatively connected to each other. For example, the memory 801, the processor 802, and the communication interface 803 may be connected through a network to implement a communication connection. Alternatively, the electronic device 800 may further include a bus 804 . The memory 801 , the processor 802 , and the communication interface 803 are connected to each other through a bus 804 . FIG. 10 is an electronic device 800 in which a memory 801 , a processor 802 , and a communication interface 803 are connected to each other through a bus 804 for communication.

The memory 801 may be a read-only memory (Read Only Memory, ROM), a static storage device, a dynamic storage device or a random access memory (Random Access Memory, RAM). The memory 801 may store programs, and when the programs stored in the memory 801 are executed by the processor 802, the processor 802 and the communication interface 803 are used to execute the above method.

The processor 802 may be a general-purpose central processing unit (Central Processing Unit, CPU), a microprocessor, an application-specific integrated circuit (Application Specific Integrated Circuit, ASIC), a graphics processing unit (graphics processing unit, GPU) or one or more integrated circuit.

The processor 802 may also be an integrated circuit chip with signal processing capability. In the implementation process, the method of the present application may be completed by an integrated logic circuit of hardware in the processor 802 or instructions in the form of software. The above-mentioned processor 802 can also be a general-purpose processor, a digital signal processor (digital signal processing, DSP), an application-specific integrated circuit (ASIC), a ready-made programmable gate array (field programmable gate array, FPGA) or other programmable logic devices , discrete gate or transistor logic devices, discrete hardware components. A general-purpose processor may be a microprocessor, or the processor may be any conventional processor, or the like. The software module can be located in a mature storage medium in the field such as random access memory, flash memory, read-only memory, programmable read-only memory or electrically erasable programmable memory, register. The storage medium is located in the memory 801, and the processor 802 reads the information in the memory 801, and implements the method in the embodiment of the present application in combination with its hardware.

The communication interface 803 uses a transceiver module such as but not limited to a transceiver to implement communication between the electronic device 800 and other devices or communication networks. For example, a data transmission message may be sent or received through the communication interface 803 .

When the above-mentioned electronic device 800 includes a bus 804, the bus 804 may include a path for transmitting information among various components of the electronic device 800 (for example, a memory 801, a processor 802, and a communication interface 803).

According to the present application, there is also provided a computer storage medium, on which a computer program is stored, and when the computer program is executed by a computer, the computer can execute the methods of the above method embodiments. In other words, the embodiments of the present application further provide a computer program product including instructions, and when the instructions are executed by a computer, the computer executes the methods of the foregoing method embodiments.

According to the present application there is also provided a computer program product or computer program comprising computer instructions stored in a computer readable storage medium. The processor of the computer device reads the computer instruction from the computer-readable storage medium, and the processor executes the computer instruction, so that the computer device executes the method of the above method embodiment.

In other words, when implemented using software, it may be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. When the computer program instructions are loaded and executed on the computer, the processes or functions according to the embodiments of the present application will be generated in whole or in part. The computer can be a general purpose computer, a special purpose computer, a computer network, or other programmable device. The computer instructions may be stored in or transmitted from one computer-readable storage medium to another computer-readable storage medium, for example, the computer instructions may be transferred from a website, computer, server, or data center by wire (such as coaxial cable, optical fiber, digital subscriber line (DSL)) or wireless (such as infrared, wireless, microwave, etc.) to another website site, computer, server or data center. The computer-readable storage medium may be any available medium that can be accessed by a computer, or a data storage device such as a server or a data center integrated with one or more available media. The available medium may be a magnetic medium (such as a floppy disk, a hard disk, or a magnetic tape), an optical medium (such as a digital video disc (digital video disc, DVD)), or a semiconductor medium (such as a solid state disk (solid state disk, SSD)), etc.

Those skilled in the art can appreciate that the modules and algorithm steps of the examples described in conjunction with the embodiments disclosed herein can be implemented by electronic hardware, or a combination of computer software and electronic hardware. Whether these functions are executed by hardware or software depends on the specific application and design constraints of the technical solution. Those skilled in the art may use different methods to implement the described functions for each specific application, but such implementation should not be regarded as exceeding the scope of the present application.

In the several embodiments provided in this application, it should be understood that the disclosed systems, devices and methods may be implemented in other ways. For example, the device embodiments described above are only illustrative. For example, the division of the modules is only a logical function division. In actual implementation, there may be other division methods. For example, multiple modules or components can be combined or can be Integrate into another system, or some features may be ignored, or not implemented. In another point, the mutual coupling or direct coupling or communication connection shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or modules may be in electrical, mechanical or other forms.

A module described as a separate component may or may not be physically separated, and a component displayed as a module may or may not be a physical module, that is, it may be located in one place, or may also be distributed to multiple network units. Part or all of the modules can be selected according to actual needs to achieve the purpose of the solution of this embodiment. For example, each functional module in each embodiment of the present application may be integrated into one processing module, each module may exist separately physically, or two or more modules may be integrated into one module.

Those skilled in the art can clearly understand that for the convenience and brevity of the description, the specific working process of the above-described system, device and unit can refer to the corresponding process in the foregoing method embodiment, which will not be repeated here. In addition, various method embodiments and various device embodiments may also refer to each other, and the same or corresponding content in different embodiments may refer to each other, and details are not repeated here.

Claims (19)

1. A method for real-time data push, comprising: Receive a data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in the header of the data transmission message, and the first information is used to describe the recommended data; Acquiring the recommended data according to the first information. 2. The method according to claim 1, wherein the first information includes at least one of type information, time information and business information of the recommended data; Wherein, the type information includes data communication protocol information, wherein the data communication protocol information corresponds to the type of the recommended data. 3. The method according to claim 1 or 2, wherein the data transmission message comprises a real-time message transfer protocol RTMP message, and the first information is encapsulated in a basic header or a message header of the RTMP message middle. 4. The method according to any one of claims 1-3, further comprising: Send the recommended data according to the first information. 5. The method according to claim 4, wherein the sending the recommended data according to the first information comprises: According to the first information, acquire the actor object associated with the recommended data; Determine that the state of the actor object is an execution state, so as to send the recommended data. 6. The method according to claim 5, further comprising: Put the actor object into the cache pool list, and determine that the state of the actor object is a reuse state. 7. The method according to claim 5 or 6, wherein said acquiring the recommended data-associated actor object according to said first information comprises: When it is determined that the recommended data-associated actor object is included in the buffer pool list, the state of the actor object is modified from a reuse state to a waiting state; When it is determined that the recommended data-associated actor object is not included in the buffer pool list, the recommended data-associated actor object is established, and the state of the actor object is determined to be a waiting state. 8. The method according to claim 7, wherein when the recommended data includes a financial product, the establishment of the actor object associated with the recommended data includes: According to the first information, the financial product data FPD is obtained from the database, and the FPD includes at least one of the identification ID, name, minimum amount, annual interest rate, landing page uniform resource locator URL and time limit of the financial product; According to the index function, determine the index field corresponding to the FPD; Establishing an actor object associated with the FPD, wherein the actor object includes the index field; Wherein, the determining that the state of the actor object is an execution state so as to send the recommended data to the third device includes: Determine that the state of the actor object is an execution state, so as to send the data in the FPD corresponding to the index field of the actor object to the third device. 9. The method according to any one of claims 1-8, wherein the data transmission message further includes second information, and the first information is encapsulated in the header of the data transmission message, so The second information is used to indicate the conditions that trigger the server to push the financial product to the audience terminal. 10. A method for real-time data push, comprising: Get recommended data; determining first information, the first information being used to describe the recommended data; Sending a data transmission message, where the data transmission message includes the live data stream and the first information, and the first information is encapsulated in the header of the data transmission message. 11. The method according to claim 10, wherein the first information includes at least one of type information, time information and business information of the recommended data; Wherein, the type information includes data communication protocol information, wherein the data communication protocol information corresponds to the type of the recommended data. 12. The method according to claim 10 or 11, wherein the data transmission message comprises a real-time message transmission protocol RTMP message, and the first information is encapsulated in a basic header or a message header of the RTMP message middle. 13. The method according to any one of claims 10-12, wherein said acquiring recommended data comprises: According to the financial product data FPD of the recommended financial product, display the financial product, the FPD includes at least one of the logo, name, minimum amount, annual interest rate, URL of the landing page uniform resource locator and time limit of the financial product; Acquiring a push instruction input by a user through the first input area, the push instruction being used to instruct to push the financial product; According to the push instruction, it is determined to recommend the financial product. 14. The method according to any one of claims 10-13, wherein the data transmission message further includes second information, and the second information is encapsulated in the header of the data transmission message, so The second information is used to indicate the conditions that trigger the server to push the financial product to the audience terminal. 15. A real-time data push device, characterized in that it comprises: A transceiver unit, configured to receive a data transmission message, the data transmission message includes a live data stream and first information, wherein the first information is encapsulated in the header of the data transmission message, and the first information Data used to describe recommendations; A processing unit, configured to acquire the recommended data according to the first information. 16. A device for real-time data push, comprising: An acquisition unit, configured to acquire recommended data; a processing unit configured to determine first information for describing the recommended data; The transceiver unit is configured to send a data transmission message, the data transmission message includes the live data stream and the first information, and the first information is encapsulated in the header of the data transmission message. 17. An electronic device, comprising: a processor and a memory; The memory is used to store computer programs; The processor is configured to execute the computer program to implement the method according to any one of claims 1-14. 18. A computer-readable storage medium, characterized in that the storage medium comprises computer instructions, and when the instructions are executed by a computer, the computer implements the method according to any one of claims 1-14. 19. A computer program product, characterized by comprising computer program code, when the computer program code is executed by an electronic device, the electronic device is made to execute the method according to any one of claims 1-14.

Images