Routing using partial message parsing
A message router partially decodes messages to determine how to route the messages. The message router receives a message and identifies a field of the message as a candidate field for including an envelope identifier that indicates an envelope type of the message. The envelope type of the message indicates where information, such as where to route the message, is stored within the message. The message router attempts to decode the candidate field to determine whether the candidate field includes the envelope identifier, and responsive to the candidate filed including the envelope identifier, the message router determines the envelope type of the message. The message router routes the message according to the envelope type.
1. A method for routing a message in a network, the method comprising:
receiving the message at a message router;
identifying a field of the message as a candidate field for including an envelope identifier, the envelope identifier indicating an envelope type of the message, wherein identifying the field of the message as the candidate field comprises:
determining whether the field is length delimited; and
responsive to the field being length delimited, selecting the field as the candidate field;
decoding the candidate field to determine whether the candidate field includes the envelope identifier;
responsive to the candidate field including the envelope identifier, determining the envelope type of the message; and
routing the message according to the envelope type.
2. The method of claim 1 , further comprising:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a second field in the message is not a length delimited field; and
writing the second field to a forwarding buffer without decoding the second field.
3. The method of claim 2 , further comprising: responsive to the candidate field including the envelope identifier, writing a remainder of the message to the forwarding buffer.
4. The method of claim 1 , further comprising:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a third field in the message is length delimited;
decoding the third field to determine whether the third field includes the envelope identifier; and
responsive to the third field not including the envelope identifier, writing the third field to a forwarding buffer.
5. The method of claim 4 , further comprising: responsive to the candidate field including the envelope identifier, writing a remainder of the message to the forwarding buffer.
6. The method of claim 1 , wherein determining whether the field is length delimited comprises decoding a start byte.
7. The method of claim 1 , wherein the envelope identifier is indicative of which bytes in the message correspond to routing information.
8. The method of claim 1 , wherein routing the message comprises extracting a payload from the message and forwarding the payload to a destination in a network without forwarding remaining fields of the message.
9. A non-transitory computer-readable storage medium storing instructions that, when executed by a processor, cause the processor to perform operations comprising:
receiving a message at a message router;
identifying a field of the message as a candidate field for including an envelope identifier, the envelope identifier indicating an envelope type of the message, wherein identifying the field of the message as the candidate field comprises:
determining whether the field is length delimited; and
responsive to the field being length delimited, selecting the field as the candidate field:
decoding the candidate field to determine whether the candidate field includes the envelope identifier;
responsive to the candidate field including the envelope identifier, determining the envelope type of the message; and
routing the message according to the envelope type.
10. The non-transitory computer-readable storage medium of claim 9 , wherein the operations further comprise:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a second field in the message is not a length delimited field; and
writing the second field to a forwarding buffer without decoding the second field.
11. The non-transitory computer-readable storage medium of claim 10 , wherein the operations further comprise: responsive to the candidate field including the envelope identifier, writing a remainder of the message to the forwarding buffer.
12. The non-transitory computer-readable storage medium of claim 9 , wherein the operations further comprise:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a third field in the message is length delimited;
decoding the third field to determine whether the third field includes the envelope identifier; and
responsive to the third field not including the envelope identifier, writing the third field to a forwarding buffer.
13. The non-transitory computer-readable storage medium of claim 12 , wherein the operations further comprise: responsive to the candidate field including the envelope identifier, writing a remainder of the message to the forwarding buffer.
14. The non-transitory computer-readable storage medium of claim 9 , wherein determining whether the field is length delimited comprises decoding a start byte.
15. The non-transitory computer-readable storage medium of claim 9 , wherein the envelope identifier is indicative of which bytes in the message correspond to routing information.
16. The non-transitory computer-readable storage medium of claim 9 , wherein routing the message comprises extracting a payload from the message and forwarding the payload to a destination in a network without forwarding remaining fields of the message.
17. A message router comprising:
a local data store storing a list of client devices connected to the message router; and
a routing module configured to perform operations comprising:
receiving a message at the message router;
identifying a field as a candidate field for including an envelope identifier, the envelope identifier indicating an envelope type of the message, wherein identifying the field of the message as the candidate field comprises:
determining whether the field is length delimited; and
responsive to the field being length delimited, selecting the field as the candidate field;
decoding the candidate field to determine whether the candidate field includes the envelope identifier;
responsive to the candidate field including the envelope identifier, determining the envelope type of the message; and
routing the message according to the envelope type.
18. The message router of claim 17 , wherein the operations further comprise:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a second field in the message is not a length delimited field; and
writing the second field to a forwarding buffer without decoding the second field.
19. The message router of claim 17 , wherein the operations further comprise:
prior to identifying the field as the candidate field for including the envelope identifier, determining that a third field in the message is length delimited;
decoding the third field to determine whether the third field includes the envelope identifier; and
responsive to the third field not including the envelope identifier, writing the third field to a forwarding buffer.
20. The message router of claim 17 , wherein routing the message comprises extracting a payload from the message and forwarding the payload to a destination in a network without forwarding remaining fields of the message.