System and method for supporting a selection service in a server environment

• US 10,050,857 B2
• Filed: 08/28/2017
• Issued: 08/14/2018
• Est. Priority Date: 10/15/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Falco, Mark, Bihani, Ballav
• Primary Examiner(s): Wang, Liangche A
• Application Number:
  US15/688,151
• Publication Number:
  US 20170359240A1
• Time in Patent Office: 351 Days
• Field of Search: 709206, 709223, 709224, 709227, 726 1, 726 4, 726 8, 726 23
• CPC Class Codes: G06F 11/16 Error detection or correction of the data by redundancy in hardware
• CPC Class Codes: G06F 11/2041 with more than one idle spare processing component
• CPC Class Codes: G06F 11/2048 where the redundant components share neither address space nor persistent storage
• CPC Class Codes: G06F 11/2097 maintaining the standby controller/processing unit updated initialisation or re-synchronisation thereof G06F11/1658 and subgroups
• CPC Class Codes: G06F 16/10 File systems; File servers
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 2201/82 Solving problems relating to consistency ensuring consistency in mirrored systems G06F11/2064
• CPC Class Codes: H04L 41/0668 by dynamic selection of recovery network elements, e.g. replacement by the most appropriate element after failure
• CPC Class Codes: H04L 43/0811 by checking connectivity
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes

Abstract

A system and method can support socket programming in a server environment, such as a distributed data grid. The server environment can include a selection service that operates to register a plurality of sockets, wherein each said socket is associated with a handler in a plurality of handlers. Furthermore, the selection service can listen for one or more incoming connection requests on the plurality of sockets, and invoke a pluggable callback provided by a said handler associated with a registered socket in the plurality of sockets, when said registered socket receives an incoming connection request.

Claims

1. A method for supporting socket programming in a middleware environment executing on one or more microprocessors, the method comprising:

configuring a distributed in-memory data grid comprising a cluster of nodes in the middleware environment to support asynchronized message processing;

providing, in the distributed in-memory data grid, a selection service that implements a plurality of abstract methods of an interface on the distributed in-memory data grid, wherein the selection service is associated with a single physical port configured to be multiplexed into a plurality of sub-ports, and includes a registration method and an invocation method;

registering a plurality of server socket channels with the selection service using the registration method thereof, wherein each socket channel is configured to bind one of a plurality of server sockets to one of the plurality of sub-ports;

registering a socket handler for each server socket with the selection service using the registration method thereof, wherein the socket handler provides a callback for use by the selection service to invoke that socket handler to process incoming network streams at the corresponding server socket;

listening, on one of the plurality of server sockets, for a connection request directed to an application on the distributed in-memory data grid;

invoking, via the invocation method of the selection service, the callback provided by the socket handler corresponding to the server socket, to process the connection request;

wherein the connection request is processed using a message processing thread, and a service thread; and

wherein the service thread is configured to generate a data structure representing a control state for processing the connection request, and transmit the processing of the connection request along with the data structure to the message processing thread for further processing.

2. The method according to claim 1, further comprising:

utilizing one or more threads in a thread pool to handle the plurality of sockets.

3. The method according to claim 2, wherein the number of threads used in the thread pool is determined by the distributed in-memory data grid.

4. The method according to claim 2, wherein each of the one or more applications implements application logic that is independent of the thread pool.

5. The method according to claim 1, wherein the plurality of server sockets share a single physical port.

6. The method according to claim 5, wherein the single physical port is multiplexed into multiple sub-ports.

7. The method according to claim 1, wherein each of the plurality of server sockets is registered with the selection service.

8. A system for to support socket programming, comprising:

one or more computers, each including an application server in a middleware environment executing on one or more microprocessors;

a distributed in-memory data grid in a middleware environment executing on the one or more computers, wherein the distributed in-memory data grid comprises a cluster of nodes and is configured to support asynchronized message processing;

a selection service running on the distributed in-memory data grid, wherein the selection service implements a plurality of abstract methods of an interface on the distributed in-memory data grid, wherein the interface includes a registration method and an invocation method;

wherein the selection service is associated with a single physical port configured to be multiplexed into a plurality of sub-ports, and operates to

register a plurality of server socket channels with the selection service using the registration method thereof, wherein each socket channel is configured to bind one of a plurality of server sockets to one of the plurality of sub-ports,

register a socket handler for each server socket with the selection service using the registration method thereof, wherein the socket handler provides a callback for use by the selection service to invoke that socket handler to process incoming network streams at the corresponding server socket,

listen, on one of the plurality of server sockets, for one or more connection requests directed to an application on the distributed in-memory data grid,

invoke, using the invocation method of the selection service, the callback provided by the socket handler corresponding to a server socket, to process the one or more connection requests,

wherein the connection request is processed using a message processing thread, and a service thread, and

wherein the service thread is configured to generate a data structure representing a control state for processing the connection request, and transmit the processing of the connection request along with the data structure to the message processing thread for further processing.

9. The system according to claim 8, further comprising:

one or more threads in a thread pool that operates to handle the plurality of sockets.

10. The system according to claim 9, wherein the number of threads used in the thread pool is determined by the distributed in-memory data grid.

11. The system according to claim 10, wherein each of the one or more applications implements application logic that is independent of the thread pool.

12. The system according to claim 8, wherein the plurality of sockets share a single physical port.

13. The system according to claim 12, wherein the single physical port is multiplexed into multiple sub-ports.

14. The system according to claim 11, wherein each of the plurality of server sockets is registered with selection service.

15. A non-transitory machine readable storage medium having instructions stored thereon that when executed cause a system to perform the steps comprising:

configuring a distributed in-memory data grid comprising a cluster of nodes in the middleware environment to support asynchronized message processing;

providing, in the distributed in-memory data grid, a selection service that implements a plurality of abstract methods of an interface on the distributed in-memory data grid, wherein the selection service is associated with a single physical port configured to be multiplexed into a plurality of sub-ports, and includes a registration method and an invocation method;

registering a plurality of server socket channels with the selection service using the registration method thereof, wherein each socket channel is configured to bind one of a plurality of server sockets to one of the plurality of sub-ports;

registering a socket handler for each server socket with the selection service using the registration method thereof, wherein the socket handler provides a callback for use by the selection service to invoke that socket handler to process incoming network streams at the corresponding server socket;

listening, on one of the plurality of server sockets, for a connection request directed to an application on the distributed in-memory data grid;

invoking, via the invocation method of the selection service, the callback provided by the socket handler corresponding to the server socket, to process the connection request;

wherein the connection request is processed using a message processing thread, and a service thread; and

wherein the service thread is configured to generate a data structure representing a control state for processing the connection request, and transmit the processing of the connection request along with the data structure to the message processing thread for further processing.

16. The non-transitory computer-readable storage medium according to claim 15, further comprising:

utilizing one or more threads in a thread pool to handle the plurality of server sockets.

17. The non-transitory computer-readable storage medium according to claim 16, wherein the number of threads used in the thread pool is determined by the distributed in-memory data grid.

18. The non-transitory computer-readable storage medium according to claim 16, wherein each of the one or more applications implements application logic that is independent of the thread pool.

19. The non-transitory computer-readable storage medium according to claim 15, wherein the plurality of server sockets share a single physical port.

20. The non-transitory computer-readable storage medium according to claim 19, wherein the single physical port is multiplexed into multiple sub-ports.