Delivering messages from message sources to subscribing recipients

• US 10,454,864 B2
• Filed: 04/21/2014
• Issued: 10/22/2019
• Est. Priority Date: 06/23/2010
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Inventors: Ickman, Steven W., Laird-McConnell, Thomas M.
• Primary Examiner(s): Nano, Sargon N
• Application Number:
  US14/257,894
• Publication Number:
  US 20140229561A1
• Time in Patent Office: 2,010 Days
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: H04L 51/212 using filtering or selective blocking
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 51/52 for supporting social networking services

Abstract

Many scenarios involve the delivery of messages received from various message sources to recipients, based on subscriptions established between various recipients and message sources. The recipients may be distributively assigned to one or more message servers, either operating independently or as part of an interoperating message server set. Respective message servers may generate a subscription filter indicating whether at least one assigned recipient subscribes to respective message sources, and may utilize the subscription filter to determine, upon receiving a message from a message source, whether to discard the message or store the message for delivery. Interoperating message servers may also exchange subscription filters, and upon receiving a message from any message source, a message server may utilize the subscription filters of the other message servers to determine which other message servers are assigned at least one subscribing recipient, and may retransmit the message only to such message servers.

Claims

1. A method of causing a message server having a processor, a memory, and a subscription filter, to deliver messages respectively generated by a message source to a first user and a second user of the who are serviced by the message server, the method comprising:

executing, by the processor, instructions that cause the message server to;

responsive to receiving a message from a message source;

examine the subscription filter to determine whether at least one-of the first user and the second user subscribes to the message source;

responsive to determining that at least one of the first user and the second user subscribes to the message source;

store a copy of the message in the memory, and

store in the memory an association of the message with the at least one of the first user and the second user who subscribe to the message source; and

responsive to a receive request from a selected user to receive messages;

identify a selected message that is associated with the selected user;

retrieve, from the message store, the copy of the selected message; and

present the selected message to the user.

2. The method of claim 1, wherein:

the message server further comprises a social network server in a social network;

the message source further comprises a third user of the social network authoring at least one message; and

the user comprising a second user of the social network subscribing to messages of the first user.

3. The method of claim 1, wherein executing the instructions further causes the message server to, responsive to a subscribe request from a selected user to subscribe to a message source:

update the user profile of the selected user to identify the message source subscribed by the selected user; and

update the subscription filter to indicate that at least one user assigned to the message server subscribes to the message source.

4. The method of claim 1, wherein the subscription filter further comprises a bloom filter indicating, for respective message sources, whether at least one user assigned to the message server subscribes to the message source.

5. The method of claim 4, wherein updating the subscription filter to indicate that at least one user assigned to the message server subscribes to the message source further comprises:

inserting the message source into the bloom filter to indicate that at least one user assigned to the message server subscribes to the message source.

6. The method of claim 4, wherein executing the instructions further causes the message server to:

responsive to an unsubscribe request from a subscribing user to unsubscribe from a message source, identify a second subscribing user, not comprising the subscribing user, who subscribes to the message source; and

responsive to failing to identify a second subscribing user who subscribes to the message source, update the bloom filter to indicate that no users assigned to the message server subscribe to the message source.

7. The method of claim 4, wherein executing the instructions further causes the device to, responsive to a removal request to remove a recipient selected user from the message server:

identify a second user, not comprising the selected user, who subscribes to the message source; and

responsive to failing to identify a second user who subscribes to the message source, update the bloom filter to indicate that no users assigned to the message server subscribe to the message source.

8. The method of claim 4, wherein:

the message server also stores, within respective user profiles of users assigned to the message server, a list of message sources subscribed by the user; and

regenerating the bloom filter further comprises;

evaluate an accuracy of the bloom filter; and

responsive to determining that the accuracy of the bloom filter is below an accuracy threshold, regenerate the bloom filter according to the user profiles of the users assigned to the message server.

9. The method of claim 8, wherein:

the bloom filter initially uses a first hash technique; and

regenerating the bloom filter further comprises;

regenerating the bloom filter using a second hash technique that is different from the first hash technique.

10. The method of claim 1, wherein:

the message server is included in a message server set;

respective users of the message sever set are assigned to a selected message server in the message server set; and

the message servers of the message server set share an assignment map indicating an assignment of respective users to a message server in the message server set.

11. The method of claim 10, wherein executing the instructions further causes the message server to, responsive to a receive request from the selected user to receive messages:

using the assignment map, determine whether the selected user is assigned to the message server; and

responsive to determining that the selected user is not assigned to the message server and is assigned to a second message server of the message server set, forward the receive request of the selected user to the second message server.

12. The method of claim 10, wherein executing the instructions further causes the message server to, responsive to an assignment request to assign a new user to the message server:

generate a new user profile identifying the message sources subscribed by the new user; and

update the assignment map indicating an assignment of the new user to the message server.

13. The method of claim 12, wherein:

respective users are assigned to a message server of the message server set based on a predicted shared set of message sources subscribed by the respective users; and

executing the instructions further causes the message server to, responsive to the add request to add the new user to the message server set;

identify, among the message servers of the message server set, a selected message server for which the new user shares a predicted shared set of message sources with other users assigned to the selected message server; and

update the assignment map indicating an assignment of the new user to the selected message server.

14. The method of claim 13, wherein predicting the predicted shared set of message sources subscribed by the users of the message server set further comprises:

for respective users, identifying at least one demographic trait that is predictive of message sources that may be subscribed by the user; and

assigning to a message server the users of the message server set who share at least one shared demographic trait.

15. The method of claim 10, wherein executing the instructions further causes the message server to, responsive to identifying at least one shared message source subscribed by a first user who is hosted by the message server and a second user who is hosted by a second message server, send, to the second message server, a transfer request to transfer the second user from the second message server to the message server.

16. The method of claim 10, wherein executing the instructions further causes the message server to:

responsive to receiving a second subscription filter from a second message server, store the second subscription filter of the second message server; and

responsive to receiving a message from a message source, for respective second subscription filters;

examine the second subscription filter to identify at least one user who is assigned to the second message server and who subscribes to the message source, and

responsive to identifying the at least one user who is assigned to the second message server and who subscribes to the message source, forward the message to the second message server.

17. The method of claim 16, wherein executing the instructions further causes the device to, responsive to joining the message server set, send the subscription filter to at least one other message server of the message server set.

18. The method of claim 16, wherein executing the instructions further causes the device to, responsive to leaving the message server set:

for respective users assigned to the message server, transfer the user to another message server of the message server set; and

request at least one second message server of the message server set to remove the subscription filter for the message server.

19. The method of claim 16, wherein executing the instructions further causes the message server to:

identify a popular message source that is subscribed by many users of the message server set; and

responsive to receiving a message from the popular message source, send the message to the message servers of the message server set.

20. The method of claim 1, wherein executing the instructions further causes the message server to, responsive to receiving a message from a message source having zero users of the message server who are subscribed to the message source according to the subscription filter, discard the message.