Distributed computing system architecture

• US 8,185,665 B2
• Filed: 09/17/2008
• Issued: 05/22/2012
• Est. Priority Date: 02/22/2001
• Status: Active Grant

• Current Assignee: Charles Schwab & Company Incorporated (Charles Schwab Corporation)
• Original Assignee: Charles Schwab & Company Incorporated (Charles Schwab Corporation)
• Inventors: Goldstein, Neal, Richards, Adam, Sherr, David, Levy, David, Mullins, Chalon
• Primary Examiner(s): Coulter, Kenneth R
• Application Number:
  US12/212,407
• Publication Number:
  US 20090077269A1
• Time in Patent Office: 1,343 Days
• Field of Search: 709/253, 709/223
• US Class Current: 709/253
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04N 21/266 Channel or content management, e.g. generation and management of keys and entitlement messages in a conditional access system, merging a VOD unicast channel into a multicast channel
• CPC Class Codes: H04N 21/2668 Creating a channel for a dedicated end-user group, e.g. insertion of targeted commercials based on end-user profiles information retrieval from the Internet by querying with filtering and personalisation G06F16/9535; arrangements for replacing or switching information during the broadcast H04H20/10; push services over packet-switching network H04L12/1859; adaptation of message content in packet-switching networks H04L51/063

Abstract

A computing system architecture is based upon a peer-to-peer, asynchronous model. The architecture specifies a set of infrastructure facilities that comprise an inter-prise operating system. The inter-prise operating system provides all the facilities that make application coding as easy in the peer-to-peer asynchronous model as it is in a hierarchical, synchronous model. Services, which reside in containers, are linked asynchronously by an inter-prise bus and use data from a virtual data store.

Claims

1. A computing system, which comprises:

a bus including a channel manager component that provides for at least three different types of channels for the bus, the at least three different types of channels including a service channel, an event channel, and a stream channel, which provide for communications between a plurality of different service requestors and a plurality of different service providers, wherein the channel manager component is adapted to create a channel in response to receipt of an open channel message;

a context manager component, within the bus, that retrieves context sent through the bus, wherein context flows through each of the service channel, event channel, and stream channel, further wherein the bus strips off the context from messages sent through the service channel, event channel, and stream channel prior to retrieval by the context manager;

a tank operatively coupled to said bus;

a data management component operatively coupled to said bus, said data management component containing a database manager configured to store data in a physical memory operatively coupled with the bus;

a physical memory operatively coupled to said bus;

a service requestor container operatively coupled to said bus, said service requestor container containing a service requestor application, wherein said service requestor application does not have access to the context;

a service provider container operatively coupled to said bus, said service provider container containing a service provider application, wherein said service provider application does not have access to the context; and

,

a virtual data store operatively coupled to said service requestor container and to said service provider container.

2. The computing system as claimed in claim 1, wherein each of said channels is identified by a logical channel name.

3. The computing system as claimed in claim 2, wherein said logical channel name is a handle dynamically created by said channel manager component.

4. The computing system as claimed in claim 2, wherein said channel manager component is adapted to create said tank, and said logical name is a name of said tank.

5. The computing system as claimed in claim 2, wherein said created channel is a service channel.

6. The computing system as claimed in claim 2, wherein said created channel is an event channel.

7. The computing system as claimed in claim 2, wherein said created channel is an unmapped stream.

8. The computing system as claimed in claim 2, wherein said created channel is a mapped stream.

9. The computing system as claimed in claim 1, wherein said virtual data store comprises:

a posting service coupled to receive data updates from said service provider container;

a first database coupled to said posting service;

an information service coupled to provide data in response to inquiries from said service requestor container;

at least one second database coupled to said posting service; and

,

a replication manager coupled between said first database and said at least one second database for selectively replicating data from said first database to said second database.

10. The computing system as claimed in claim 9, wherein said information service includes means for calling a security manager for security information.

