METHODS, APPARATUS AND COMPUTER PROGRAMS FOR DATA COMMUNICATION EFFICIENCY

• US 20070043824A1
• Filed: 08/10/2006
• Published: 02/22/2007
• Est. Priority Date: 08/20/2005
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Fremantle, Paul
• Granted Patent: US 8,635,368 B2
• Time in Patent Office: Days
• US Class Current: 709/214
• CPC Class Codes: H04L 67/2876 Pairs of inter-processing entities at each side of the network, e.g. split proxies
• CPC Class Codes: H04L 67/55 Push-based network services
• CPC Class Codes: H04L 67/564 Enhancement of application control based on intercepted application data
• CPC Class Codes: H04L 67/568 Storing data temporarily at an intermediate stage, e.g. caching

Abstract

To reduce repetitive data transfers, data content of an outgoing message is stored within cache storage of an intermediate node of a data communications network. A token for identifying the cached data content is stored at the intermediate node and the sender. When a subsequent outgoing message is to be routed from a first network node to a target destination via the intermediate node, a process running at the first node checks whether the content of the message matches data cached at the intermediate node. If there is a match, a copy of the token is sent from the first node to the intermediate node instead of the data content. The token is used at the intermediate node to identify the cached data, and the cached data is retrieved from the cache and forwarded to the target destination as an outgoing message.

Claims

1. A method for data communication between a first node and second node of a data processing network, for outgoing messages, the method comprising:

deriving a token from data contents of a first outgoing message, which outgoing message is sent from the first node to the second node;

storing the token in cache storage at the first node;

prior to sending a second outgoing message from the first node to the second node, deriving a token from data contents of the second outgoing message and comparing the token derived from data contents of the second outgoing message with tokens held in cache storage at the first node; and

,

in response to comparing, identifying a match, sending the matching token to the second node instead of sending the data contents of the second outgoing message.

2. The method of claim 1, further comprising prior to sending the matching token to the second node, checking that the second node implements a caching policy such that a matching token and data contents can be expected to be available at the second node, and sending the matching token only if the checking step indicates that the matching token and data contents can be expected to be available.

3. The method of claim 1, further comprising storing the token and the data contents in cache storage at the second node.

4. The method of claim 3, further comprising:

responsive to receipt of a token at the second node, comparing the received token with tokens held in cache storage at the second node; and

,

in response to identifying a matching token at the second node, retrieving the data contents from cache storage at the second node.

5. The method of claim 1, wherein, for the first outgoing message, deriving a token is performed at the first node and the derived token is sent to the second node together with the first outgoing message.

6. The method of claim 1, wherein, for the first outgoing message, deriving a token is performed by a process running at each of the first and second nodes, such that an identical token is derived at each of the first and second nodes.

7. The method claim 1, wherein deriving a token comprises hashing the data contents of an outgoing message.

8. The method of claim 1, wherein the first and second nodes are intermediate nodes within a network, between an originator of an outgoing message and a target destination of the outgoing message.

9. The method of claim 1, wherein at least one of the first and second nodes is a message broker within a publish/subscribe messaging network, the message broker identifying recipients for a message by comparing messages with stored subscriptions.

10. The method of claim 1, wherein the first and second nodes are messaging middleware computer programs for handling communications between respective first and second endpoint application programs.

11. The method of claim 10, wherein the first outgoing message comprises a message header and message body, and wherein the step of deriving a token from data contents of the first outgoing message comprises hashing said message body.

12. The method of claim 1, wherein the second node is a Web services gateway.

13. The method of claim 1, further comprising:

detecting a data size for the contents of an outgoing message; and

deriving, storing and comparing tokens only for outgoing messages for which the detected data size exceeds a threshold.

14. The method of claim 1, further comprising:

comparing an outgoing message with a predefined set of message types; and

deriving, storing and comparing tokens only for outgoing messages which match the predefined set of message types.

15. The method of claim 1, further comprising:

for a set of outgoing messages sent from the first node to the second node, for which set of outgoing messages the comparing identifies a single matching token, defining the target destinations of the set of outgoing messages as a group;

for a subsequent outgoing message sent from the first node to a first member of the group, deriving a second token from data contents of the subsequent outgoing message;

storing the second token and identification of the group in cache storage at the first node;

storing the second token and data contents of the subsequent outgoing message in cache storage at the second node; and

sending the second token to the second node with an instruction to forward an outgoing message to the members of the group other than the first member.

16. The method of claim 15, further comprising:

responsive to receipt of the second token and instruction at the second node, forwarding an outgoing message, including the data contents of the subsequent outgoing message, to the members of the group other than the first member.

17. A method for data communication between a first node and a second node of a data processing network, for outgoing messages, the method comprising:

deriving a token from data contents of a first outgoing message which is sent from the first node to the second node;

storing the token and the data contents in cache storage at the first node;

storing the token and the data contents in cache storage at the second node;

prior to sending a second outgoing message from the first node to the second node, comparing the data contents of the second outgoing message with the data contents stored in cache storage at the first node;

in response to comparing, identifying a partial match, deriving a delta file representing differences between the first outgoing message and the second outgoing message; and

sending the stored token and delta file to the second node without sending the full data contents of the second outgoing message.

18. The method of claim 17, including comparing the size of the delta file with a threshold size and determining whether the identified partial match should be accepted based on the delta file size comparison;

wherein sending the stored token and delta file is performed for an accepted partial match and the complete message contents is sent to the second node for a non-accepted partial match.

19. A data processing apparatus comprising a sender node for use in a method of data communication between a sender node and a receiver node of a data processing network, the sender node comprising:

means for deriving a token from data contents of a first outgoing message which is sent from the sender node to the receiver node, and for deriving a token from data contents of a second outgoing message, prior to sending the second outgoing message from the sender node to the receiver node means for storing, in cache storage at the sender node, the token derived from data contents of the first outgoing message;

means for comparing the token derived from data contents of the second outgoing message with tokens held in cache storage at the sender node, to identify a match; and

means, responsive to the comparing identifying a match, for determining that the matching token should be sent to the receiver node without the data contents of the second outgoing message.

20. A data communication network comprising:

a data processing apparatus comprising a sender node; and

a data processing apparatus comprising a receiver node, for use in a method of data communication between the sender node and the receiver node, wherein the receiver node comprises;

means for caching, in cache storage of the receiver node, message contents and corresponding tokens derived from said message contents;

means, responsive to receipt of a token representing a required data communication between the sender node and the receiver node, for comparing the received token with tokens cached at the receiver node, to identify a match;

means for retrieving, from cache storage of the receiver node in response to the comparing identifying a match, the matching cached message contents; and

means for passing the retrieved message contents to a target destination.