WO2011160462A1

WO2011160462A1 - Charging server and method for processing online service log

Info

Publication number: WO2011160462A1
Application number: PCT/CN2011/071200
Authority: WO
Inventors: 史益斌; 王春; 洪君景
Original assignee: 中兴通讯股份有限公司
Priority date: 2010-06-25
Filing date: 2011-02-23
Publication date: 2011-12-29
Also published as: CN101883111B; CN101883111A

Abstract

A charging server and a method for processing the online service log are provided by the present invention. The method includes: a charging server stores the user number of the processed user; when receiving a firewall log message, the charging server inquires the user number of the user, and generates a bill message according to the user number and the firewall log message. The technical solution of the present invention can reduce the access to the RADIUS server, improve the efficiency of processing the log message, and increase the speed of generating the bill.

Description

Billing server and method for processing online service log

Technical field

The present invention relates to the field of communications, and in particular, to a charging server and method for processing an online service log.

Background technique

The Wireless Application Protocol (WAP) gateway implements JAVA online and streaming media online services by processing request and response message packets through the WAP gateway firewall when processing the online application of the socket-based JAVA online and streaming media. The log files of JAVA online, streaming media, etc. are generated through message interaction between the WAP gateway firewall, the WAP gateway remote user dial-up authentication system (RADIUS) server, and the accounting server. The accounting server receives the socket online service log message sent by the WAP gateway firewall, and extracts the user IP address and other related message fields from the message packet, and sends the IP address to the WAP gateway RADIUS server to query the user information corresponding to the IP according to the agreed format. After receiving the return message of the WAP gateway RADIUS server, the message fields are combined into a bill format message, and the bill process is sent to the billing server, and the bill process is responsible for generating the file to the specified directory, and the operator's computing platform obtains the log message. Perform statistical analysis alone.

With the increase of communication traffic, higher requirements are placed on the performance of the accounting server. Increasing socket online business volume requires the billing server to process the syslog of the firewall faster, and the particularity of the online service of the socket, the user's IP information in the firewall syslog, and no user number, so the billing server can be After receiving the firewall message, the user IP address can be quickly parsed, and the RADIUS server can be queried for the user number information corresponding to the IP to generate a valid CDR. If the firewall syslog generated by multiple accesses of the same user for a period of time is queried, the RADIUS server will increase the load on the RADIUS server. This may result in failure of querying the user information, and may even cause the RADIUS server to hang, causing the entire service to crash. In addition, frequent access to the RADIUS server and waiting for the response from the server also greatly affects the processing performance of the CDR server. Summary of the invention The problem to be solved by the present invention is to provide an accounting server and method for processing an online service log, which can reduce access to the RADIUS server and improve the efficiency of processing log messages.

The present invention provides a method for processing an online service log, including:

The billing server stores the user number of the processed user. When the billing server receives the firewall message, it queries the user number of the user, and generates a bill message according to the user number and the firewall log message.

The charging server records the user number of the processed user, and the charging server establishes and stores a correspondence between the user IP and the user number;

After the firewall log message is received, the user number of the user is queried. The accounting server searches for the user number of the user according to the corresponding relationship between the user IP address and the user number.

The method further includes: the billing server allocates a bill identifier for the firewall log message, and if the query user number fails, stores the parsed bill message structure, and sends a query message to the RADIUS server to query the user number; the query message The user IP address and the bill identifier are carried.

The method further includes: after receiving the response message returned by the RADIUS server, if the query succeeds, the billing message structure is read according to the bill identifier in the response message, and the user number in the response message is Forming a bill message together with the single message structure;

If the query fails, the stored bill message structure is read according to the bill identifier in the response message, and the user number is set to 0 to generate a bill message together with the bill message structure.

The accounting server establishes and stores a correspondence between the user IP address and the user number after receiving the response message of the successful query returned by the RADIUS server.

The method further includes: if the charging server receives the offline notification from the RADIUS server, the user searches for the IP address-user number corresponding relationship according to the user number in the notification, and deletes the correspondence, thereby deleting the IP address. - The correspondence between the processing unit numbers.

