CN112073512A - Data processing method and device - Google Patents

Abstract

The embodiment of the invention provides a data processing method and equipment, wherein the method comprises the following steps: receiving a first network request sent by a browser, acquiring flow data corresponding to a user identifier according to the first network request, constructing a response message according to the first network request, the flow data corresponding to the user identifier and a popup request carrying the user identifier, sending a reinjection request to the browser according to the response message, receiving a second network request sent by the browser according to the response message in the reinjection request, searching signaling plane data corresponding to the user identifier based on the second network request, performing association processing on the flow data corresponding to the user identifier and the signaling plane data to obtain associated data corresponding to the user identifier, matching the associated data corresponding to the user identifier with a pre-stored service rule to obtain a target service rule, and executing a corresponding target service according to the target service rule. The data reinjection under the 5G network architecture is realized, and the normal operation of a service system is ensured.

Description

Data processing method and device

technical field

Embodiments of the present invention relate to the technical field of data processing, and in particular, to a data processing method and device.

Background technique

With the development of network technology, the Internet has penetrated into people's work, study and life and other fields.

Under the traditional 4G network architecture, the signaling plane NEs and the user plane NEs are in the same location. The aggregation and offloading equipment can simultaneously aggregate the signaling plane data and user plane data in a hybrid collection method, and analyze the signaling plane data inside the equipment. The data is correlated with the user plane data in real time to prepare for the business system to call the data later.

With the development of 5G technology, the traditional 4G network architecture is gradually transforming to the 5G network architecture. However, under the 5G network architecture, the signaling plane data is centrally processed in the regional nodes, while the user plane data is distributed in various cities. At the node, that is, where the signaling plane data and the user plane data are not in the same location, the 5G network architecture cannot use the existing re-injection method to realize the data re-injection, which in turn affects the normal operation of the business system corresponding to the data.

SUMMARY OF THE INVENTION

Embodiments of the present invention provide a data processing method and device, so as to realize the re-injection of data under the 5G network architecture, thereby ensuring the normal operation of the service system corresponding to the data.

In a first aspect, an embodiment of the present invention provides a data processing method, including: receiving a first network request sent by a browser, and acquiring traffic data corresponding to a user identifier according to the first network request, wherein the first network The request carries the user ID; constructs a response message according to the first network request, the traffic data corresponding to the user ID, and the pop-up request carrying the user ID, and sends a response message to the browser according to the response message re-injection request; receiving a second network request sent by the browser according to the response message in the re-injection request, wherein the second network request carries the user identifier; based on the second network request, Searching for signaling plane data corresponding to the user identification, and performing association processing between the traffic data corresponding to the user identification and the signaling plane data, to obtain associated data corresponding to the user identification, wherein the user identification corresponds to The signaling plane data is pre-stored in the database; the associated data corresponding to the user identifier is matched with the pre-stored service rules to obtain target service rules, and the corresponding target service is executed according to the target service rules.

Optionally, constructing a response message according to the first network request, the traffic data corresponding to the user ID, and the pop-up request carrying the user ID, and sending the response message to the browser according to the response message. The re-injection request includes: parsing the traffic data corresponding to the user identifier according to the first network request, and obtaining the destination address, destination port number, source address, source port number, and protocol number corresponding to the user identifier, and / or Uniform Resource Locator URL information; generate a pop-up request according to the user ID; according to the first network request, the corresponding target address, destination port number, source address, source port number, protocol corresponding to the user ID ID, and/or Uniform Resource Locator URL information, and construct a response message with the pop-up window request carrying the user ID, and send a remark request to the browser according to the response message.

Optionally, before generating the pop-up request according to the user identification, the method further includes: based on a rule engine, the target address, destination port number, source address, source port number, protocol number corresponding to the user identification, and /or the Uniform Resource Locator URL information is matched with the rules in the pre-stored rule base; if the matching is successful, the steps of generating a pop-up window request according to the user identifier and subsequent steps are performed.

Optionally, the matching of the associated data corresponding to the user identifier with a pre-stored business rule to obtain a target business rule, and executing the corresponding target business according to the target business rule includes: acquiring the corresponding target business of the user identifier. Matching field information of the associated data; according to the matching field information and pre-stored business rules, the target business rules are obtained, and the corresponding target business is executed according to the target business rules, wherein the target business includes the call charge package processing business , any one or more of broadband network access processing services and traffic package processing services.

