CN105376155B - A kind of Intelligent routing system and method based on distributed type assemblies framework - Google Patents
A kind of Intelligent routing system and method based on distributed type assemblies framework Download PDFInfo
- Publication number
- CN105376155B CN105376155B CN201510662218.8A CN201510662218A CN105376155B CN 105376155 B CN105376155 B CN 105376155B CN 201510662218 A CN201510662218 A CN 201510662218A CN 105376155 B CN105376155 B CN 105376155B
- Authority
- CN
- China
- Prior art keywords
- gateway
- network element
- routing
- client
- routing iinformation
- 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.)
- Active
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/14—Routing performance; Theoretical aspects
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/12—Avoiding congestion; Recovering from congestion
- H04L47/125—Avoiding congestion; Recovering from congestion by balancing the load, e.g. traffic engineering
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Mobile Radio Communication Systems (AREA)
Abstract
The present invention relates to a kind of Intelligent routing system and methods based on distributed type assemblies framework, including client, load equalizer, interface network element, transmission network element and gateway；Interface network element realizes route filtering for the downlink mobile message to client push according to the routing policy of selection；Network element is sent, for realizing route filtering to the state report and uplink mobile message of gateway push respectively；Load equalizer, for according to the recent route information and the corresponding routing policy of operator's model selection in shared storage.It has by the invention been realized, develop a set of Intelligent routing system based on distributed type assemblies framework on mobile message comprehensive platform, ensure that the high-speed operations of mobile message data with it is concurrent.
Description
Technical field
The present invention relates to the present invention relates to the information technology field for notification broadcast and data exchange, it is related to telecom communication
Technology, Internet architecture technology, mobile Internet mechanics of communication, more particularly to a kind of intelligent road based on distributed type assemblies framework
By system and method.
Background technology
1 telecom operators' interface model associated specifications and professional standard；
2 telecom operators, group customer mobile message application safety standard requirements；
The progress of the communication technology, universal and mobile communications network the capability improving of mobile terminal are that mobile information service exists
The popularization of China brings opportunity.In face of based on financial industry, communications and transportation, e-commerce, retail commerce and trade, cultural medium,
The demand that the fields such as public service constantly change, deepen proposes more autgmentability and opening, more to mobile information service
Standardization, standardization, more healthy and stronger, stable requirement are in urgent need load balancing.
Traditional industry mobile information service is using China Mobile's MAS machines as the mobile information service platform of representative.This is flat
Platform uses the entrusted management model of ADC (Application Data Center) Application Data Center, needs to establish MAS servers
In the interior net side of industry group customer, input and maintenance cost are high, are unable to Quick Extended exploitation, and installation and deployment are cumbersome.Standard MAS
Machine cannot be satisfied the individual demand of mechanism, and the MAS machines manufacturer of China Mobile cannot provide the technological service of customization.
Invention content
It is an object of the present invention to provide a kind of Intelligent routing system and methods based on distributed type assemblies framework, solve existing skill
The above problem present in art.
The technical solution that the present invention solves above-mentioned technical problem is as follows：
A kind of Intelligent routing system based on distributed type assemblies framework, including client, load equalizer, interface network element,
Send network element and gateway；
The interface network element reads the net element information of itself from database when being used for system and starting, and by the net of itself
Metamessage is synchronized to shared storage, and routing iinformation is generated for sending network element；It is used to periodically collect the routing iinformation of client, and
The routing iinformation of client in the shared storage of update；It is used to update the routing iinformation of its own；It is additionally operable to client
The downlink mobile message of push realizes route filtering according to the routing policy of selection；
The transmission network element reads the net element information of itself from database when being used for system and starting, and by the net of itself
Metamessage is synchronized to shared storage, and routing iinformation is generated for interface network element；It is used to periodically collect the routing iinformation of gateway, and more
The routing iinformation of gateway in new shared storage；It is used to update the routing iinformation of its own；It is additionally operable to respectively push away gateway
The state report and uplink mobile message sent realize route filtering；
The load equalizer is used for corresponding according to the recent route information and operator's model selection shared in storage
Routing policy.
The beneficial effects of the invention are as follows：Realize developed on mobile message comprehensive platform it is a set of be based on distributed type assemblies frame
The Intelligent routing system of structure, ensure that the high-speed operations of mobile message data with it is concurrent.Interface network element carries out routing letter in time
Breath update, can effectively avoid error in data from pushing to different interface network elements；And it can realize that client passes through load balancing
Mechanism, smart allocation effectively avoid the overall process efficiency caused by machine performance difference from declining to different interface network elements
The problem of.
Based on the above technical solution, the present invention can also be improved as follows.
Further, the routing iinformation includes downstream routing information and uplink routing iinformation；Different routing iinformations uses
Different MAP mechanism are stored；
The downstream routing information includes channel group ID, carrier ID, gateway ID, module I D, gateway service code, gateway
Service code ID, charge type, accounting code and long code；Wherein, the channel group ID, carrier ID and gateway ID joints are made
It is used for Key, the module I D, gateway service code, gateway service code ID, charge type, accounting code and long code are made
It is used for Value；
The uplink routing iinformation includes channel group ID, carrier ID, gateway ID, client id, gateway service code, closes
Key word, keyword match rule, long code, long code matching rule, type of message and the affiliated province number of mobile phone；Wherein, described
Carrier ID, gateway ID, keyword, keyword match rule, long code and long code matching rule joint are used as Key,
The channel group ID, client id, gateway service code, type of message and the affiliated province number of mobile phone are used as Value.
Advantageous effect using above-mentioned further scheme is route by downstream routing and uplink, on the one hand by interface net
Member and gateway organic combination ensure that data can rationally be exchanged according to the given requirements of routing setting；On the other hand logical
Routing iinformation is crossed, information is subjected to completion, such as the information that interface network element receives, by downstream routing, completion difference gateway needs
Call parameter, these parameters are stored in the value of routing iinformation.Routing iinformation provides for realization distributed cluster system
Basic data, while also basic data and reference frame are provided for the selection of routing policy.
Further, the routing policy includes elementary tactics, balance policy and active and standby strategy；
The elementary tactics refers to only connecting operator by a server providing services, for multichannel in same system
When being managed in system, according to customer requirement, it is distributed to different gateways, each gateway does not have relevance, respectively independent；
The balance policy refers to providing to service connection operator by multiple servers, the equal shunt volume of multiple servers,
Load is spread out；
The active and standby strategy refers to providing service connection operator by multiple servers, and multiple servers can provide clothes
Business, is detected server by system, when a wherein system crash, automatically switches data and is serviced to another
Device.
Further, the interface network element includes the first collecting unit, the first receiving unit and processing unit；
First collecting unit reads the net element information of corresponding interface network element from database when being used for system startup,
And the net element information of corresponding interface network element is synchronized to shared storage, generate routing iinformation for sending network element；It is additionally operable to periodically
The routing iinformation of client is collected, and updates the routing iinformation of the client in shared storage；It is additionally operable to update corresponding interface
The routing iinformation of network element；
First receiving unit is used to receive the downlink mobile message of client push；
The processing unit is used to judge the routing iinformation of downlink mobile message；When routing iinformation meets road
By requiring, according to the routing policy of selection, downlink mobile message is pushed into down queue；It is wanted when routing iinformation is unsatisfactory for routing
It asks, downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The transmission network element includes the second collecting unit, the second receiving unit, matching unit and transmission unit；
When being used for system startup, the corresponding net element information for sending network element is read from database for second collecting unit,
And the corresponding net element information for sending network element is synchronized to shared storage, generate routing iinformation for interface network element；It is additionally operable to periodically
The routing iinformation of gateway is collected, and updates the routing iinformation of the gateway in shared storage；It is additionally operable to update corresponding transmission network element
Routing iinformation；
Second receiving unit is used to receive the state report of gateway push；It is additionally operable to receive gateway push
Uplink mobile message；
The matching unit, the routing iinformation progress of the state report for being used to receive and downlink mobile message
Match；Such as successful match, the routing iinformation of the client in state report and the recent route information in shared storage are compared
Compared with the interface server address of acquisition downstream client connection；If it fails to match, state report is pushed into unsuccessfully queue, it is accurate
Standby storage；It is additionally operable to by the routing iinformation of the client in uplink mobile message and the recent route information in shared storage into
Row compares, and obtains the interface server address of uplink client connection；
The transmission unit is used for state report with pushing to the interface server being connect with the downstream client
The corresponding interface network element in location；It is additionally operable to uplink mobile message pushing to the interface server connecting with the uplink client
The corresponding interface network element in address.
Advantageous effect using above-mentioned further scheme is to receive mobile message and processing is bound；And downlink team
It is classified as memory queue, reduces storage write-in number；Improve system finishing treatment effeciency.
Further, described collect uses broadcast mechanism；The push uses pub/sub push-mechanisms；The prison of the push
It listens using obstruction thread dormancy awakening mechanism.
Advantageous effect using above-mentioned further scheme is, by broadcast mechanism collect & route information, effectively avoids collecting
Because shared data is asynchronous in mechanism, lead to treatment mechanism different problems；Active push is combined with shared storage, is reduced
The push server for having to rely on single-point, is stored by Distributed sharing, and structure is more clear, and eliminates single-point risk；It monitors
Shared storage ensure that system structure is more stablized, and ensure that system performance while reducing monitoring pressure, improve reality
Shi Xing.
Another technical solution of the present invention is as follows：
A kind of method for intelligently routing based on distributed type assemblies framework, includes the following steps：
Step 1, when system starts, each interface network element reads the net element information of itself from database respectively, and by itself
Net element information is synchronized to shared storage, and routing iinformation is generated for sending network element；Each network element that sends reads itself from database respectively
Net element information, and the net element information of itself is synchronized to shared storage, routing iinformation is generated for interface network element；
Step 2, interface network element periodically collects the routing iinformation of client, updates the routing letter of the client in shared storage
Breath, and update the routing iinformation of its own；The routing iinformation that network element periodically collects gateway is sent, the gateway in shared storage is updated
Routing iinformation, and update the routing iinformation of its own；
Step 3, load equalizer is according to the recent route information and the corresponding road of operator's model selection shared in storage
By strategy；
Step 4, interface network element is routed through the downlink mobile message of client push according to the routing policy realization of selection
Filter；It sends network element and route filtering is realized to the state report that gateway pushes；Letter is moved to the uplink that gateway pushes with network element is sent
Breath realizes route filtering.
Based on the above technical solution, the present invention can also be improved as follows.
Further, the routing iinformation includes downstream routing information and uplink routing iinformation；Different routing iinformations uses
Different MAP mechanism are stored；
The downstream routing information includes channel group ID, carrier ID, gateway ID, module I D, gateway service code, gateway
Service code ID, charge type, accounting code and long code；Wherein, the channel group ID, carrier ID and gateway ID joints are made
It is used for Key, the module I D, gateway service code, gateway service code ID, charge type, accounting code and long code are made
It is used for Value；
The uplink routing iinformation includes channel group ID, carrier ID, gateway ID, client id, gateway service code, closes
Key word, keyword match rule, long code, long code matching rule, type of message and the affiliated province number of mobile phone；Wherein, described
Carrier ID, gateway ID, keyword, keyword match rule, long code and long code matching rule joint are used as Key,
The channel group ID, client id, gateway service code, type of message and the affiliated province number of mobile phone are used as Value.
Further, the routing policy includes elementary tactics, balance policy and active and standby strategy；
The elementary tactics refers to only connecting operator by a server providing services, for multichannel in same system
When being managed in system, according to customer requirement, it is distributed to different gateways, each gateway does not have relevance, respectively independent；
The balance policy refers to providing to service connection operator by multiple servers, the equal shunt volume of multiple servers,
Load is spread out；
The active and standby strategy refers to providing service connection operator by multiple servers, and multiple servers can provide clothes
Business, is detected server by system, when a wherein system crash, automatically switches data and is serviced to another
Device.
Further, the interface network element realizes the downlink mobile message of client push according to the routing policy of selection
Route filtering is implemented as, and interface network element receives the downlink mobile message of client push, and to downlink mobile message
Routing iinformation is judged；When routing iinformation meets route request, according to the routing policy of selection, downlink mobile message is pushed
To down queue；When routing iinformation is unsatisfactory for route request, downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the state report that gateway pushes, and sends network element and receives
The state report of gateway push, state report is matched with the routing iinformation of downlink mobile message；Such as successful match, by shape
The routing iinformation of client in state report is compared with the recent route information in shared storage, is obtained downstream client and is connected
The interface server address connect, and the interface server address that state report is pushed to the downstream client connects is corresponding
Interface network element；If it fails to match, state report is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the uplink mobile message that gateway pushes, and sends network element
The uplink mobile message for receiving gateway push by the routing iinformation of the client in uplink mobile message and is shared in storage most
New routing information is compared, and obtains the interface server address of uplink client connection；And uplink mobile message is pushed to
Interface network element corresponding with the interface server address of uplink client connection.
Further, described collect uses broadcast mechanism；The push uses pub/sub push-mechanisms；The prison of the push
It listens using obstruction thread dormancy awakening mechanism.
Description of the drawings
Fig. 1 is a kind of functional block diagram of the Intelligent routing system based on distributed type assemblies framework of the present invention；
Fig. 2 is a kind of method flow diagram of the method for intelligently routing based on distributed type assemblies framework of the present invention.
Specific implementation mode
The principle and features of the present invention will be described below with reference to the accompanying drawings, and the given examples are served only to explain the present invention, and
It is non-to be used to limit the scope of the present invention.
As shown in Figure 1, a kind of Intelligent routing system based on distributed type assemblies framework, including client, load equalizer,
Interface network element sends network element and gateway；
The interface network element reads the net element information of itself from database when being used for system and starting, and by the net of itself
Metamessage is synchronized to shared storage, and routing iinformation is generated for sending network element；It is used to periodically collect the routing iinformation of client, and
The routing iinformation of client in the shared storage of update；It is used to update the routing iinformation of its own；It is additionally operable to client
The downlink mobile message of push realizes route filtering according to the routing policy of selection；
The transmission network element reads the net element information of itself from database when being used for system and starting, and by the net of itself
Metamessage is synchronized to shared storage, and routing iinformation is generated for interface network element；It is used to periodically collect the routing iinformation of gateway, and more
The routing iinformation of gateway in new shared storage；It is used to update the routing iinformation of its own；It is additionally operable to respectively push away gateway
The state report and uplink mobile message sent realize route filtering；
The load equalizer is used for corresponding according to the recent route information and operator's model selection shared in storage
Routing policy.
It is preferred that the interface network element includes the first collecting unit, the first receiving unit and processing unit；
First collecting unit reads the net element information of corresponding interface network element from database when being used for system startup,
And the net element information of corresponding interface network element is synchronized to shared storage, generate routing iinformation for sending network element；It is additionally operable to periodically
The routing iinformation of client is collected, and updates the routing iinformation of the client in shared storage；It is additionally operable to update corresponding interface
The routing iinformation of network element；
First receiving unit is used to receive the downlink mobile message of client push；
The processing unit is used to judge the routing iinformation of downlink mobile message；When routing iinformation meets road
By requiring, according to the routing policy of selection, downlink mobile message is pushed into down queue；It is wanted when routing iinformation is unsatisfactory for routing
It asks, downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The transmission network element includes the second collecting unit, the second receiving unit, matching unit and transmission unit；
When being used for system startup, the corresponding net element information for sending network element is read from database for second collecting unit,
And the corresponding net element information for sending network element is synchronized to shared storage, generate routing iinformation for interface network element；It is additionally operable to periodically
The routing iinformation of gateway is collected, and updates the routing iinformation of the gateway in shared storage；It is additionally operable to update corresponding transmission network element
Routing iinformation；
Second receiving unit is used to receive the state report of gateway push；It is additionally operable to receive gateway push
Uplink mobile message；
The matching unit, the routing iinformation progress of the state report for being used to receive and downlink mobile message
Match；Such as successful match, the routing iinformation of the client in state report and the recent route information in shared storage are compared
Compared with the interface server address of acquisition downstream client connection；If it fails to match, state report is pushed into unsuccessfully queue, it is accurate
Standby storage；It is additionally operable to by the routing iinformation of the client in uplink mobile message and the recent route information in shared storage into
Row compares, and obtains the interface server address of uplink client connection；
The transmission unit is used for state report with pushing to the interface server being connect with the downstream client
The corresponding interface network element in location；It is additionally operable to uplink mobile message pushing to the interface server connecting with the uplink client
The corresponding interface network element in address.
As shown in Fig. 2, a kind of method for intelligently routing based on distributed type assemblies framework, includes the following steps：
Step 1, when system starts, each interface network element reads the net element information of itself from database respectively, and by itself
Net element information is synchronized to shared storage, and routing iinformation is generated for sending network element；Each network element that sends reads itself from database respectively
Net element information, and the net element information of itself is synchronized to shared storage, routing iinformation is generated for interface network element；
Step 2, interface network element periodically collects the routing iinformation of client, updates the routing letter of the client in shared storage
Breath, and update the routing iinformation of its own；The routing iinformation that network element periodically collects gateway is sent, the gateway in shared storage is updated
Routing iinformation, and update the routing iinformation of its own；
Step 3, load equalizer is according to the recent route information and the corresponding road of operator's model selection shared in storage
By strategy；
Step 4, interface network element is routed through the downlink mobile message of client push according to the routing policy realization of selection
Filter；It sends network element and route filtering is realized to the state report that gateway pushes；Letter is moved to the uplink that gateway pushes with network element is sent
Breath realizes route filtering.
It is preferred that the routing iinformation includes downstream routing information and uplink routing iinformation；Different routing iinformations is not using
Same MAP mechanism is stored.
The downstream routing information includes channel group ID, carrier ID, gateway ID, module I D, gateway service code, gateway
Service code ID, charge type, accounting code and long code；Wherein, the channel group ID, carrier ID and gateway ID joints are made
It is used for Key, the module I D, gateway service code, gateway service code ID, charge type, accounting code and long code are made
It is used for Value；Wherein, channel group ID：When being mainly used for client transmission, downlink is sent to unique mark of which gateway
Know；Carrier ID：According to cell-phone number, the carrier ID of Client handset is determined, so that it is determined that being sent to which gateway, carrier ID
Predominantly：1, mobile, 2, unicom and 3, telecommunications；Gateway ID：Unique mark for identifying gateway；Module I D：For identifying net
Unique mark of module where closing；Gateway service code：For the service code that operator sends, to distinguish different business
Type；Gateway service code ID：Gateway service code is numbered in order to facilitate management, to unique mark gateway industry
Business code；Charge type：For the unique mark of operator identifier charge type, it is specifically identified meaning, sees operator protocol text
Shelves；Accounting code：For the code that operator identifier charging uses, it is specifically identified meaning, sees operator protocol document；Trombone
Code：When being sent for gateway, the long code of the unified addition of the channel group, such as 10086, it needs to increase by 01 long code, send in this way
When, the number that mobile phone receives is 1008601.
The uplink routing iinformation includes channel group ID, carrier ID, gateway ID, client id, gateway service code, closes
Key word, keyword match rule, long code, long code matching rule, type of message and the affiliated province number of mobile phone；Wherein, described
Carrier ID, gateway ID, keyword, keyword match rule, long code and long code matching rule joint are used as Key,
The channel group ID, client id, gateway service code, type of message and the affiliated province number of mobile phone are used as Value；Its
In, channel group ID：When being mainly used for client transmission, downlink is sent to the unique mark of which gateway；Carrier ID：According to
Cell-phone number, determines the carrier ID of Client handset, so that it is determined which gateway be sent to, carrier ID is mainly：1, mobile, 2,
Unicom and 3, telecommunications；Gateway ID：Unique mark for identifying gateway；Client id：Only for module where identifying gateway
One mark；Gateway service code：For the service code that operator sends, to distinguish different types of service；Keyword：Hair
It send in uplink short message, when comprising certain special content, can be used as filter identification, which is keyword；Keyword match rule：
Refer to the matching logic of keyword, such as：0：Fuzzy matching, 1：Accurate matching；Long code：When being sent for gateway, the channel group system
The long code of one addition, such as 10086 need to increase by 01 long code, and when sending in this way, the number that mobile phone receives is 1008601；It is long
Numbers match rule：Refer to the matching logic of long code, such as：0：Fuzzy matching, 1：Accurate matching；Such as 1008601, match 01 trombone
Code, for accurate matching；10086010002,01 long code is matched, is fuzzy matching；Type of message：Refer to the message that operator receives
Type, such as：1 orders, and 0 quits the subscription of；The affiliated province number of mobile phone：The unique mark saved where phone number.
It is preferred that the routing policy includes elementary tactics, balance policy and active and standby strategy.Elementary tactics refers to：Only pass through
The routing policy of one server providing services connection operator, be mainly used for usual system pressure it is little in the case of, one
The simple routing policy of kind；When being managed in same system for multichannel, according to customer requirement, when being distributed to different gateways
The strategy used, each gateway do not have relevance, respectively independent；Balance policy refers to：Service connection is provided by multiple servers
The routing policy of operator, the equal shunt volume of multiple servers, load is spread out, to reduce the pressure of server, drop
The risk of low system crash；Active and standby strategy refers to：It is provided by multiple servers and services the routing policy for connecting operator, more
Server can provide service, be detected to server by system, when a wherein system crash, automatically switch data
To the routing policy of another server, by main standby route strategy, to ensure that the high availability of system.
It is preferred that downlink mobile message of the interface network element to client push, road is realized according to the routing policy of selection
It is implemented as by what is filtered, interface network element receives the downlink mobile message of client push, and to the road of downlink mobile message
Judged by information；When routing iinformation meets route request, according to the routing policy of selection, downlink mobile message is pushed to
Down queue；When routing iinformation is unsatisfactory for route request, downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the state report that gateway pushes, and sends network element and receives
The state report of gateway push, state report is matched with the routing iinformation of downlink mobile message；Such as successful match, by shape
The routing iinformation of client in state report is compared with the recent route information in shared storage, is obtained downstream client and is connected
The interface server address connect, and the interface server address that state report is pushed to the downstream client connects is corresponding
Interface network element；If it fails to match, state report is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the uplink mobile message that gateway pushes, and sends network element
The uplink mobile message for receiving gateway push by the routing iinformation of the client in uplink mobile message and is shared in storage most
New routing information is compared, and obtains the interface server address of uplink client connection；And uplink mobile message is pushed to
Interface network element corresponding with the interface server address of uplink client connection.
It is preferred that described collect uses broadcast mechanism；The push uses pub/sub push-mechanisms；The monitoring of the push
Using obstruction thread dormancy awakening mechanism.Present invention push uses pub/sub push-mechanisms, rather than in general sense, it will count
According to the mode of indentation queue, it is pressed into the mode of queue on ordinary meaning, needs redis as queue medium, and by reception line
Journey timing repeating query queue, to ensure on the one hand the timely transmission of data, thread repeating query consume performance, on the other hand there is delay,
Therefore there are many drawbacks, and pub/sub push is active push to receiving thread, and thread is persistently monitored, once information is received,
It immediately treats, therefore real-time has preferable guarantee.The push of the present invention is monitored mainly by obstruction thread dormancy awakening mechanism
It realizes, when monitoring can not obtain data, thread immediately enters blocked state, after waiting for pub/sub mechanism propelling datas, stands
Thread is waken up, is handled.
The foregoing is merely presently preferred embodiments of the present invention, is not intended to limit the invention, it is all the present invention spirit and
Within principle, any modification, equivalent replacement, improvement and so on should all be included in the protection scope of the present invention.
Claims (10)
1. a kind of Intelligent routing system based on distributed type assemblies framework, which is characterized in that including client, load equalizer,
Interface network element sends network element and gateway；
The interface network element when being used for the Intelligent routing system startup, the net element information of itself is read from database, and will
The net element information of itself is synchronized to shared storage, and routing iinformation is generated for sending network element；It is used to periodically collect the road of client
By information, and update the routing iinformation of the client in shared storage；It is used to update the routing iinformation of its own；It is additionally operable to
To the downlink mobile message of client push, route filtering is realized according to the routing policy of selection, the routing policy includes base
This strategy, balance policy and active and standby strategy；
The transmission network element when being used for the Intelligent routing system startup, the net element information of itself is read from database, and will
The net element information of itself is synchronized to shared storage, and routing iinformation is generated for interface network element；It is used to periodically collect the routing of gateway
Information, and update the routing iinformation of the gateway in shared storage；It is used to update the routing iinformation of its own；It is additionally operable to distinguish
Route filtering is realized to the state report and uplink mobile message of gateway push；
The load equalizer is used for according to the recent route information and the corresponding road of operator's model selection shared in storage
By strategy.
2. a kind of Intelligent routing system based on distributed type assemblies framework according to claim 1, which is characterized in that the road
Include downstream routing information and uplink routing iinformation by information；Different routing iinformations is stored using different MAP mechanism；
The downstream routing information includes channel group ID, carrier ID, gateway ID, module I D, gateway service code, gateway service
Code ID, charge type, accounting code and long code；Wherein, the channel group ID, carrier ID and gateway ID joint conducts
Key is used, the module I D, gateway service code, gateway service code ID, charge type, accounting code and long code conduct
Value is used；
The uplink routing iinformation includes channel group ID, carrier ID, gateway ID, client id, gateway service code, key
Word, keyword match rule, long code, long code matching rule, type of message and the affiliated province number of mobile phone；Wherein, the fortune
Battalion quotient ID, gateway ID, keyword, keyword match rule, long code and long code matching rule joint are used as Key, institute
Channel group ID, client id, gateway service code, type of message and the affiliated province number of mobile phone is stated to use as Value.
3. a kind of Intelligent routing system based on distributed type assemblies framework according to claim 1, which is characterized in that the base
This strategy refers to only connecting operator by a server providing services, for multichannel in the same Intelligent routing system
When middle management, according to customer requirement, it is distributed to different gateways, each gateway does not have relevance, respectively independent；
The balance policy refers to providing service connection operator by multiple servers, and the equal shunt volume of multiple servers will be born
Load spreads out；
The active and standby strategy refers to providing service connection operator by multiple servers, and multiple servers can provide service,
Server is detected by the Intelligent routing system, when a wherein server crash, automatically switches data
To another server.
4. a kind of Intelligent routing system based on distributed type assemblies framework according to claim 1, which is characterized in that described to connect
Mouth network element includes the first collecting unit, the first receiving unit and processing unit；
When being used for the Intelligent routing system startup, corresponding interface network element is read from database for first collecting unit
Net element information, and the net element information of corresponding interface network element is synchronized to shared storage, generate routing iinformation for sending network element；It is also
Routing iinformation for periodically collecting client, and update the routing iinformation of the client in shared storage；It is additionally operable to update
The routing iinformation of corresponding interface network element；
First receiving unit is used to receive the downlink mobile message of client push；
The processing unit is used to judge the routing iinformation of downlink mobile message；It is wanted when routing iinformation meets routing
It asks, according to the routing policy of selection, downlink mobile message is pushed into down queue；When routing iinformation is unsatisfactory for route request,
Downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The transmission network element includes the second collecting unit, the second receiving unit, matching unit and transmission unit；
When being used for the Intelligent routing system startup, corresponding transmission network element is read from database for second collecting unit
Net element information, and the corresponding net element information for sending network element is synchronized to shared storage, generate routing iinformation for interface network element；It is also
Routing iinformation for periodically collecting gateway, and update the routing iinformation of the gateway in shared storage；It is additionally operable to update and corresponds to
Send the routing iinformation of network element；
Second receiving unit is used to receive the state report of gateway push；It is additionally operable to the uplink for receiving gateway push
Mobile message；
The matching unit, the state report for being used to receive are matched with the routing iinformation of downlink mobile message；Such as
The routing iinformation of client in state report is compared with the recent route information in shared storage, obtains by successful match
Obtain the interface server address of downstream client connection；As it fails to match, state report is pushed into unsuccessfully queue, prepare into
Library；It is additionally operable to compare the routing iinformation of the client in uplink mobile message and the recent route information in shared storage
Compared with the interface server address of acquisition uplink client connection；
The transmission unit is used to push to state report the interface server address phase being connect with the downstream client
The interface network element answered；It is additionally operable to uplink mobile message pushing to the interface server address connecting with the uplink client
Corresponding interface network element.
5. a kind of Intelligent routing system based on distributed type assemblies framework according to claim 4, which is characterized in that the receipts
Collection uses broadcast mechanism；The push uses pub/sub push-mechanisms；The monitoring of the push is using obstruction thread dormancy awakening
Mechanism.
6. a kind of method for intelligently routing based on distributed type assemblies framework, which is characterized in that include the following steps：
Step 1, when the Intelligent routing system starts, each interface network element reads the net element information of itself from database respectively, and
The net element information of itself is synchronized to shared storage, routing iinformation is generated for sending network element；Each network element that sends is respectively from database
The net element information of itself is read, and the net element information of itself is synchronized to shared storage, routing iinformation is generated for interface network element；
Step 2, interface network element periodically collects the routing iinformation of client, updates the routing iinformation of the client in shared storage,
And update the routing iinformation of its own；The routing iinformation that network element periodically collects gateway is sent, the gateway in shared storage is updated
Routing iinformation, and update the routing iinformation of its own；
Step 3, load equalizer route plan accordingly according to the recent route information and operator's model selection shared in storage
Slightly, the routing policy includes elementary tactics, balance policy and active and standby strategy；
Step 4, interface network element realizes route filtering to the downlink mobile message of client push according to the routing policy of selection；
It sends network element and route filtering is realized to the state report that gateway pushes；Network element is sent to realize the uplink mobile message that gateway pushes
Route filtering.
7. a kind of method for intelligently routing based on distributed type assemblies framework according to claim 6, which is characterized in that the road
Include downstream routing information and uplink routing iinformation by information；Different routing iinformations is stored using different MAP mechanism；
The downstream routing information includes channel group ID, carrier ID, gateway ID, module I D, gateway service code, gateway service
Code ID, charge type, accounting code and long code；Wherein, the channel group ID, carrier ID and gateway ID joint conducts
Key is used, the module I D, gateway service code, gateway service code ID, charge type, accounting code and long code conduct
Value is used；
The uplink routing iinformation includes channel group ID, carrier ID, gateway ID, client id, gateway service code, key
Word, keyword match rule, long code, long code matching rule, type of message and the affiliated province number of mobile phone；Wherein, the fortune
Battalion quotient ID, gateway ID, keyword, keyword match rule, long code and long code matching rule joint are used as Key, institute
Channel group ID, client id, gateway service code, type of message and the affiliated province number of mobile phone is stated to use as Value.
8. a kind of method for intelligently routing based on distributed type assemblies framework according to claim 6, which is characterized in that the base
This strategy refers to only connecting operator by a server providing services, for multichannel in the same Intelligent routing system
When middle management, according to customer requirement, it is distributed to different gateways, each gateway does not have relevance, respectively independent；
The balance policy refers to providing service connection operator by multiple servers, and the equal shunt volume of multiple servers will be born
Load spreads out；
The active and standby strategy refers to providing service connection operator by multiple servers, and multiple servers can provide service,
Server is detected by the Intelligent routing system, when a wherein server crash, automatically switches data
To another server.
9. a kind of method for intelligently routing based on distributed type assemblies framework according to claim 6, which is characterized in that described to connect
Mouth network element realizes being implemented as route filtering to the downlink mobile message of client push according to the routing policy of selection,
Interface network element receives the downlink mobile message of client push, and judges the routing iinformation of downlink mobile message；Work as road
Route request is met by information, according to the routing policy of selection, downlink mobile message is pushed into down queue；Work as routing iinformation
It is unsatisfactory for route request, downlink mobile message is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the state report that gateway pushes, and sends network element and receives gateway
The state report of push matches state report with the routing iinformation of downlink mobile message；Such as successful match, by state report
The routing iinformation of client in announcement is compared with the recent route information in shared storage, obtains downstream client connection
Interface server address, and connect state report is pushed to the downstream client connects interface server address is corresponding
Mouth network element；If it fails to match, state report is pushed into unsuccessfully queue, prepares storage；
The network element that sends realizes being implemented as route filtering to the uplink mobile message that gateway pushes, and sends network element and receives
The uplink mobile message of gateway push, by the routing iinformation of the client in uplink mobile message and the newest road in shared storage
It is compared by information, obtains the interface server address of uplink client connection；And uplink mobile message is pushed to and institute
State the corresponding interface network element in interface server address of uplink client connection.
10. a kind of method for intelligently routing based on distributed type assemblies framework according to claim 9, which is characterized in that described
It collects and uses broadcast mechanism；The push uses pub/sub push-mechanisms；The monitoring of the push is called out using obstruction thread suspend mode
The mechanism of waking up.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201510662218.8A CN105376155B (en) | 2015-10-14 | 2015-10-14 | A kind of Intelligent routing system and method based on distributed type assemblies framework |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201510662218.8A CN105376155B (en) | 2015-10-14 | 2015-10-14 | A kind of Intelligent routing system and method based on distributed type assemblies framework |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN105376155A CN105376155A (en) | 2016-03-02 |
| CN105376155B true CN105376155B (en) | 2018-11-02 |
Family
ID=55377975
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201510662218.8A Active CN105376155B (en) | 2015-10-14 | 2015-10-14 | A kind of Intelligent routing system and method based on distributed type assemblies framework |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN105376155B (en) |
Families Citing this family (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106559231A (en) * | 2015-09-25 | 2017-04-05 | 中兴通讯股份有限公司 | Net element information sharing method between many operational systems, apparatus and system |
| CN110445624B (en) * | 2018-05-04 | 2022-09-13 | 中国移动通信有限公司研究院 | CDR processing system and device |
| CN111918225B (en) * | 2020-09-15 | 2022-03-29 | 北京值得买科技股份有限公司 | Method for sending short message based on multiple operators |
| CN115834472B (en) * | 2022-10-17 | 2024-07-19 | 北京奇艺世纪科技有限公司 | Message processing method, forwarding strategy acquisition method and device |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1419382A (en) * | 2001-11-14 | 2003-05-21 | 深圳市中兴通讯股份有限公司上海第二研究所 | Short message original calling control gateway |
| CN101044725A (en) * | 2004-10-06 | 2007-09-26 | 诺基亚公司 | Service routing selection |
| CN101388854A (en) * | 2007-09-14 | 2009-03-18 | 中兴通讯股份有限公司 | Method, system and gateway for multimedia message transmission |
| CN101656631A (en) * | 2009-09-07 | 2010-02-24 | 中兴通讯股份有限公司 | Method and device for supporting multiple gateways in unified management platform |
| CN101771960A (en) * | 2009-01-04 | 2010-07-07 | 中国移动通信集团公司 | Service invoking method for mobile network, and service gateway, service platform and system thereof |
| US7788403B2 (en) * | 2003-01-24 | 2010-08-31 | Soa Software, Inc. | Network publish/subscribe incorporating web services network routing architecture |
| CN101959220A (en) * | 2009-07-15 | 2011-01-26 | 中兴通讯股份有限公司 | Management method and management system of centralized mobile agent server |
| CN104753774A (en) * | 2013-12-26 | 2015-07-01 | 中国移动通信集团公司 | Distributed enterprise integrated access gateway |
-
2015
- 2015-10-14 CN CN201510662218.8A patent/CN105376155B/en active Active
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1419382A (en) * | 2001-11-14 | 2003-05-21 | 深圳市中兴通讯股份有限公司上海第二研究所 | Short message original calling control gateway |
| US7788403B2 (en) * | 2003-01-24 | 2010-08-31 | Soa Software, Inc. | Network publish/subscribe incorporating web services network routing architecture |
| CN101044725A (en) * | 2004-10-06 | 2007-09-26 | 诺基亚公司 | Service routing selection |
| CN101388854A (en) * | 2007-09-14 | 2009-03-18 | 中兴通讯股份有限公司 | Method, system and gateway for multimedia message transmission |
| CN101771960A (en) * | 2009-01-04 | 2010-07-07 | 中国移动通信集团公司 | Service invoking method for mobile network, and service gateway, service platform and system thereof |
| CN101959220A (en) * | 2009-07-15 | 2011-01-26 | 中兴通讯股份有限公司 | Management method and management system of centralized mobile agent server |
| CN101656631A (en) * | 2009-09-07 | 2010-02-24 | 中兴通讯股份有限公司 | Method and device for supporting multiple gateways in unified management platform |
| CN104753774A (en) * | 2013-12-26 | 2015-07-01 | 中国移动通信集团公司 | Distributed enterprise integrated access gateway |
Also Published As
| Publication number | Publication date |
|---|---|
| CN105376155A (en) | 2016-03-02 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN100531055C (en) | Data synchronous system and its method | |
| CN105376155B (en) | A kind of Intelligent routing system and method based on distributed type assemblies framework | |
| CN101499995B (en) | Service scheduling method, system and device for service scheduling | |
| CN104796422A (en) | Online customer service staff equilibrium assignment method and online customer service staff equilibrium assignment device | |
| CN110784779B (en) | Data acquisition method of electricity consumption information acquisition system | |
| CN102929961A (en) | Data processing method and device thereof based on building quick data staging channel | |
| CN107301529A (en) | A kind of government affairs demand accepts centring system | |
| CN103581966A (en) | Real-time monitoring optimizing configuration method for smart phone | |
| CN102195851A (en) | Load sharing method, system and access server | |
| CN101420681B (en) | Method and apparatus for processing multi-channel request subscription under service management platform | |
| CN101226654A (en) | Bank client note numbering queueing method | |
| WO2004059418A2 (en) | Context sensitive call processing | |
| CN103021167A (en) | Method and system for taxi information interaction | |
| CN101159972B (en) | Traffic processing method and system and traffic control point | |
| EP2439881A1 (en) | Cluster system and request message distribution method for processing multi-node transaction | |
| CN103258389B (en) | The method of self-aided terminal upload file, system and self-aided terminal | |
| CN103024023A (en) | Electronic reading room network auditing method | |
| CN115225138A (en) | Service data processing method, device and system for satellite communication service | |
| CN103021172B (en) | Method and system for taxi scheduling | |
| WO2010043138A1 (en) | Method for accessing magnanimity data of intelligent network service database and system and device thereof | |
| CN102137102A (en) | Realizing method of service supporting platform for supporting multiclass information publishing modes | |
| CN104798397A (en) | Method and device for hosting application by access node | |
| CN108471387B (en) | Log flow decentralized control method and system | |
| CN112636959B (en) | Network slice privacy number service guarantee system and method for distinguishing service types | |
| CN111245878A (en) | Method for computing and offloading communication network based on hybrid cloud computing and fog computing |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| CP03 | Change of name, title or address | ||
| CP03 | Change of name, title or address |
Address after: 334000 room 139, building 2, cultural and creative center, Chasheng East Road, Shangrao High Speed Railway Economic Experimental Zone, Jiangxi Province Patentee after: Jiangxi Tianli Technology Co.,Ltd. Address before: 100144 9th floor, building 6, yard 30, Shixing street, Shijingshan District, Beijing Patentee before: BEIJING WIRELESS TIANLI MOBILE INFORMATION TECHNOLOGY Co.,Ltd. |