The method further includes: if the IP address-user number correspondence stored by the accounting server is out of time, deleting the timeout IP address-user number correspondence relationship, and further deleting the correspondence relationship between the IP address and the processing unit number.

The invention also provides an accounting server for processing an online service log, comprising a message receiving module, a storage module and a bill message processing module; The storage module is configured to: store a user number of the processed user;

The message receiving module is configured to: receive a firewall log message and send the message to the bill message processing module;

The bill message processing module is configured to: after receiving the firewall log message, query the user number of the user, and generate a bill message according to the user number and the firewall message.

The storage module is configured to: establish and store a correspondence between the user IP address and the user number; the message receiving module is further configured to: query the correspondence between the user IP address and the user number stored in the storage module according to the user IP address The user number of the user.

The bill message processing module includes one or more bill message processing units;

The storage module is further configured to: store a correspondence between a user IP address and a processing unit that processes the user message;

The message receiving module is further configured to: after receiving the firewall log message, searching for the correspondence between the IP address and the processing unit in the storage module according to the IP address in the message, and storing the firewall message to the corresponding bill The cache queue corresponding to the message processing unit, if not, selects an idle bill message processing unit to process the firewall log message, and stores the firewall log message to the selected bill message processing unit.

The message processing unit is configured to: read a firewall log message in the corresponding cache queue, parse and verify whether the message is valid, and discard the message if invalid, and if the firewall message passes, assign a unique message to the message. CDR identification, and the information of the CDR field, the CDR identifier and the time stamp obtained after parsing is written into the CDR message structure; and, according to the parsed user IP address, whether the CDR processing unit stores the corresponding IP address. The address-user number correspondence is to splicing the queried user number and the fields in the CDR message structure into a single CDR message, and sending the CDR message to the CDR file generation module; if no IP address is stored - The user number correspondence relationship stores the parsed CDR message structure in the CDR message HASH table corresponding to the CDR message processing unit, and sends the user IP address and the CDR ID to the RADIUS server to query the user number.

After receiving the response message returned by the RADIUS server, the message receiving module queries the corresponding CDR message processing unit according to the user IP address, and if the query is successful, sends a response to the successful CDR message processing unit, which carries the user IP address, CDR ID and user number, if query If the failure occurs, the response to the query failure message is sent to the corresponding CDR message processing unit, where the user IP address and the CDR identifier are carried;

The CDR message processing unit is further configured to: after receiving the response of the query success, read the corresponding CDR message structure from the CDR message HASH table according to the CDR identifier, and configure each of the user number and the CDR message structure After the field is spliced into a CDR message, the CDR message is sent to the CDR file generating module. After receiving the response to the Query failure, the CDR message structure is read from the CDR message HASH table according to the CDR ID. The user number is set to 0 and the fields in the bill message structure are concatenated into a single bill message and sent to the bill file generating module.

The storage module establishes and stores a correspondence between the user IP address and the user number after receiving the response message of the query successfully returned by the RADIUS server.

In summary, the present invention provides an accounting server and method for processing an online service log. The technical solution of the present invention can reduce the frequency of access to the RADIUS server and the speed of generating the bill. BRIEF abstract

1 is a schematic diagram of a WAP-based socket online service log processing system according to an embodiment of the present invention; FIG. 2 is a processing flow of a WAP-based socket online service log processing system according to an embodiment of the present invention. Preferred embodiment of the invention

In order to solve the above technical problem, the present invention is achieved by the following technical solutions:

The embodiment provides a WAP-based socket online service log accounting server, as shown in FIG. 1 , which includes a message receiving module, a storage module, a bill message processing module, and a bill file generating module.

a storage module, configured to store a user number of the processed user and a correspondence between the user IP address and a processing unit that processes the user message; the storage module establishes and stores the user IP address after receiving the response message of the query successfully returned by the RADIUS server. Correspondence with the user number.

Here, the storage module can also store the user number in other ways, and the established correspondence can also be It is the correspondence between the user number and other user information except the user IP address.