Optionally, after receiving the first network request sent by the browser, the method further includes: acquiring signaling plane data corresponding to the user identifier, and storing the signaling plane data corresponding to the user identifier in a database.

Optionally, the pop-up request carrying the user ID is a toolbar pop-up request carrying the user ID.

Optionally, the first network request and the second network request are both network requests in a hypertext transfer protocol HTTP format.

Optionally, the acquiring the traffic data corresponding to the user identifier according to the first network request includes: based on a data plane development kit DPDK driver, acquiring the network card capture packet corresponding to the user identifier according to the first network request. flow data at the mouth.

In a second aspect, an embodiment of the present invention provides a data processing device, comprising: at least one processor and a memory; the memory stores computer-executed instructions; the at least one processor executes the computer-executed instructions stored in the memory, so that the execution The computer program implements the following steps: receiving a first network request sent by a browser, and acquiring traffic data corresponding to a user identifier according to the first network request, wherein the first network request carries the user identifier; The first network request, the traffic data corresponding to the user ID, and the pop-up request carrying the user ID construct a response message, and send a remark request to the browser according to the response message; receive the browser The second network request sent by the device according to the response message in the re-injection request, wherein the second network request carries the user identifier; based on the second network request, the user identifier is searched for Signaling plane data, and perform correlation processing between the traffic data corresponding to the user identifier and the signaling plane data to obtain the associated data corresponding to the user identifier, wherein the signaling plane data corresponding to the user identifier is pre-stored in the database; matching the associated data corresponding to the user identifier with the pre-stored business rules to obtain target business rules, and execute the corresponding target business according to the target business rules.

In a third aspect, an embodiment of the present invention provides a computer-readable storage medium, where computer-executable instructions are stored in the computer-readable storage medium, and when a processor executes the computer-executable instructions, any one of the first aspect is implemented the data processing method.

Embodiments of the present invention provide a data processing method and device. After the above solution is adopted, traffic data corresponding to the user ID carried in the first network request can be obtained according to the first network request received by the browser, And construct a response message according to the first network request, the traffic data corresponding to the user ID, and the pop-up request carrying the user ID, and then send a re-injection request to the browser according to the response message, and then receive the first message sent by the browser according to the re-injection request. The second network request, and then based on the second network request, search for the signaling plane data corresponding to the user ID, and obtain the associated data after the signaling plane data and the user data are correlated and processed, and then match the associated data with the pre-stored business rules, The target business rules are obtained, and finally the corresponding target business is executed according to the target business rules, realizing the re-injection of data under the 5G network architecture, thereby ensuring the normal operation of the business system corresponding to the data.

Description of drawings

In order to explain the embodiments of the present invention or the technical solutions in the prior art more clearly, the following briefly introduces the accompanying drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present invention, and for those of ordinary skill in the art, other drawings can also be obtained from these drawings without any creative effort.

FIG. 1 is a schematic structural diagram of an application system of a data processing method provided by an embodiment of the present invention;

2 is a schematic flowchart of a data processing method provided by an embodiment of the present invention;

3 is an interactive schematic diagram of a data processing method provided by another embodiment of the present invention;

4 is a schematic structural diagram of a data processing apparatus provided by an embodiment of the present invention;

FIG. 5 is a schematic diagram of a hardware structure of a data processing device according to an embodiment of the present invention.

Detailed ways

The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only a part of the embodiments of the present invention, but not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

The terms "first", "second", "third", "fourth", etc. (if present) in the description and claims of the present invention and the above-mentioned drawings are used to distinguish similar objects and are not necessarily used to Describe a particular order or sequence. It is to be understood that the data so used are interchangeable under appropriate circumstances such that the embodiments of the invention described herein are also capable of encompassing other sequential instances than those illustrated or described. Furthermore, the terms "comprising" and "having", and any variations thereof, are intended to cover non-exclusive inclusion, for example, a process, method, system, product or device comprising a series of steps or units is not necessarily limited to those expressly listed Rather, those steps or units may include other steps or units not expressly listed or inherent to these processes, methods, products or devices.

Under the traditional 4G network architecture, the signaling plane NEs and the user plane NEs are in the same location. The aggregation and offloading equipment can simultaneously aggregate the signaling plane data and user plane data in a hybrid collection method, and analyze the signaling plane data inside the equipment. The data is correlated with the user plane data in real time to prepare for the business system to call the data later.

