Neworking internet of things (IoT) devices

1. An electronic device for use in a publish-subscribe messaging system, the electronic device comprising:

a storage device; and

a processor to:

generate a topic string comprising a string of characters that represent a subscription to a requested publication;

generate a subscription filter based on the topic string;

receive a publication comprising a data payload and a publication filter;

perform a bitwise comparison of the subscription filter and the publication filter to determine whether the publication is a destination match for the subscription; and

if the publication is a destination match for the subscription, consume the data payload of the publication.

2. The electronic device of claim 1 , wherein the processor is to generate a routing vector based on the subscription filter and send the routing vector to a downstream subscriber node.

3. The electronic device of claim 1 , wherein the subscription filter and the publication filter are Bloom filters.

4. The electronic device of claim 1 , wherein the processor is to:

generate a first routing vector based on the subscription filter;

receive a second routing vector from an upstream subscriber node;

combine the first routing vector and second routing vector to generate a combined routing vector; and

send the combined routing vector to a downstream subscriber node.

5. The electronic device of claim 1 , wherein the processor is to generate an interests vector based on the subscription filter, wherein the interests vector is equal to the subscription filter.

6. The electronic device of claim 1 , wherein the processor is to:

generate a first interests vector based on the subscription filter;

receive a second interests vector from an upstream subscriber node;

combine the first interests vector and second interests vector via a bitwise AND operation to generate a combined interests vector; and

send the combined interests vector to a downstream subscriber node.

7. The electronic device of claim 1 , wherein the processor is to generate a needs vector based on the subscription filter, wherein the needs vector is a locality sensitive hash of the subscription filter and includes a unary encoding of a number of bits set in the subscription filter.

8. The electronic device of claim 1 , wherein the processor is to:

generate a first needs vector based on the subscription filter;

receive a second needs vector from an upstream subscriber node;

combine the first needs vector and second needs vector via a bitwise OR operation to generate a combined needs vector; and

send the combined needs vector to a downstream subscriber node.

9. The electronic device of claim 1 , wherein the processor is to:

receive an interests vector from an upstream subscriber node;

compare the interests vector to the publication filter; and

if any bit set in the interests vector is also set in the publication filter, forward the publication to the upstream subscriber node.

10. The electronic device of claim 1 , wherein the processor is to:

receive an interests vector and a needs vector from an upstream subscriber node;

compute an intersection of the publication filter and the interests vector and compute a locality sensitive hash of the intersection; and

if the locality sensitive hash is a superset or equal to the needs vector, forward the publication to the upstream subscriber node.

11. A method of operating a subscriber node in a publish-subscribe messaging system, the method comprising:

generating a topic string comprising a string of characters that represent a subscription to a requested publication;

generating a subscription filter based on the topic string;

receiving a publication comprising a data payload and a publication filter;

performing a bitwise comparison of the subscription filter and the publication filter to determine whether the publication is a destination match for the subscription; and

if the publication is a destination match for the subscription, consuming the data payload of the publication.

12. The method of claim 11 , comprising:

generating a first routing vector based on the subscription filter;

receiving a second routing vector from an upstream subscriber node;

combining the first routing vector and second routing vector to generate a combined routing vector; and

sending the combined routing vector to a downstream subscriber node.

13. The method of claim 11 , comprising:

generating a first interests vector based on the subscription filter;

receiving a second interests vector from an upstream subscriber node;

combining the first interests vector and second interests vector via a bitwise AND operation to generate a combined interests vector; and

sending the combined interests vector to a downstream subscriber node.

14. The method of claim 11 , comprising generating a needs vector based on the subscription filter, wherein the needs vector is a locality sensitive hash of the subscription filter and includes a unary encoding of a number of bits set in the subscription filter.

15. The method of claim 11 , comprising:

generating a first needs vector based on the subscription filter;

receiving a second needs vector from an upstream subscriber node;

combining the first needs vector and second needs vector via a bitwise OR operation to generate a combined needs vector; and

sending the combined needs vector to a downstream subscriber node.

16. The method of claim 11 , comprising:

receiving an interests vector from an upstream subscriber node;

comparing the interests vector to the publication filter; and

if any bit set in the interests vector is also set in the publication filter, forwarding the publication to the upstream subscriber node.

17. The method of claim 11 , comprising:

receiving an interests vector and a needs vector from an upstream subscriber node;

computing an intersection of the publication filter and the interests vector and computing a locality sensitive hash of the intersection; and

if the locality sensitive hash is a superset or equal to the needs vector, forwarding the publication to the upstream subscriber node.

18. The method of claim 11 , comprising generating a routing vector based on the subscription filter and sending the routing vector to a downstream subscriber node.

19. The method of claim 11 , wherein the subscription filter and the publication filter are Bloom filters.

20. The method of claim 11 , comprising generating an interests vector based on the subscription filter, wherein the interests vector is equal to the subscription filter.

21. A tangible, non-transitory, computer-readable medium comprising instructions that, when executed by a processor, direct the processor to operate a subscriber node in a publish-subscribe messaging system, the instructions to direct the processor to:

generate a topic string comprising a string of characters that represent a subscription to a requested publication;

generate a subscription filter based on the topic string;

receive a publication comprising a data payload and a publication filter;

perform a bitwise comparison of the subscription filter and the publication filter to determine whether the publication is a destination match for the subscription; and

if the publication is a destination match for the subscription, consume the data payload of the publication.

22. The computer-readable medium of claim 21 , comprising instructions to direct the processor to:

generate a first interests vector based on the subscription filter;

receive a second interests vector from an upstream subscriber node;

combine the first interests vector and second interests vector via a bitwise AND operation to generate a combined interests vector; and

send the combined interests vector to a downstream subscriber node.

23. The computer-readable medium of claim 21 , comprising instructions to direct the processor to:

generate a first needs vector based on the subscription filter;

receive a second needs vector from an upstream subscriber node;

combine the first needs vector and second needs vector via a bitwise OR operation to generate a combined needs vector; and

send the combined needs vector to a downstream subscriber node.

24. The computer-readable medium of claim 21 , comprising instructions to direct the processor to:

receive an interests vector from an upstream subscriber node;

compare the interests vector to the publication filter; and

if any bit set in the interests vector is also set in the publication filter, forward the publication to the upstream subscriber node.

25. The computer-readable medium of claim 21 , comprising instructions to direct the processor to:

receive an interests vector and a needs vector from an upstream subscriber node;

compute an intersection of the publication filter and the interests vector and compute a locality sensitive hash of the intersection; and

if the locality sensitive hash is a superset or equal to the needs vector, forward the publication to the upstream subscriber node.