The message receiving module is configured to receive a firewall log message sent by the WAP gateway firewall, and search for a correspondence between the IP address and the processing unit in the storage module according to the IP address in the message, and store the firewall log message to the corresponding message. The cache queue corresponding to the single message processing unit, if not, selects an idle bill message processing unit to process the firewall log message, and stores the firewall log message to the selected bill message processing unit.

The IP address-processing unit correspondence record records the CDR message processing unit of the user firewall log message, and the correspondence may be an IP address-processing unit HASH table.

The message receiving module is further configured to receive a response message returned by the RADIUS server, where the response message includes a user IP address, a bill identifier, a user number, and a query result status indicating whether the query is successful. If the status of the query result indicates that the query is successful, the corresponding information of the IP address-processing unit is queried according to the IP address of the user, and the corresponding message processing unit is sent, and then the response to the successful message is sent to the corresponding message processing unit, where the user IP address is carried. If the query result status indicates that the query fails, the query sends a query failure response to the corresponding bill message processing unit, where the user IP address and the bill identifier are carried;

The message receiving module is further configured to: after receiving the offline notification sent by the RADIUS server, search for the IP address-user number corresponding relationship according to the user number in the notification, and delete the corresponding relationship; and further delete the IP address-processing unit number. Correspondence relationship (ie HASH table of IP-address processing unit number).

The CDR message processing unit is configured to read the firewall log message in the corresponding cache queue, parse and verify whether the message is valid, and discard the message if invalid, and if the firewall message passes, assign a unique CDR to the message. Identifying, and writing the information of the CDR field, the CDR identifier, and the timestamp obtained in the CDR message structure; and querying whether the CDR message processing unit stores the corresponding IP address according to the parsed user IP address. - the corresponding relationship of the user number, the user number and the fields in the bill message structure are concatenated into a single bill message, and the bill message is sent to the bill file generating module; if the IP address is not stored - The user number correspondence structure stores the parsed CDR message structure in the CDR message HASH table corresponding to the CDR message processing unit, and sends the user IP address and the CDR ID to the RADIUS server to query the user number. The bill message processing unit is further configured to: after receiving the response of the query success, read the corresponding bill message structure from the bill message HASH table according to the bill identifier, and concatenate the user number and the fields in the bill message structure into a bill message, after which the bill message is sent to the bill file generating module; and after receiving the response to the query failure, the corresponding bill message structure is read from the bill message HASH table according to the bill identifier, and the user number is After being set to 0 and the fields in the bill message structure are spliced into a single message, the message is sent to the bill file generating module.

The bill message processing unit is further configured to delete the IP address-user number correspondence of the timeout when the IP address-user number correspondence timeout expires; and further delete the correspondence between the IP address and the processing unit number (ie, the IP address-processing unit number) HASH table).

The bill message processing unit is further configured to: when the bill message structure body is timed out, the timeout bill message structure is taken out, the corresponding user number is set to 0, and the bill message is formed together with the bill message structure body, and then sent to the bill file. Generate modules.

The CDR file generating module is configured to check whether the CDR message cache queue is full after receiving the CDR message, and if the CDR message queue is full, the CDR message in the buffer queue is written into the CDR file, and if not, the CDR will be received. The message is written to the cache queue.

In this embodiment, a cache queue is set for each message processing module, which reduces the time overhead caused by multiple message processing modules sharing the same message cache, and improves the efficiency of the message receiving module for distributing firewall log messages.

This embodiment provides a method for processing a socket-based online service log based on WAP. As shown in FIG. 2, the following processing procedure is included:

Step S1: The accounting server receives the firewall log message sent by the WAP gateway firewall. Step S2: The accounting server parses and verifies the firewall log message. If the verification is invalid, the message is discarded. The message is assigned a CDR identifier, and the information of the CDR field, the CDR identifier and the time stamp obtained after parsing is written into the CDR message structure;

Step S3: The accounting server queries whether the corresponding relationship between the IP address and the user number is stored according to the parsed user IP address, if yes, step S4 is performed; otherwise, step S5 is performed;