For the application of Internet access pipes, the current general practice is to aggregate and split devices and simultaneously aggregate the user's signaling plane and user plane data, and allocate bypass split ports to DPI devices, and the DPI devices will mix the user's signaling data and traffic data. The collection is correlated with real-time data. After the protocol analysis of the TCP/IP data of the original traffic, if it is an HTTP request and the information matches the corresponding policy, a specific TCPIP response message is sent to the user through the GI interface. The browser automatically accesses the user's original page and pop-up page according to the response message.

With the development of 5G technology, the traditional 4G network architecture is gradually transforming to the 5G network architecture. However, under the 5G network architecture, the signaling plane data is centrally processed in the regional nodes, while the user plane data is distributed in various cities. At the node, that is, where the signaling plane data and the user plane data are not in the same location, the 5G network architecture cannot use the existing re-injection method to realize the data re-injection, which in turn affects the normal operation of the business system corresponding to the data.

Based on the above problems, the present application realizes the data re-injection method by associating the user plane data and the signaling plane data according to the user identifier, so as to realize the data re-injection under the 5G system architecture, thereby ensuring the data re-injection in the 5G system. The normal operation of the business corresponding to the data under the architecture.

FIG. 1 is a schematic diagram of the architecture of an application system of a data processing method provided by an embodiment of the present invention. As shown in FIG. 1 , the system may include: a client 101 and a server 102, wherein the client 101 and the server 102 may use 5G network for data transmission. In addition, an application program corresponding to the browser 103 may be installed on the client terminal 101, and a request may be sent to the server side 102 through the application program corresponding to the browser 103, thereby realizing data re-injection. Among them, the client can be a device that can access the 5G network through a browser, such as a smartphone, tablet, or personal computer.

The technical solutions of the present invention will be described in detail below with specific examples. The following specific embodiments may be combined with each other, and the same or similar concepts or processes may not be repeated in some embodiments.

FIG. 2 is a schematic flowchart of a data processing method according to an embodiment of the present invention. The method in this embodiment may be executed by the server 102 . As shown in FIG. 2, the method of this embodiment may include:

S201: Receive a first network request sent by a browser, and acquire traffic data corresponding to a user identifier according to the first network request, where the first network request carries the user identifier.

In this embodiment, the browser on the terminal may send a network request to the server, and the network request may carry the identifier corresponding to the user account that has logged into the browser, or the identifier corresponding to the client where the browser is located. called the user ID.

S202: Construct a response message according to the first network request, the traffic data corresponding to the user ID, and the pop-up window request carrying the user ID, and send a remark request to the browser according to the response message.

In this embodiment, after the network request is received and the traffic data corresponding to the network request is obtained, a pop-up window request may also be generated, and a pop-up window may be generated according to the first network request, the traffic data corresponding to the user ID, and the pop-up window carrying the user ID. The request constructs a response message, and then a re-injection request can be initiated to the re-injection switch, and the re-injection switch sends the re-injection request to the browser. Among them, the re-injection is to analyze the request message in real time by means of bypass splitting. When a qualified request message is found, a custom response message is constructed, and the response message is injected into the original request link, so that the original server The response from the terminal is invalid.

A possible implementation manner of sending the re-injection request is: parse the traffic data corresponding to the user identifier according to the first network request, and obtain the destination address, destination port number, source address, source address and source address corresponding to the user identifier. Port number, protocol number, and/or Uniform Resource Locator URL information. Generate popup request based on user ID. According to the first network request, the corresponding target address, destination port number, source address, source port number, protocol number, and/or Uniform Resource Locator URL information corresponding to the user identifier, and the bomb that carries the user identifier The window request constructs a response message, and sends a remark request to the browser according to the response message.

In addition, the popup request carrying the user ID may be a toolbar popup request carrying the user ID.

S203: Receive a second network request sent by the browser according to the response message in the re-injection request, where the second network request carries the user identifier.

In this embodiment, after completing the construction of the response message, a re-injection request may be generated according to the response message, wherein the re-injection request may carry message information of the response message. The browser may send the second network request to the server according to the message information of the response message in the re-injection request.

S204: Based on the second network request, search for signaling plane data corresponding to the user identifier, and perform correlation processing between the traffic data corresponding to the user identifier and the signaling plane data to obtain associated data corresponding to the user identifier, where the user identifier corresponds to The signaling plane data is pre-stored in the database.

