System and methods for communicating in a telecommunication network via independent key routing and proxies

• US 9,363,177 B2
• Filed: 05/28/2013
• Issued: 06/07/2016
• Est. Priority Date: 05/29/2012
• Status: Active Grant

• Current Assignee: Openet Telecom Limited (Amdocs Ltd.)
• Original Assignee: Openet Telecom Limited (Amdocs Ltd.)
• Inventors: Brady, Thomas, Ferguson, Craig, Haraszti, Peter, Dunne, Cameron Ross, McNamee, Alan
• Primary Examiner(s): Shingles, Kristie
• Assistant Examiner(s): MIAN, MOHAMMAD YOU A
• Application Number:
  US13/903,816
• Publication Number:
  US 20130325986A1
• Time in Patent Office: 1,106 Days
• Field of Search: 709/206
• US Class Current: 1/1
• CPC Class Codes: H04L 45/745 Address table lookup; Address filtering
• CPC Class Codes: H04L 45/7452 Multiple parallel or consecutive lookup operations lookup operation involving Bloom filters H04L45/7459
• CPC Class Codes: H04L 67/1006 with static server selection, e.g. the same server being selected for a specific client
• CPC Class Codes: H04L 67/1014 based on the content of a request
• CPC Class Codes: H04L 67/1031 Controlling of the operation of servers by a load balancer, e.g. adding or removing servers that serve requests
• CPC Class Codes: H04L 67/1034 Reaction to server failures by a load balancer
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context

Abstract

A combination of an independent key routing (IKR) method and a data proxy architecture (DPA) method may be used to route communication messages in a telecommunication network to achieve improved data locality and reduce secondary key lookups. A processor may receive a first communication message that includes subscriber identifiers that uniquely identify a subscriber, generate a plurality of keys for a plurality of message types, identify a first logical scalable unit (LSU) that includes a first memory that stores a first type of data via a database API and a first key, identify a second LSU that includes a second memory that stores a second type of data relating to the subscriber via the database API and a second key of the plurality of keys, store the first communication message and the first key in the first database memory, and store the first key in the second database memory.

Claims

1. A method of routing communication messages in an elastically scalable telecommunication network, comprising:

receiving a first communication message in a processor of a multiprocessor computing system from a component in the elastically scalable telecommunication network, the first communication message including subscriber identifiers that uniquely identify a subscriber;

generating in the processor a plurality of keys for a plurality of message types based on the subscriber identifiers included in the first communication message;

identifying in the processor a first logical scalable unit that includes a first database memory that stores a first type of data relating to the subscriber via a database application programming interface (API) and a first key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying in the processor a second logical scalable unit that includes a second database memory that stores a second type of data relating to the subscriber via the database API and a second key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying a first application processor in the multiprocessor computing system that is part of the first logical scalable unit;

identifying a second application processor in the multiprocessor computing system that is part of the second logical scalable unit;

storing by the processor the received first communication message and the first key in the first database memory included in the first logical scalable unit identified via the first key; and

storing by the processor the first key in the second database memory included in the second logical scalable unit identified via the second key.

2. The method of claim 1, wherein storing the first communication message and the first key in the first database memory included in the first logical scalable unit comprises storing the first communication message in a memory that is remote from the processor.

3. The method of claim 1, wherein the operations of storing the first communication message and the first key in the first database memory and storing the first key in the second database memory are performed concurrently.

4. The method of claim 1, further comprising:

updating a local request table of a first application component to include a reference to the first communication message by the first application processor in response to the processor storing the first communication message in the first database memory.

5. The method of claim 4, further comprising:

retrieving the first communication message from the first database memory by the first application component;

retrieving subscriber data from the first database memory;

performing application-level operations using the subscriber data retrieved from the first database memory and the retrieved first communication message;

generating a second communication message based on the subscriber data retrieved from the first database memory; and

sending the second communication message from the first application processor to the processor.

6. The method of claim 1, further comprising:

receiving in the processor a third communication message;

identifying the second key based on information included in the third communication message;

determining that the second database memory in the second logical scalable unit stores the second type of data via the database API and the second key; and

storing the third communication message in the second database memory in the second logical scalable unit.

7. The method of claim 6, further comprising:

retrieving the third communication message and the first key from the second database memory by a second application component of the second logical scalable unit;

identifying a third logical scalable unit that includes a third database memory that stores the first type of data via the database API and the first key, wherein the third database memory stores the first type of data as a result of a scaling operation within the elastically scalable telecommunication network; and

retrieving subscriber data from the third database memory.