Step S4: The accounting server obtains the user number from the correspondence between the IP address and the user number, and the root Generating a bill message according to the user number and the bill message structure;

Step S5: The accounting server stores the CDR message structure, and sends an Query message to the RADIUS server, where the user IP address and the CDR ID are carried.

Step S6: The RADIUS server receives the query message, queries the user number according to the user IP address, and returns a response message to the accounting server, including the user IP address, the bill identifier, the user number, and the query result status. The query result status indicates the user number. Whether the query is successful;

Step S7: The accounting server receives the response message returned by the RADIUS server, if the query is successful, step S8 is performed, otherwise step S9 is performed;

Step S8: The accounting server locally establishes a correspondence between the user IP address and the user number, and reads the stored bill message structure according to the bill identifier, inserts the user number to generate a bill message; and then executes step S10;

The correspondence between the user IP address and the user number may be a HASH table of the user IP address-user number. Step S9: The accounting server reads the stored bill message structure according to the bill identifier, and sets the corresponding user number to 0 together with the bill. The message structure forms a bill message; then step S10 is performed;

Step S10: The accounting server checks whether the CDR message cache is full. When it is full, the CDR message is written to the CDR file. If the message cache is idle, the generated CDR message is written into the cache.

In the foregoing step S2, if the accounting server receives a large number of firewall log messages and cannot directly process the received firewall log messages, the firewall log messages may be cached first to form a cache queue, and the firewall logs in the cache queue may be processed in the order of receiving the messages. Message; The message can be parsed and verified when the message in the cache queue is processed.

The billing server can set multiple message processing units to process firewall log messages at the same time.

All firewall log messages during the same user's online period are processed by the same message processing unit. The accounting server also records the correspondence between the user IP address and the processing unit that processes the user message. The correspondence may be, but is not limited to, the user IP address-processing. Unit number HASH table; After receiving the firewall message, the accounting server queries the IP address-processing unit number HASH table according to the user IP address to learn the processing unit that processes the user firewall log message, and stores the firewall log message. To the cache queue of the corresponding processing unit. Each message processing unit corresponds to a cache queue for saving Firewall log messages distributed to this processing unit.

If the accounting server does not query the HASH table of the IP address-processing unit number according to the IP address, select an idle processing unit to process the message, preferably, the processing with the least number of cached messages according to the principle of load balancing Select a processing unit from the unit.

Each message processing unit corresponds to a CDR message HASH table. If the message processing unit fails to query the IP address-user number HASH table, the CDR message is temporarily saved in the CDR message HASH table corresponding to the unit number.

When receiving the offline notification from the RADIUS server, the accounting server searches for the IP address-user number corresponding relationship according to the user number in the notification and deletes the corresponding relationship; IP address - the correspondence between the processing unit numbers (ie, the IP address - the HASH table of the processing unit number).

If the IP address-user number correspondence time stored by the accounting server expires, the timeout IP address-user number correspondence is deleted; and then the correspondence between the IP address and the processing unit number is deleted (that is, the HASH table of the IP address-processing unit number) .

If the bill message structure is timed out, the timeout message structure is taken out, the corresponding user number is set to 0, and a bill message is formed together with the bill message structure.

In the present invention, by storing the IP address-processing module number correspondence relationship and the IP address-user number correspondence relationship, the user stores the user information and the assigned processing module number in the local storage module of the accounting server after using the socket online service for the first time. The firewall message generated by the subsequent access to the same user can quickly locate the module number of the last time the user message is processed, and allocate the message to the message cache corresponding to the module, thereby reducing the repeated query of the same user's access to the RADIUS server. . This two-level HASH query mechanism can reduce the frequency of access to the RADIUS server and the speed of bill generation.

One of ordinary skill in the art will appreciate that all or a portion of the above steps may be performed by a program to instruct the associated hardware, such as a read only memory, a magnetic disk, or an optical disk. Alternatively, all or part of the steps of the above embodiments may also be implemented using one or more integrated circuits. Correspondingly, each module/unit in the above embodiment can be used The form of hardware implementation can also be implemented in the form of software function modules. The invention is not limited to any specific form of combination of hardware and software.

