CN103188405A - Method and system for synchronization order relation in value added service - Google Patents
Method and system for synchronization order relation in value added serviceDownload PDFInfo
- Publication number
- CN103188405A CN103188405ACN2011104479327ACN201110447932ACN103188405ACN 103188405 ACN103188405 ACN 103188405ACN 2011104479327 ACN2011104479327 ACN 2011104479327ACN 201110447932 ACN201110447932 ACN 201110447932ACN 103188405 ACN103188405 ACN 103188405A
- Authority
- CN
- China
- Prior art keywords
- database
- service
- ordering
- basic information
- relationship
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
- 238000000034methodMethods0.000titleclaimsabstractdescription41
- 238000004806packaging method and processMethods0.000claimsabstractdescription5
- 238000012545processingMethods0.000claimsdescription15
- 230000008569processEffects0.000claimsdescription4
- 230000001360synchronised effectEffects0.000description9
- 238000011161developmentMethods0.000description4
- 238000010586diagramMethods0.000description4
- 238000012986modificationMethods0.000description3
- 230000004048modificationEffects0.000description3
- 238000011160researchMethods0.000description3
- 241000238631HexapodaSpecies0.000description1
- 241000607479Yersinia pestisSpecies0.000description1
- 230000009286beneficial effectEffects0.000description1
- 230000005540biological transmissionEffects0.000description1
- 201000010099diseaseDiseases0.000description1
- 208000037265diseases, disorders, signs and symptomsDiseases0.000description1
- 238000009313farmingMethods0.000description1
- 230000006872improvementEffects0.000description1
- 230000002452interceptive effectEffects0.000description1
- 230000004044responseEffects0.000description1
- 238000012795verificationMethods0.000description1
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
Description
Technical Field
The present invention relates to the field of communications, and in particular, to a method and system for synchronizing subscription relationships in value added services.
Background
In the prior art, an information network integrates various networks, such as a mobile network, a data network and the internet, and provides value-added services for users in various ways. Wherein, SI (Service Integrator) provides Service, user orders the required Service, and information network sends the Service ordered by user to user. After receiving the subscription request of the user, the information network needs to synchronize the subscription relationship of the subscription request to the SI.
For example, the rural information network integrates resources such as a mobile network, a data network, and the internet, and provides agricultural information provided by agricultural departments, agricultural scientific research institutions, and agricultural-related enterprises to farmers through IVR (Interactive Voice Response) telephone Voice service, short message service, WEB sites, and the like. The agricultural departments, agricultural scientific research institutions and agricultural-related enterprises provide agricultural related services, and farmers order required services through information networks. After receiving an order request of a farmer user, an information network synchronizes an order relationship of the order request to a corresponding SI (service Hub Platform) through a BHP (Business Hub Platform), such as a government agricultural department, an agricultural scientific research institution or a farming enterprise. Furthermore, rural policies, agricultural laws and regulations, market information and scientific and technical information are timely sent to farmers through BHP, and information in aspects of agriculture, farmers, agricultural skills, farmer trade, market supply and demand, agricultural meteorology, early warning of plant diseases and insect pests and the like is provided for modern agricultural management.
The prior art solution for synchronizing subscription relationships is shown in fig. 1 and includes the following steps.
Step 101, a BOSS (Business Operation support System) receives a request of a user for subscribing a certain Business, locally stores the subscription relationship, and synchronizes the subscription relationship to a BHP.
And 102, receiving the BOSS synchronous subscription relationship by the BHP, locally storing the subscription relationship, and synchronizing the subscription relationship to the SI.
Step 103, the SI receives and saves the BHP synchronized subscription relationship.
The BOSS transmits the message of the ordering relationship to OrderReceiver service (ordering receiving service) in BHP by using HTTP protocol, the OrderReceiver service is WEB service, the OrderReceiver service receives the message of the ordering relationship, carries out service analysis on the message of the ordering relationship, and stores the analyzed ordering relationship in a database. And then, generating a message of the subscription relationship according to the format requirement specified by the SI, and transmitting the message of the subscription relationship to the URL address provided by the SI.
The prior art solution includes the following problems.
In the prior art, the synchronous service chain is too long, the synchronization between the BOSS and the BHP and the synchronization between the BHP and the SI are included in the service chain, and the too long service chain increases the possibility of generating risks.
In the prior art, a single database is used, and because the ordering relation synchronization involves the operation of a plurality of data tables, the single database is adopted, so that the pressure of the database is too large, and the synchronization speed is influenced.
In the prior art, a single service, an ordereceived service, is used, and only one service is provided to process BHP side services, so that the risk generation possibility is increased.
The prior art is not easy to expand, and when the concurrent processing amount needs to be improved, a large amount of development is needed to realize upgrading.
Disclosure of Invention
The invention provides a method and a system for synchronizing subscription relations in value-added services, which aim to solve the problem that the possibility of risk generation is increased due to overlong service chains.
The invention discloses a method for synchronizing an order relationship in a value added service, which comprises the following steps:
step 1, after receiving a request for ordering a service, a service operation support system forwards a message for packaging an ordering relation corresponding to the request to a service hub platform;
step 2, an order relation storage module of the service hub platform stores the order relation in the received message into a database;
and 3, periodically checking the database by a service integrator sending module of the service hub platform, reading the newly stored ordering relationship from the database after checking the newly stored ordering relationship in the database, and sending the newly stored ordering relationship to the service integrator for storage.
Wherein the database comprises a plurality of pool databases;
the step 2 further comprises:
and step 21, the order relation storage module stores the order relation in the received message to a corresponding pool database according to the configured rule.
Wherein the step 2 further comprises:
step 31, after receiving the message, the gateway module of the order relation storage module forwards the message to the receivers in the receiver cluster of the order relation storage module in a load balancing manner;
and step 32, after receiving the message, the receiver processes the message, analyzes the ordering relationship, and stores the ordering relationship in a database.
Wherein the database further comprises a global database;
the method further includes storing the configured base information to a global database;
the step 21 further comprises:
step 41, the order relation storage module reads basic information from the global database according to configured rules, and determines the class to which the received order relation belongs according to the basic information;
and 42, storing the received order relation to a pool database corresponding to the belonged class by the order relation storage module.
Wherein the database comprises a plurality of pool databases;
the storing the subscription relationship in a database further comprises:
step 51, the receiver sends the ordering relation to a data access layer module of a service hub platform;
step 52, the data access layer module stores the order relationship to the corresponding pool database according to the configured rule.
Wherein the step 3 further comprises:
step 61, the service integrator sending module periodically sends a check instruction to a data access layer module of the service hub platform;
step 62, the data access layer module queries the database according to the check instruction, reads the order relationship newly stored in the database, and sends the read order relationship to the service integrator sending module;
and 63, the service integrator sending module sends the received order relation to the service integrator for storage.
The method further comprises the steps of storing the basic information in the global database into a cache according to the configuration;
the step of reading the basic information from the global database by the subscription relation storage module according to the configured rule further comprises the following steps:
step 71A, the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule; or,
the step of reading the basic information from the global database by the subscription relation storage module according to the configured rule further comprises the following steps:
step 71B, the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule, and the read basic information is stored in the cache;
the method also comprises
And 72B, counting the called times of each piece of basic information in the cache, and periodically deleting the pieces of basic information, the called times of which are smaller than a preset threshold value, from the cache.
Wherein the method further comprises:
and step 81, when the data volume stored in the pool database exceeds a preset threshold value, modifying the configured rule, and dividing part of ordering relations correspondingly stored in the pool database into a new pool database for storage.
The invention also discloses a system for synchronizing the order relationship in the value added service, which comprises: the service operation support system comprises a service operation support system, a service integrator and a service hub platform, wherein the service hub platform comprises a database, a service integrator sending module and an ordering relation storage module;
the service operation support system is used for receiving a request for ordering the service and then forwarding a message for packaging the ordering relation corresponding to the request to the service hub platform;
the ordering relation storage module is used for storing the ordering relation in the received message into a database;
the service integrator sending module is used for periodically checking the database, reading the newly stored ordering relationship from the database and sending the ordering relationship to the service integrator after checking the newly stored ordering relationship in the database;
and the service integrator is used for storing the received subscription relation.
Wherein the database comprises a plurality of pool databases;
the ordering relation storage module is further used for storing the ordering relation in the received message to a corresponding pool database according to the configured rule;
or,
the subscription relationship storage module further comprises a gateway module and a receiver cluster,
the gateway module is used for forwarding the message to the receivers in the receiver cluster in a load balancing mode after receiving the message;
and the receiver is used for processing the message after receiving the message, analyzing the ordering relation and storing the ordering relation into a database.
The embodiment of the invention has the beneficial effects that: the ordering relationship is synchronized by periodically checking the newly stored ordering relationship in the database, so that a three-party synchronization mode in the prior art can be converted into a pairwise synchronization mode, and the risk caused by overlong service chain is avoided; by storing the ordering relationship into a plurality of pool databases, the database pressure can be reduced, and the synchronous processing capacity can be improved; by adopting a plurality of receivers to carry out load balancing, the synchronous processing speed can be improved, and the expansion is convenient; moreover, by adopting a plurality of receivers and a plurality of pool databases, after the traffic is greatly improved, the concurrent processing capacity of order relationship synchronization can be improved through simple configuration without secondary development; by using the global database and the cache, basic information can be conveniently inquired, and the processing speed is improved; the data access layer module is used for data access, so that the expansion is facilitated, and a plurality of functional modules are adopted to complete the synchronization of the ordering relationship, so that the risk of synchronization failure is reduced; the data in the pool database with excessive storage is divided again and stored in a shunting way, so that the requirement of increasing the amount of clients can be continuously met, and the processing capacity is improved.
Drawings
FIG. 1 is a diagram illustrating a prior art solution for synchronizing subscription relationships;
FIG. 2 is a flow chart of a method for synchronizing subscription relationships in value-added services according to the present invention;
fig. 3 is a schematic diagram of an embodiment of a method for synchronizing subscription relationships in value-added services according to the present invention;
FIG. 4 is a flowchart of an embodiment of a method for synchronizing subscription relationships in value-added services according to the present invention;
fig. 5 is a structural diagram of a system for synchronizing subscription relationships in value added services according to the present invention.
Detailed Description
In order to make the objects, technical solutions and advantages of the present invention more apparent, embodiments of the present invention will be described in detail with reference to the accompanying drawings.
Referring to fig. 2, it is a flowchart of a method for synchronizing subscription relationships in value added services provided in the present invention.
Step S100, after receiving the request for ordering the service, the BOSS (service operation support system) forwards a message encapsulating the ordering relationship corresponding to the request to the BHP (service hub platform).
Each request for subscribing the service corresponds to a subscription relationship between a user subscribing to the service and a service integrator providing the service.
Step S200, the subscription relation storage module of the BHP stores the subscription relation in the received message into a database.
In a preferred embodiment, the database comprises a plurality of pool databases.
The step S200 further includes that the subscription relationship storage module of the BHP stores the subscription relationship in the received message to the corresponding pool database according to the configured rule.
Further, the method also comprises the step of modifying the configured rule when the data volume stored in the pool database exceeds a preset threshold value, and dividing part of ordering relations correspondingly stored in the pool database into a new pool database for storage.
When the data volume stored in a certain pool database is too large and exceeds a preset threshold value to indicate that the stored data volume is too large, modifying the configured rule, dividing the ordering relation correspondingly stored in the pool database into a plurality of parts, wherein one part is still stored in the original pool database, and the other parts are stored in a new pool database.
Further, the database also comprises a global database; and storing the configured basic information into a global database. For example, the configured base information is stored to the global database before the BHP begins to receive messages.
The step of storing the subscription relationship in the received message to the corresponding pool database by the subscription relationship storage module of the BHP according to the configured rule further includes:
step S210A, the subscription relationship storage module reads the basic information from the global database according to the configured rule, and determines the class to which the received subscription relationship belongs according to the basic information.
The configured rules prescribe a standard for classifying the ordering relations, relevant basic information in the global database is read according to the standard, and the class to which the ordering relations belong is determined according to the read basic information.
For example, the basic information includes area data, commodity data, and number segment data. The region data is a corresponding relation table of the number segment and the region to which the number segment belongs, the number segment data is a corresponding relation table of the mobile phone number and the number segment to which the mobile phone number belongs, and the commodity data comprises description information of each service and the URL address of the SI of the service. And if the configured rules specify that the mobile phone numbers of the users who subscribe the service belong to the number segments, reading the number segment data, and determining the number segments to which the mobile phone numbers of the users who subscribe the service belong, wherein the subscription belongs to the class corresponding to the number segments. Wherein each class corresponds to a pool database.
Step S220A, the order relation storage module stores the received order relation in the pool database corresponding to the belonging class.
Further, the basic information is stored by using the cache, and the reading speed of the basic information is improved.
In a specific embodiment, before the BHP starts receiving the packet, the basic information in the global database is stored in the cache according to the configuration. For example, part of the basic information in the global database is stored in the cache according to the configuration.
The step of reading the basic information from the global database by the subscription relationship storage module of the BHP according to the configured rule further comprises: and the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule. When the basic information in the global database is changed, the information stored in the cache is synchronously updated.
In another embodiment, the step of the BHP's subscription relationship storage module reading the basic information from the global database according to the configured rule further comprises: and the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule, and the read basic information is stored in the cache. The method further comprises the steps of counting the calling times of each piece of basic information in the cache, and deleting the basic information of which the calling times are smaller than a preset threshold value from the cache periodically. When the basic information in the global database is changed, the information stored in the cache is synchronously updated.
By the method, the hotspot basic information can be stored in the cache, the hit rate of searching the basic information in the cache is improved, and the reading speed of the basic information is further improved.
In another preferred embodiment, the step S200 further includes
Step S210B, after receiving the message, the gateway module of the subscription relationship storage module forwards the message to the receiver in the receiver cluster of the subscription relationship storage module in a load balancing manner.
The load balancing manner is a manner of balancing the number of messages processed by each receiver in the receiver cluster, and includes various specific implementation manners. For example, polling a receiver in a receiver cluster to forward a message to the polled receiver, specifically, the polling method is to sort the receivers in the receiver cluster, forward the message to a receiver next to the receiver that received the message last time, and forward the message to a first receiver in the sort when the receiver that received the message last time is the last receiver in the sort; or, for another example, forward the message to the receiver with the fewest messages currently waiting to be processed by the receiver cluster.
Step S220B, after the receiver receives the message, it processes the message, analyzes the order relationship, and stores the order relationship in the database.
The message processing comprises message analysis and message validity verification.
Wherein the database comprises a plurality of pool databases; the storing the subscription relationship in the database further comprises:
step S221, the receiver sends the subscription relationship to the data access layer module.
Step S222, the data access layer module stores the order relationship to the corresponding pool database according to the configured rule.
Step S300, the service integrator sending module of the BHP periodically checks the database, and after checking the new stored subscription relationship in the database, reads the new stored subscription relationship from the database and sends it to the SI (service integrator) for storage.
In a preferred embodiment, the step S300 further includes the following steps.
Step S310, the service integrator sending module periodically sends a check instruction to the data access layer module of the BHP.
Step S320, the data access layer module checks the database according to the check instruction, reads the new stored ordering relationship in the database, and sends the read ordering relationship to the service integrator sending module.
Step S330, the service integrator sending module sends the received order relation to the SI for storage. Fig. 3 is a schematic diagram of an embodiment of a method for synchronizing subscription relationships in value-added services according to the present invention.
In the prior art, the function realized by the OrderReceiver service is realized by a gateway module, a receiver cluster, a data access layer module and a service integrator sending module together.
The database is divided into two types of databases by a single database in the prior art, namely a global database and a pool database, wherein the pool database is multiple and corresponds to the classification of the ordering relationship.
The global database stores basic information such as: region data, commodity data, number segment data, and the like. The region data is a corresponding relation table of the number segment and the region to which the number segment belongs, the number segment data is a corresponding relation table of the mobile phone number and the number segment to which the mobile phone number belongs, and the commodity data comprises description information of each service and the URL address of the SI of the service. The basic information provides support for completing the storage of the ordering relationship.
In addition, in this embodiment, a part of the basic information is cached according to configuration, so as to reduce access to the global database, improve the synchronization processing speed, and alleviate the database pressure.
The pool database stores the subscription relationships and other corresponding data of the subscription relationships, such as user information corresponding to the subscription relationships. The pool database is a plurality of, and the configured rules specify the standard for classifying the ordering relationship, for example, classifying according to number segments, each segment corresponding to one class, or classifying according to the area where the mobile phone number of the user is located, each area corresponding to one class. Each pool database stores a class of subscription relationships. In this embodiment, the classification is performed according to regions, and each region corresponds to one class.
When the data volume in a certain pool database is excessive due to the development of services, for example, exceeds a preset threshold value, the configured rule is modified, and part of ordering relations correspondingly stored in the pool database are divided into a new pool database for storage, so that the database access speed is improved.
Referring to fig. 4, it is a flowchart of an embodiment of the method for synchronizing subscription relationships in value added services according to the present invention.
Step S401, after the BOSS receives the request of the order service, the message of the order relation corresponding to the request is transmitted to the BHP through the HTTP protocol.
Step S402, after receiving the message, the gateway module forwards the received message to a receiver in the receiver cluster through an RPC (Remote Procedure Call Protocol) Protocol in a load balancing manner.
In this embodiment, the load balancing manner is to poll the receivers in the receiver cluster, and forward a packet to the polled receivers.
Step S403, after the receiver receives the message, the receiver verifies the validity of the message, analyzes the message to obtain the ordering relationship, and sends the ordering relationship to the data access layer module through the RPC protocol.
Step S404, the data access layer module determines the basic information to be read according to the configured rule, searches the basic information to be read from the cache, reads the searched basic information if the basic information to be read is found, and otherwise, searches the basic information to be read from the global database and reads the basic information to be read.
In this embodiment, since the classification is performed by area, the basic information to be read is number segment data and area data.
Step S405, the data access layer module determines the class to which the received order relation belongs according to the basic information, and stores the order relation in a pool database corresponding to the class to which the order relation belongs.
In this embodiment, the data access layer module determines, according to the number segment data, a number segment where the mobile phone number of the user in the ordering relationship is located, and then searches for an area to which the number segment belongs according to the area information, obtains an area to which the user number of the ordering relationship belongs, and further determines a class to which the ordering relationship belongs.
In step S406, the pool database copies the newly stored subscription relationship into a temporary table.
Step S407, the service integrator sending module sends a check instruction to the data access layer module periodically through the RPC protocol.
Step S408, the data access layer module queries the temporary table of the pool database according to the check instruction, reads the order relation stored in the temporary table, sends the read order relation to the service integrator sending module, and deletes the information in the temporary table.
Step S409, the service integrator sending module generates a message according to the received order relation and sends the message to the SI for storage.
According to the embodiment, the service integrator sending module periodically indicates the data access layer module to check the order relation newly stored in the database, so that the order relation is synchronized, a three-party synchronization mode in the prior art can be converted into a pairwise synchronization mode, and risks caused by overlong service chains are avoided; by storing the ordering relationship into a plurality of pool databases, the database pressure can be reduced, and the synchronous processing capacity can be improved; by adopting a plurality of receivers to carry out load balancing, the synchronous processing speed can be improved, and the expansion is convenient; moreover, by adopting a plurality of receivers and a plurality of pool databases, after the traffic is greatly improved, the concurrent processing capacity of order relationship synchronization can be improved through simple configuration without secondary development; by using the global database and the cache, basic information can be conveniently inquired, and the processing speed is improved; by using the data access layer module for data access, the expansion can be facilitated; by the aid of the method, functions realized by OrderReceiver services in the prior art are realized by a gateway module, a receiver cluster, a data access layer module and a service integrator sending module together, and synchronization failure risks can be reduced.
Fig. 5 shows a system for synchronizing subscription relationships in value-added services according to the present invention.
The system comprises: the serviceoperation support system 100, theservice integrator 300, and the service hub platform 200, wherein the service hub platform 200 includes a subscription relationship storage module 210, a database 220, and a service integrator transmission module 230.
The serviceoperation support system 100 is configured to, after receiving a request for ordering a service, forward a message encapsulating an ordering relationship corresponding to the request to the service hub platform 200.
And a subscription relation storage module 210, configured to store the subscription relation in the received message in a database 220.
The service integrator sending module 230 is configured to periodically check the database, and after checking that the subscription relationship is newly stored in the database 220, read the newly stored subscription relationship from the database 220 and send the newly stored subscription relationship to theservice integrator 300.
Aservice integrator 300 for storing the received subscription relationship.
Further, the database comprises a plurality of pool databases;
the order relation storage module is further used for storing the order relation in the received message to a corresponding pool database according to the configured rule.
Further, the subscription relationship storage module further comprises a gateway module and a receiver cluster,
the gateway module is used for forwarding the message to the receivers in the receiver cluster in a load balancing mode after receiving the message;
and the receiver is used for processing the message after receiving the message, analyzing the ordering relation and storing the ordering relation into a database.
Wherein the database comprises a plurality of pool databases; the service hub platform further comprises a data access layer module,
the receiver is further configured to send the subscription relationship to a data access layer module when storing the subscription relationship in a database;
and the data access layer module is used for storing the ordering relation to the corresponding pool database according to the configured rule.
Further, the database also comprises a global database for storing basic information of the configuration;
the ordering relation storage module is further used for reading basic information from a global database according to configured rules and determining the class to which the received ordering relation belongs according to the basic information; and storing the received order relation to a pool database corresponding to the belonged class.
The service hub platform also comprises a cache for storing the basic information in the global database according to the configuration;
the ordering relation storage module is further used for searching the basic information from the cache according to the configured rule when reading the basic information from the global database according to the configured rule, if the basic information is searched, the searched basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule.
The service hub platform further comprises a cache;
the ordering relation storage module is further used for searching the basic information from the cache according to the configured rule when reading the basic information from the global database according to the configured rule, if the basic information is searched, the searched basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule, and the read basic information is stored in the cache.
The service hub platform further comprises an update module,
and the updating module is used for counting the called times of each piece of basic information in the cache and deleting the basic information of which the called times are smaller than a preset threshold value from the cache regularly.
Further, the service hub platform also comprises a data access layer module,
the service integrator sending module is further used for periodically sending a checking instruction to a data access layer module of the service hub platform; sending the received ordering relation to a service integrator for storage;
and the data access layer module is used for inquiring the database according to the check instruction, reading the ordering relationship newly stored in the database and sending the read ordering relationship to the service integrator sending module.
Further, the service hub platform further comprises a rule modification module, wherein the rule modification module is used for modifying configured rules when the data volume stored in the pool database exceeds a preset threshold value, and dividing part of ordering relationships stored in the pool database into a new pool database for storage.
The above description is only for the preferred embodiment of the present invention, and is not intended to limit the scope of the present invention. Any modification, equivalent replacement, or improvement made within the spirit and principle of the present invention shall fall within the protection scope of the present invention.
Claims (10)
1. A method for synchronizing subscription relationship in value-added service is characterized in that the method comprises the following steps:
step 1, after receiving a request for ordering a service, a service operation support system forwards a message for packaging an ordering relation corresponding to the request to a service hub platform;
step 2, an order relation storage module of the service hub platform stores the order relation in the received message into a database;
and 3, periodically checking the database by a service integrator sending module of the service hub platform, reading the newly stored ordering relationship from the database after checking the newly stored ordering relationship in the database, and sending the newly stored ordering relationship to the service integrator for storage.
2. The method for synchronizing subscription relationship in value added services according to claim 1,
the database comprises a plurality of pool databases;
the step 2 further comprises:
and step 21, the order relation storage module stores the order relation in the received message to a corresponding pool database according to the configured rule.
3. The method for synchronizing subscription relationship in value added services according to claim 1,
the step 2 further comprises:
step 31, after receiving the message, the gateway module of the order relation storage module forwards the message to the receivers in the receiver cluster of the order relation storage module in a load balancing manner;
and step 32, after receiving the message, the receiver processes the message, analyzes the ordering relationship, and stores the ordering relationship in a database.
4. The method for synchronizing subscription relationship in value added services according to claim 2,
the database further comprises a global database;
the method further includes storing the configured base information to a global database;
the step 21 further comprises:
step 41, the order relation storage module reads basic information from the global database according to configured rules, and determines the class to which the received order relation belongs according to the basic information;
and 42, storing the received order relation to a pool database corresponding to the belonged class by the order relation storage module.
5. A method for synchronizing subscription relations in a value added service according to claim 3,
the database comprises a plurality of pool databases;
the storing the subscription relationship in a database further comprises:
step 51, the receiver sends the ordering relation to a data access layer module of a service hub platform;
step 52, the data access layer module stores the order relationship to the corresponding pool database according to the configured rule.
6. The method for synchronizing subscription relationship in value added services according to claim 1,
the step 3 further comprises:
step 61, the service integrator sending module periodically sends a check instruction to a data access layer module of the service hub platform;
step 62, the data access layer module queries the database according to the check instruction, reads the order relationship newly stored in the database, and sends the read order relationship to the service integrator sending module;
and 63, the service integrator sending module sends the received order relation to the service integrator for storage.
7. The method for synchronizing subscription relationships in value added services according to claim 4,
the method further comprises storing the basic information in the global database into a cache according to the configuration;
the step of reading the basic information from the global database by the subscription relation storage module according to the configured rule further comprises the following steps:
step 71A, the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule; or,
the step of reading the basic information from the global database by the subscription relation storage module according to the configured rule further comprises the following steps:
step 71B, the ordering relation storage module searches the basic information from the cache according to the configured rule, if the basic information is found, the found basic information is read, otherwise, the basic information is searched and read from the global database according to the configured rule, and the read basic information is stored in the cache;
the method also comprises
And 72B, counting the called times of each piece of basic information in the cache, and periodically deleting the pieces of basic information, the called times of which are smaller than a preset threshold value, from the cache.
8. The method for synchronizing subscription relationship in value added services according to claim 2,
the method further comprises the following steps:
and step 81, when the data volume stored in the pool database exceeds a preset threshold value, modifying the configured rule, and dividing part of ordering relations correspondingly stored in the pool database into a new pool database for storage.
9. A system for synchronizing subscription relationships in value added services, the system comprising: the service operation support system comprises a service operation support system, a service integrator and a service hub platform, wherein the service hub platform comprises a database, a service integrator sending module and an ordering relation storage module;
the service operation support system is used for receiving a request for ordering the service and then forwarding a message for packaging the ordering relation corresponding to the request to the service hub platform;
the ordering relation storage module is used for storing the ordering relation in the received message into a database;
the service integrator sending module is used for periodically checking the database, reading the newly stored ordering relationship from the database and sending the ordering relationship to the service integrator after checking the newly stored ordering relationship in the database;
and the service integrator is used for storing the received subscription relation.
10. The system for synchronizing subscription relationships in value added services according to claim 9,
the database comprises a plurality of pool databases;
the ordering relation storage module is further used for storing the ordering relation in the received message to a corresponding pool database according to the configured rule;
or,
the subscription relationship storage module further comprises a gateway module and a receiver cluster,
the gateway module is used for forwarding the message to the receivers in the receiver cluster in a load balancing mode after receiving the message;
and the receiver is used for processing the message after receiving the message, analyzing the ordering relation and storing the ordering relation into a database.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201110447932.7ACN103188405B (en) | 2011-12-28 | 2011-12-28 | The method and system of synchronous order relations in a kind of value-added service |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201110447932.7ACN103188405B (en) | 2011-12-28 | 2011-12-28 | The method and system of synchronous order relations in a kind of value-added service |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN103188405Atrue CN103188405A (en) | 2013-07-03 |
| CN103188405B CN103188405B (en) | 2015-10-28 |
Family
ID=48679363
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201110447932.7AActiveCN103188405B (en) | 2011-12-28 | 2011-12-28 | The method and system of synchronous order relations in a kind of value-added service |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN103188405B (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109819123A (en)* | 2017-11-21 | 2019-05-28 | 中兴通讯股份有限公司 | A kind of implementation method of value-added service, device and industrial application Authentication Center |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20020068567A1 (en)* | 2000-12-04 | 2002-06-06 | Staffan Johansson | Using statistically ascertained position for starting synchronization searcher during diversity handover |
| CN102104858A (en)* | 2009-12-17 | 2011-06-22 | 中国联合网络通信集团有限公司 | Method and system for ordering value added service |
- 2011
- 2011-12-28CNCN201110447932.7Apatent/CN103188405B/enactiveActive
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20020068567A1 (en)* | 2000-12-04 | 2002-06-06 | Staffan Johansson | Using statistically ascertained position for starting synchronization searcher during diversity handover |
| CN102104858A (en)* | 2009-12-17 | 2011-06-22 | 中国联合网络通信集团有限公司 | Method and system for ordering value added service |
Non-Patent Citations (1)
| Title |
|---|
| 刘帅: "移动公司吉林分公司增值业务综合运营平台的设计与实现", 《信息科技辑》, 15 September 2011 (2011-09-15), pages 1 - 62* |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109819123A (en)* | 2017-11-21 | 2019-05-28 | 中兴通讯股份有限公司 | A kind of implementation method of value-added service, device and industrial application Authentication Center |
| WO2019101082A1 (en)* | 2017-11-21 | 2019-05-31 | 中兴通讯股份有限公司 | Value-added service implementation method and device, and industry application authentication center |
Also Published As
| Publication number | Publication date |
|---|---|
| CN103188405B (en) | 2015-10-28 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US6985747B2 (en) | Use of triggers and a location hypercube to enable push-based location applications | |
| CN103051667B (en) | Distributing multi-source push notifications to multiple targets | |
| CN101197694B (en) | Central statistics and processing system and method for communication system log | |
| CN100589606C (en) | A short message query analysis system and method | |
| JP2012526314A (en) | System and method for analyzing behavioral and contextual data | |
| US20130067025A1 (en) | Target subscription for a notification distribution system | |
| WO2007115477A1 (en) | Data synchronization method und system | |
| CN102224516A (en) | Controlling transmission of a content item to a user terminal by independently transmitting additional content to the user terminal | |
| CN101667179A (en) | Mobile search method and system, and method for synchronizing search capability of search server | |
| US20120023065A1 (en) | System and method for managing data on an occasionally connected mobile device | |
| CN111552885A (en) | System and method for realizing automatic real-time message pushing operation | |
| CN110110196A (en) | A kind of information push method and device | |
| CN103037000B (en) | Publish-subscribe system and notification message processing method thereof | |
| CN108197263A (en) | Method of data synchronization | |
| CN1319323C (en) | Method for implementing multi-channel warning service and warning managing system | |
| CN106599068A (en) | Scientific and technical literature information retrieval system of maker venture capital investment space | |
| US10171963B2 (en) | Call transfer method and terminal | |
| CN101667932A (en) | Method of network element equipment log management and device | |
| CN103188405B (en) | The method and system of synchronous order relations in a kind of value-added service | |
| US9749426B2 (en) | Method, system, and apparatus for agent-based architecture for integrated mobile applications | |
| CN101924815A (en) | 3G MOA phone middleware embedded system | |
| US20070207774A1 (en) | System for compiling data from call event information | |
| CN106331027A (en) | Information pushing method, pushing device and system | |
| CN101715176A (en) | Short message router, short message monitoring system and short message monitoring method | |
| CN113468340B (en) | Construction system and construction method of industrial knowledge graph |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C14 | Grant of patent or utility model | ||
| GR01 | Patent grant | ||
| CP02 | Change in the address of a patent holder | ||
| CP02 | Change in the address of a patent holder | Address after:Room 810, 8 / F, 34 Haidian Street, Haidian District, Beijing 100080 Patentee after:BEIJING D-MEDIA COMMUNICATION TECHNOLOGY Co.,Ltd. Address before:100089 Beijing city Haidian District wanquanzhuang Road No. 28 Wanliu new building 6 storey block A room 602 Patentee before:BEIJING D-MEDIA COMMUNICATION TECHNOLOGY Co.,Ltd. |