8. The method of claim 7, further comprising:

performing application-level operations using the subscriber data retrieved from the third database memory;

generating a fourth communication message based on the subscriber data retrieved from the third database memory; and

sending the fourth communication message from the second application processor to the processor.

9. The method of claim 6, wherein:

receiving the first communication message in the processor comprises receiving a Gx communication message in the processor; and

receiving the third communication message in the processor comprises receiving a Rx communication message in the processor.

10. A computing device, comprising:

a processor configured with processor-executable instructions to perform operations comprising;

receiving a first communication message that includes subscriber identifiers that uniquely identify a subscriber from a component in an elastically scalable telecommunication network;

generating a plurality of keys for a plurality of message types based on the subscriber identifiers included in the first communication message;

identifying a first logical scalable unit that includes a first database memory that stores a first type of data relating to the subscriber via a database application programming interface (API) and a first key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying a second logical scalable unit that includes a second database memory that stores a second type of data relating to the subscriber via the database API and a second key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying a first application processor that is part of the first logical scalable unit;

identifying a second application processor that is part of the second logical scalable unit;

storing the received first communication message and the first key in the first database memory included in the first logical scalable unit identified via the first key;

storing the first key in the second database memory included in the second logical scalable unit identified via the second key; and

receiving a second communication message in response to storing the first communication message and the first key in the first database memory and routing the second communication message to another component the elastically scalable telecommunication network.

11. The computing device of claim 10, wherein the processor is configured with processor-executable instructions to perform operations further comprising:

receiving a third communication message;

identifying the second key based on information included in the third communication message;

determining that the second database memory in the second logical scalable unit stores the second type of data via the database API and the second key; and

storing the third communication message in the second database memory.

12. The computing device of claim 11, wherein the processor is configured with processor-executable instructions to perform operations such that receiving the third communication message comprises:

receiving a communication message that includes a subset the subscriber identifiers included in the first communication message.

13. The computing device of claim 11, wherein the processor is configured with processor-executable instructions to perform operations such that receiving the third communication message comprises:

receiving a communication message that identifies the subscriber using a different identifier than the subscriber identifiers included in the first communication message.

14. The computing device of claim 11, wherein the processor is configured with processor-executable instructions to perform operations such that:

receiving the first communication message comprises receiving a Gx communication message; and

receiving the third communication message comprises receiving a Rx communication message.

15. A non-transitory computer readable storage medium having stored thereon processor-executable software instructions configured to cause a processor to perform operations comprising:

receiving a first communication message that includes subscriber identifiers that uniquely identify a subscriber from a component an elastically scalable telecommunication network;

generating a plurality of keys for a plurality of message types based on the subscriber identifiers included in the first communication message;

identifying a first logical scalable unit that includes a first database memory that stores a first type of data relating to the subscriber via a database application programming interface (API) and a first key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying a second logical scalable unit that includes a second database memory that stores a second type of data relating to the subscriber via the database API and a second key of the plurality of keys generated based on the subscriber identifiers included in the received first communication message;

identifying a first application processor that is part of the first logical scalable unit;

identifying a second application processor that is part of the second logical scalable unit;

storing the first communication message and the first key in the first database memory included in the first logical scalable unit identified via the first key;

storing the first key in the second database memory included in the second logical scalable unit identified via the second key; and

receiving a second communication message in response to storing the first communication message and the first key in the first database memory and routing the second communication message to another component the elastically scalable telecommunication network.

16. The non-transitory computer readable storage medium of claim 15, wherein the stored processor-executable software instructions are configured to cause a processor to perform operations further comprising:

receiving a third communication message;

identifying the second key based on information included in the third communication message;

determining that the second database memory in the second logical scalable unit stores the second type of data via the database API and the second key; and

storing the third communication message in the second database memory.

17. The non-transitory computer readable storage medium of claim 16, wherein the stored processor-executable software instructions are configured to cause a processor to perform operations such that receiving the third communication message comprises:

receiving a communication message that includes a subset the subscriber identifiers included in the first communication message.

18. The non-transitory computer readable storage medium of claim 16, wherein the stored processor-executable software instructions are configured to cause a processor to perform operations such that receiving the third communication message comprises:

receiving a communication message that identifies the subscriber using a different identifier than the subscriber identifiers included in the first communication message.

19. The non-transitory computer readable storage medium of claim 16, wherein the stored processor-executable software instructions are configured to cause a processor to perform operations such that:

receiving the first communication message comprises receiving a Gx communication message; and

receiving the third communication message comprises receiving a Rx communication message.