In this embodiment, after receiving the second network request, the server may first search for signaling plane data corresponding to the user identifier. The signaling plane data corresponding to the user identification may acquire the signaling plane data corresponding to the user identification after receiving the first network request sent by the browser, and store the signaling plane data corresponding to the user identification in the database in real time. Exemplarily, the database can be a Redis in-memory database.

In addition, the signaling plane data may be mobile phone numbers, user IP data, and the like.

S205: Match the associated data corresponding to the user identifier with the pre-stored business rules to obtain target business rules, and execute the corresponding target business according to the target business rules.

In this embodiment, after the associated data corresponding to the user ID is determined, the associated data corresponding to the user ID can be matched with the pre-stored business rules to obtain the target business rules.

Wherein, in a possible implementation manner, the associated data corresponding to the user ID is matched with the pre-stored business rules to obtain the target business rules, which may specifically include:

Obtain the matching field information of the associated data corresponding to the user ID. According to the matching field information and the pre-stored business rules, the target business rules are obtained.

Specifically, matching field information may be set in the associated data, and then matching with pre-stored business rules is performed according to the matching field information. Exemplarily, the matching field information may be a serial number, or may be a business identifier representing a business rule that can be matched.

In addition, after the target service rules are obtained, the corresponding target services can be executed according to the target service rules, wherein the target services may include any one or more of the service of calling charge package, broadband network access and traffic package.

After the above solution is adopted, the traffic data corresponding to the user ID carried in the first network request can be obtained first according to the first network request sent by the received browser, and the traffic data corresponding to the first network request, the user ID and the user ID can be obtained according to the first network request. The pop-up window request carrying the user ID constructs a response message, and then sends a re-injection request to the browser according to the response message, and then receives the second network request sent by the browser according to the re-injection request, and based on the second network request, searches for the user Identify the corresponding signaling plane data, and obtain the associated data after the signaling plane data and the user data are correlated, and then match the associated data with the pre-stored business rules to obtain the target business rules, and finally execute the corresponding target according to the target business rules. business, realizes the re-injection of data under the 5G network architecture, thereby ensuring the normal operation of the business system corresponding to the data.

Based on the method of FIG. 2 , some specific implementations of the method are also provided in the examples of this specification, which will be described below.

In addition, in a specific embodiment, before generating the pop-up window request according to the user identifier, it may further include:

Based on the rule engine, the target address, destination port number, source address, source port number, protocol number, and/or Uniform Resource Locator (Uniform Resource Locator) information corresponding to the user ID are stored in the pre-stored rule base. rules to match.

If the matching is successful, the pop-up request is generated according to the user ID and the subsequent steps are performed.

In this embodiment, before generating the pop-up window request, the specific parameters in the traffic data corresponding to the user identifier may be matched with the rules in the pre-stored rule base based on the rule engine. The specific parameters can be the target address, destination port number, source address, source port number, protocol number, and/or Uniform Resource Locator URL information corresponding to the user ID, which improves the accuracy of pop-up window generation and reduces system processing. Data pressure.

In addition, in a specific embodiment, the first network request and the second network request are both network requests in the hypertext transfer protocol HTTP format.

In addition, in a specific embodiment, acquiring the traffic data corresponding to the user identifier according to the first network request may include: based on the data plane development kit DPDK driver, acquiring the packet capture port of the network card corresponding to the user identifier according to the first network request traffic data.

Specifically, the packet capture driver of the data packet can adopt several different methods: DPDK, PF_RING, NETMAP, and PCAP.

FIG. 3 is an interactive schematic diagram of a data processing method provided by another embodiment of the present invention. As shown in FIG. 3 , it includes an interaction process between a user corresponding to a browser, a 5G network, a large area, a DPI device, and a toolbar terminal. It can include: Signaling plane data is separated from user traffic data, signaling plane data is collected and processed centrally by the large area, and updated to the in-memory database in real time, DPI only collects the original traffic data requested by the user, and the response message of the re-injection contains After the user ID is obtained, after the re-injection is completed, the correspondence between the signaling plane data and the real-time traffic data requested by the user is formed by post-association. The re-injection success rate is closely related to the delay. Through the innovative technology of post-association, the existing The computing delay of the technology greatly improves the success rate of re-injection, realizes the decoupling of computing logic, transfers part of the logic that requires DPI processing to the business system, and reduces the computing power consumption of existing DPI devices.

Based on the same idea, the embodiment of this specification also provides a device corresponding to the above method. FIG. 4 is a schematic structural diagram of the data processing device provided by the embodiment of the present invention. As shown in FIG. 4 , it may include:

The receiving module 401 is configured to receive a first network request sent by a browser, and obtain traffic data corresponding to a user identifier according to the first network request, wherein the first network request carries the user identifier.

The processing module 402 is configured to construct a response message according to the first network request, the traffic data corresponding to the user ID, and the pop-up window request carrying the user ID, and send the response message to the browser according to the response message Repost request.

The receiving module 401 is further configured to receive a second network request sent by the browser according to the response message in the re-injection request, wherein the second network request carries the user identifier.

The processing module 402 is further configured to search for the signaling plane data corresponding to the user identifier based on the second network request, and perform association processing between the traffic data corresponding to the user identifier and the signaling plane data, The associated data corresponding to the user identifier is obtained, wherein the signaling plane data corresponding to the user identifier is pre-stored in a database.

The processing module 402 is further configured to match the associated data corresponding to the user identifier with the pre-stored business rules to obtain target business rules, and execute the corresponding target business according to the target business rules.

In addition, in a specific embodiment, the processing module is further used for:

The traffic data corresponding to the user identifier is parsed according to the first network request, and the destination address, destination port number, source address, source port number, protocol number, and/or uniform resource locator corresponding to the user identifier are obtained URL information.

A pop-up window request is generated according to the user identifier.

According to the first network request, the corresponding target address, destination port number, source address, source port number, protocol number, and/or Uniform Resource Locator URL information corresponding to the user identifier, and carrying the user identifier The pop-up window request constructs a response message, and sends an injection-back request to the browser according to the response message.

In addition, in a specific embodiment, the processing module is further used for:

Based on the rule engine, the target address, destination port number, source address, source port number, protocol number, and/or uniform resource locator URL information corresponding to the user identifier is matched with the rules in the pre-stored rule base.

If the matching is successful, the generating a pop-up window request according to the user identifier and the subsequent steps are performed.

In addition, in a specific embodiment, the processing module is further used for:

Obtain matching field information of the associated data corresponding to the user identifier.

According to the matching field information and the pre-stored service rules, the target service rules are obtained, and the corresponding target services are executed according to the target service rules, wherein the target services include call charge package processing services, broadband network access processing services, and traffic Any one or more of the package handling services.

In addition, in a specific embodiment, the processing module is further used for:

The signaling plane data corresponding to the user identifier is acquired, and the signaling plane data corresponding to the user identifier is stored in a database.

In addition, in a specific implementation manner, the pop-up window request carrying the user identifier is a toolbar pop-up window request carrying the user identifier.

In addition, in a specific implementation manner, the first network request and the second network request are both network requests in the hypertext transfer protocol HTTP format.

In addition, in a specific embodiment, the processing module is further used for:

Based on the data plane development kit DPDK driver, the traffic data at the packet capture port of the network card corresponding to the user identifier is acquired according to the first network request.

The apparatus provided in the embodiment of the present invention can implement the method of the above-mentioned embodiment shown in FIG. 2 , and the implementation principle and technical effect thereof are similar, which will not be repeated here.

FIG. 5 is a schematic diagram of a hardware structure of a data processing device according to an embodiment of the present invention. As shown in FIG. 5 , the device 500 provided in this embodiment includes: at least one processor 501 and a memory 502 . The processor 501 and the memory 502 are connected through a bus 503 .

In a specific implementation process, at least one processor 501 executes the computer-executable instructions stored in the memory 502, so that the following steps are implemented when executing the computer program:

A first network request sent by the browser is received, and traffic data corresponding to the user identifier is acquired according to the first network request, wherein the first network request carries the user identifier.

A response message is constructed according to the first network request, the traffic data corresponding to the user ID, and the pop-up window request carrying the user ID, and a re-injection request is sent to the browser according to the response message.

Receive a second network request sent by the browser according to the response message in the re-injection request, where the second network request carries the user identifier.

Based on the second network request, the signaling plane data corresponding to the user identifier is searched, and the traffic data corresponding to the user identifier is associated with the signaling plane data to obtain the associated data corresponding to the user identifier. , wherein the signaling plane data corresponding to the user identifier is pre-stored in the database.

The associated data corresponding to the user identifier is matched with the pre-stored business rules to obtain target business rules, and the corresponding target business is executed according to the target business rules.

In addition, the processor also implements the following steps when executing the computer program:

The traffic data corresponding to the user identifier is parsed according to the first network request, and the destination address, destination port number, source address, source port number, protocol number, and/or uniform resource locator corresponding to the user identifier are obtained URL information.

A pop-up window request is generated according to the user identifier.

According to the first network request, the corresponding target address, destination port number, source address, source port number, protocol number, and/or Uniform Resource Locator URL information corresponding to the user identifier, and carrying the user identifier The pop-up window request constructs a response message, and sends an injection-back request to the browser according to the response message.

In addition, the processor also implements the following steps when executing the computer program:

Based on the rule engine, the target address, destination port number, source address, source port number, protocol number, and/or uniform resource locator URL information corresponding to the user identifier is matched with the rules in the pre-stored rule base.

If the matching is successful, the generating a pop-up window request according to the user identifier and the subsequent steps are performed.

In addition, the processor also implements the following steps when executing the computer program:

Obtain matching field information of the associated data corresponding to the user identifier.

According to the matching field information and the pre-stored service rules, the target service rules are obtained, and the corresponding target services are executed according to the target service rules, wherein the target services include call charge package processing services, broadband network access processing services, and traffic Any one or more of the package handling services.

In addition, the processor also implements the following steps when executing the computer program:

The signaling plane data corresponding to the user identifier is acquired, and the signaling plane data corresponding to the user identifier is stored in a database.

In addition, the pop-up window request carrying the user identifier is a toolbar pop-up window request carrying the user identifier.

In addition, the first network request and the second network request are both network requests in the hypertext transfer protocol HTTP format.

In addition, the processor also implements the following steps when executing the computer program:

Based on the data plane development kit DPDK driver, the traffic data at the packet capture port of the network card corresponding to the user identifier is acquired according to the first network request.

For the specific implementation process of the processor 501, reference may be made to the foregoing method embodiments, and the implementation principles and technical effects thereof are similar, and details are not described herein again in this embodiment.

In the above-mentioned embodiment shown in FIG. 5, it should be understood that the processor may be a central processing unit (English: Central Processing Unit, referred to as: CPU), or other general-purpose processors, digital signal processors (English: Digital signal processor). Signal Processor, referred to as DSP), application specific integrated circuit (English: Application Specific Integrated Circuit, referred to as: ASIC) and the like. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like. The steps of the method disclosed in conjunction with the invention can be directly embodied as executed by a hardware processor, or executed by a combination of hardware and software modules in the processor.

The memory may include high-speed RAM memory, and may also include non-volatile storage NVM, such as at least one disk memory.

The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA) bus, a Peripheral Component Interconnect (PCI) bus, or an Extended Industry Standard Architecture (Extended Industry Standard Architecture, EISA) bus, or the like. The bus can be divided into address bus, data bus, control bus and so on. For convenience of representation, the buses in the drawings of the present application are not limited to only one bus or one type of bus.

Embodiments of the present invention further provide a computer-readable storage medium, where computer-executable instructions are stored in the computer-readable storage medium, and when a processor executes the computer-executable instructions, the data processing method of the above method embodiment is implemented.

The above-mentioned computer-readable storage medium, the above-mentioned readable storage medium can be realized by any type of volatile or non-volatile storage device or their combination, such as static random access memory (SRAM), electrically erasable Programmable Read Only Memory (EEPROM), Erasable Programmable Read Only Memory (EPROM), Programmable Read Only Memory (PROM), Read Only Memory (ROM), Magnetic Memory, Flash Memory, Magnetic or Optical Disk. A readable storage medium can be any available medium that can be accessed by a general purpose or special purpose computer.

An exemplary readable storage medium is coupled to the processor such that the processor can read information from, and write information to, the readable storage medium. Of course, the readable storage medium can also be an integral part of the processor. The processor and the readable storage medium may be located in application specific integrated circuits (Application Specific Integrated Circuits, ASIC for short). Of course, the processor and the readable storage medium may also exist in the device as discrete components.

Those of ordinary skill in the art can understand that all or part of the steps of implementing the above method embodiments may be completed by program instructions related to hardware. The aforementioned program can be stored in a computer-readable storage medium. When the program is executed, the steps including the above method embodiments are executed; and the aforementioned storage medium includes: ROM, RAM, magnetic disk or optical disk and other media that can store program codes.

Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention, but not to limit them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: The technical solutions described in the foregoing embodiments can still be modified, or some or all of the technical features thereof can be equivalently replaced; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the technical solutions of the embodiments of the present invention. scope.