11. The computing system as claimed in claim 9, wherein said replication manager includes logic to preserve unit of work updates.

12. The computing system as claimed in claim 9, wherein said replication manager includes logic to ensure that only the latest version of data is replicated to said at least one second database.

13. The computing system as claimed in claim 9, including a data currency manager coupled to said information service to enable said information service to determine what version of data to use to satisfy a inquiry from said service requestor container.

14. The computing system as claimed in claim 9, wherein said virtual data store comprises a cache controller that manages a cache for the information service.

15. The computing system as claimed in claim 1, wherein each of said channels is identified by a logical channel name.

16. The computing system as claimed in claim 15, wherein said logical channel name is a handle dynamically created by said channel manager component.

17. The computing system as claimed in claim 15, wherein said channel manager component is adapted to create said tank, and said logical name is a name of said tank.

18. The computing system as claimed in claim 17, wherein the first container is adapted to write data to the tank, the system further comprising a second container adapted to read the data from the tank.

19. The computing system as claimed in claim 18, wherein said channel manager component is adapted to close a channel in response to receipt of a close channel message from the second container.

20. The computing system as claimed in claim 1, wherein said service provider application comprises a synchronous application, and the service provider container is linked asynchronously by the bus to the service requestor container.

21. The computing system as claimed in claim 1, wherein each container includes both a processing model and a service model.

22. The computing system as claimed in claim 1, wherein the data management component includes a credential manager.

23. A computing system, which comprises:

a bus, wherein the bus includes

a channel manager component that provides for at least three different types of channels for the bus which provide for communication between a plurality of different service requestors and a plurality of different service providers, the at least three different types of channels including a service channel, an event channel, and a stream channel, which provide for communications between a plurality of different service requestors and a plurality of different service providers, wherein the channel manager component is adapted to create a channel in response to receipt of an open channel message,

a service discovery component that identifies a plurality of different types of interfaces for the plurality of different service providers, wherein the different types of channels correspond to the plurality of different types of interfaces, and

a context manager component that retrieves context sent through the bus, wherein context flows through each of the service channel, event channel, and stream channel, further wherein the bus strips off the context from messages sent through the service channel, event channel, and stream channel prior to retrieval by the context manager;

a tank operatively coupled to said bus;

a data management component operatively coupled to said bus, said data management component containing a database manager configured to store data in a physical memory operatively coupled with the bus;

a service requestor container operatively coupled to said bus, said service requestor container containing a service requestor application, wherein said service requestor application does not have access to the context;

a service provider container operatively coupled to said bus, said service provider container containing a service provider application, wherein said service provider application does not have access to the context,

wherein the service provider container includes an interaction broker component, said interaction broker providing an interface between said bus and said service provider application; and

a virtual data store operatively coupled to said service requestor container and to said service provider container.

24. The computer system as claimed in claim 23, wherein each of said service provider container and said service requestor container comprises:

an operation interface defining a set of operations of a business service application that can be called by other business services;

an event interface defining a set of events that can be raised or handled by said business service application; and

,

a stream interface defining a set of streams that said business service application reads or writes.

25. The computer system as claimed in claim 23, wherein the physical memory comprises one or more direct access storage devices.

26. The computer system as claimed in claim 23, wherein the context manager is configured to retrieve context propagated by the service requestor container, the context comprising an audit context.

27. The computer system as claimed in claim 26, wherein the context manager calls the bus to obtain security context from a message sent to the container.

28. The computer system as claimed in claim 23, wherein the context manager component is adapted to determine if a container is authorized to use a channel.

29. The computing system as claimed in claim 23, wherein said bus is operatively coupled to a computer server.

30. The computing system as claimed in claim 23, wherein the database manager is responsible for unit of work data preservation.

31. The computer system as claimed in claim 23, wherein the service provider application exports a set of operations, and the service provider container maps each operation in the set of operations to one of a service request, event, or stream.