The above description is only the preferred embodiment of the present invention, and is not intended to limit the present invention. Any modifications, equivalents, improvements, etc., which are included in the spirit and scope of the present invention, should be included in the present invention. Within the scope of protection.

Industrial Applicability The present invention provides an accounting server and method for processing an online service log. The technical solution of the present invention can reduce the frequency of access to the RADIUS server and the speed of bill generation.

Claims

Claim

A method for processing an online service log, comprising:

2. The method of claim 1 wherein

The charging server records the user number of the processed user, and the charging server establishes and stores a correspondence between the user IP address and the user number;

3. The method of claim 1 or 2, the method further comprising:

The billing server allocates a bill identifier for the firewall log message, and if the query user number fails, stores the parsed bill message structure, and sends a query message to the remote user dialing authentication system (RADIUS) server to query the user number; The query message carries the user IP address and the bill identifier.

4. The method of claim 3, the method further comprising:

After receiving the response message returned by the RADIUS server, the accounting server reads the stored bill message structure according to the bill identifier in the response message, and associates the user number in the response message with the bill message structure. Generate a bill message together;

5. The method of claim 2, wherein

6. The method of claim 1 or 2, the method further comprising:

If the receiving server receives the offline notification from the RADIUS server, the accounting server searches for the IP address-user number corresponding relationship according to the user number in the notification, deletes the corresponding relationship, and then deletes the IP address. Address - The correspondence between the processing unit numbers.

7. The method of claim 1 or 2, the method further comprising:

If the IP address-user number corresponding to the accounting server expires, the timeout IP address-user number correspondence is deleted, and the correspondence between the IP address and the processing unit number is deleted.

8. An accounting server for processing an online service log, comprising a message receiving module, a storage module, and a bill message processing module;

The storage module is configured to: store a user number of the processed user;

9. The billing server according to claim 8, wherein

10. The billing server according to claim 8 or 9, wherein

The billing server according to claim 10, wherein the bill message processing unit is configured to:

Read the firewall log message in the corresponding cache queue, parse and verify that the message is valid. If the message is invalid, the message is assigned a unique CDR ID, and the CDR status, CDR ID, and timestamp information obtained after parsing are written into the CDR message structure; Querying, according to the parsed user IP address, whether the CDR message processing unit stores the corresponding IP address-user number correspondence relationship, and then splicing the queried user number and the fields in the CDR message structure into one CDR message. And sending the CDR message to the CDR file generating module; if the IP address-user number mapping relationship is not stored, the CDR message structure that is parsed is stored in the CDR message HASH table corresponding to the CDR message processing unit, and Send the user IP address and bill ID to the RADIUS server to query the user ID.

12. The charging server according to claim 11, wherein the message receiving module is further configured to:

After receiving the response message returned by the RADIUS server, the corresponding CDR message processing unit is queried according to the user IP address. If the query succeeds, the response to the CDR message processing unit is sent to the corresponding CDR message processing unit, which carries the user IP address, the CDR identifier, and the user. If the query fails, the response to the query failure message is sent to the corresponding CDR message processing unit, where the user IP address and the CDR identifier are carried; the CDR message processing unit is further configured to: after receiving the response of the query successfully, according to the message The single identifier reads the corresponding CDR message structure from the CDR message HASH table, and splices the fields in the user number and the CDR message structure into a CDR message, and then sends the CDR message to the CDR file generation module; After receiving the response of the query failure, the corresponding bill message structure is read from the bill message HASH table according to the bill identifier, and the user number is set to 0 and the fields in the bill message structure are concatenated into a bill message and then sent. Generate a module for the bill file.

The charging server according to claim 12, wherein the storage module is configured to establish and store a correspondence between a user IP address and a user number in the following manner: receiving a response message that the query returned by the RADIUS server succeeds Then, the correspondence between the user IP address and the user number is established and stored.