Claims (10)

1. A data processing method, comprising:

receiving a first network request sent by a browser, and acquiring traffic data corresponding to a user identifier according to the first network request, wherein the user identifier is carried in the first network request;

constructing a response message according to the first network request, the flow data corresponding to the user identifier and the popup request carrying the user identifier, and sending a reinjection request to the browser according to the response message;

receiving a second network request sent by the browser according to a response message in the reinjection request, wherein the second network request carries the user identifier;

based on the second network request, searching signaling surface data corresponding to the user identifier, and performing association processing on traffic data corresponding to the user identifier and the signaling surface data to obtain associated data corresponding to the user identifier, wherein the signaling surface data corresponding to the user identifier is pre-stored in a database;

and matching the associated data corresponding to the user identification with a pre-stored service rule to obtain a target service rule, and executing the corresponding target service according to the target service rule.

2. The method according to claim 1, wherein the constructing a response packet according to the first network request, the traffic data corresponding to the user identifier, and the popup request carrying the user identifier, and sending a reply request to the browser according to the response packet comprises:

analyzing the flow data corresponding to the user identification according to the first network request to obtain a target address, a destination port number, a source address, a source port number, a protocol number and/or Uniform Resource Locator (URL) information corresponding to the user identification;

generating a popup request according to the user identifier;

and constructing a response message according to the first network request, a corresponding target address, a corresponding destination port number, a corresponding source address, a corresponding source port number, a corresponding protocol number and/or Uniform Resource Locator (URL) information corresponding to the user identifier and a popup request carrying the user identifier, and sending a reinjection request to the browser according to the response message.

3. The method of claim 2, further comprising, prior to said generating a pop request from said user identifier:

based on a rule engine, matching a target address, a destination port number, a source address, a source port number, a protocol number and/or Uniform Resource Locator (URL) information corresponding to the user identifier with rules in a pre-stored rule base;

and if the matching is successful, executing the steps of generating the popup request according to the user identification and the following steps.

4. The method according to claim 1, wherein the matching the associated data corresponding to the user identifier with a pre-stored service rule to obtain a target service rule, and executing a corresponding target service according to the target service rule comprises:

acquiring matching field information of the associated data corresponding to the user identification;

and matching the matching field information with a prestored service rule to obtain a target service rule, and executing a corresponding target service according to the target service rule, wherein the target service comprises any one or more of a telephone fee package transaction service, a broadband network access transaction service and a flow packet transaction service.

5. The method according to any one of claims 1-4, further comprising, after the receiving the first network request sent by the browser:

and acquiring signaling plane data corresponding to the user identification, and storing the signaling plane data corresponding to the user identification into a database.

6. The method according to any one of claims 1 to 4, wherein the popup request carrying the user identifier is a toolbar popup request carrying the user identifier.

7. The method of any of claims 1-4, wherein the first network request and the second network request are both hypertext transfer protocol (HTTP) formatted network requests.

8. The method according to any one of claims 1 to 4, wherein the obtaining of the traffic data corresponding to the subscriber identity according to the first network request comprises:

and based on a DPDK drive of a data plane development kit, acquiring the flow data at the network card packet capturing port corresponding to the user identifier according to the first network request.

9. A data processing apparatus, characterized by comprising: at least one processor and memory;

the memory stores computer-executable instructions;

the at least one processor executing the computer executable instructions stored by the memory causes the computer program when executed to implement the steps of:

receiving a first network request sent by a browser, and acquiring traffic data corresponding to a user identifier according to the first network request, wherein the user identifier is carried in the first network request;

constructing a response message according to the first network request, the flow data corresponding to the user identifier and the popup request carrying the user identifier, and sending a reinjection request to the browser according to the response message;

receiving a second network request sent by the browser according to a response message in the reinjection request, wherein the second network request carries the user identifier;

based on the second network request, searching signaling surface data corresponding to the user identifier, and performing association processing on traffic data corresponding to the user identifier and the signaling surface data to obtain associated data corresponding to the user identifier, wherein the signaling surface data corresponding to the user identifier is pre-stored in a database;

and matching the associated data corresponding to the user identification with a pre-stored service rule to obtain a target service rule, and executing the corresponding target service according to the target service rule.

10. A computer-readable storage medium having stored thereon computer-executable instructions which, when executed by a processor, implement a data processing method according to any one of claims 1 to 8.

Images