{"id":2365,"date":"2011-12-13T10:36:36","date_gmt":"2011-12-13T09:36:36","guid":{"rendered":"http:\/\/www.devco.net\/?p=2365"},"modified":"2011-12-14T09:54:44","modified_gmt":"2011-12-14T08:54:44","slug":"common-messaging-patterns-using-stomppart-4","status":"publish","type":"post","link":"https:\/\/www.devco.net\/archives\/2011\/12\/13\/common-messaging-patterns-using-stomppart-4.php","title":{"rendered":"Common Messaging Patterns Using Stomp \u2013 Part 4"},"content":{"rendered":"<p>This is an ongoing post in a series of posts about Middlware for Stomp users, please read parts <a href=\"http:\/\/www.devco.net\/archives\/2011\/12\/11\/common-messaging-patterns-using-stomp.php\">1<\/a>, <a href=\"http:\/\/www.devco.net\/archives\/2011\/12\/11\/common-messaging-patterns-using-stomp-%E2%80%93-part-2.php\">2<\/a> and <a href=\"http:\/\/www.devco.net\/archives\/2011\/12\/12\/common-messaging-patterns-using-stomp-part-3.php\">3<\/a> of this series first before continuing below.<\/p>\n<p>Back in Part 2 we wrote a little system to ship metrics from nodes into Graphite via Stomp.  This solved the goals of the problem then but now lets see what to do when our needs change.  <\/p>\n<p>Graphite is like RRD where it would summarize data over time and eventually discard old data.  Contrast that with OpenTSDB that never summarizes or delete data and can store billions of data points. Imagine we want to use Graphite for a short term reporting service for our data but we also need to store the data long term without losing any data.  So we really want to store the data in 2 locations.<\/p>\n<p>We have a few options open to use:<\/p>\n<ul>\n<li>Send the metric twice from every node, once to Graphite and once to OpenTSDB.<\/li>\n<li>Write a software router that receives metrics on one queue and then route the metric to 2 other queues in the middleware.<\/li>\n<li>Use facilities internal to the middleware to do the routing for us<\/li>\n<\/ul>\n<p>The first option is an obvious bad idea and should just be avoided &#8211; this would be the worst case scenario for data collection at scale.  The 3rd seems like the natural choice here but first we need to understand the facilities the middleware provides.  Todays article will explore what ActiveMQ can do for you in this regard.<\/p>\n<p>The 2nd seems an odd fit but as you&#8217;ll see below the capabilities for internal routing at the middleware layer isn&#8217;t all that exciting, useful in some cases but I think most projects will reach for some kind of message router in code sooner or later.<\/p>\n<p><strong>Virtual Destinations<\/strong><br \/>\nIf you think back to part 2 you&#8217;ll remember we have a publisher that publishes data into a queue and any number of consumers that consumes the queue.  The queue will load balance the messages for us thus helping us scale.<\/p>\n<p>In order to also create OpenTSDB data we essentially need to double up the consumer side into 2 groups.  Ideally each set of consumers will be scalable horizontally and the sets of consumers should both get a copy of all the data &#8211; in other words we need 2 queues with all the data in it, one for Graphite and one for OpenTSDB.<\/p>\n<p>You will also remember that Topics have the behavior of duplicating data they receive to all consumers of the topics.  So really what we want is to attach 2 queues to a single topic.  This way the topic will duplicate the data and the queues will be used for the scalable consumption of the data.<\/p>\n<p>ActiveMQ provides a feature called Virtual Topics that solves this exact problem by convention.  You publish messages to a predictably named topic and then you can create any number of queues that will all get a copy of that message.<\/p>\n<p><center><img decoding=\"async\" src=\"http:\/\/devco.net\/images\/activemq-virtual-topics.png\"><\/center><\/p>\n<p>The image above shows the convention:<\/p>\n<ul>\n<li>Publish to <em>\/topic\/VirtualTopic.metrics<\/em><\/li>\n<li>Create consumers for <em>\/queue\/Consumer.Graphite.VirtualTopic.metrics<\/em><\/li>\n<\/ul>\n<p>Create as many of the consumer queues as you want, changing <em>Graphite<\/em> for some unique name and each of the resulting queues will behave like a normal queue with all the load balancing, storage and other queue like behaviors but all the queues will get a copy of all the data.<\/p>\n<p>You can customize the name pattern of these queues by changing the ActiveMQ configuration files.  I really like this approach to solving the problem vs approaches found in other brokers since this is all done by convention and you do not need to change your code to set up a bunch of internal structures that describes the routing topology.  I consider routing topology that is living in code of the consumers to be a form of hard coding.  Using this approach all I need to do is make sure the names of the destinations to publish to and consume from is configurable strings.<\/p>\n<p>Our Graphite consumer would not need to change other than the name of the queue it should read and ditto for the producer.<\/p>\n<p>If we find that we simply could not change the code for the consumers\/producer or if it just was not a configurable setting you can still achieve this behavior by using something called a <em>Composite Destinations<\/em> in ActiveMQ that could describe this behavior purely in the config file with any arbitrarily named queues and topics.<\/p>\n<p><strong>Selective Consumers<\/strong><br \/>\nImagine we wish to give each one of our thousands of servers a unique destination on the middleware so that we can send machines a command directly.  You could simple create queues like <em>\/queue\/nodes.web1.example.com<\/em> and keep creating queues per server.<\/p>\n<p>The problem with this approach is that internally to ActiveMQ each queue is a thread.  So you&#8217;d be creating thousands of threads &#8211; not ideal.<\/p>\n<p>As we saw before in Part 3 messages can have headers &#8211; there we used the <em>reply-to<\/em> header.  Below you&#8217;ll find some code that sets an arbitrary header:<\/p>\n<p><code><\/p>\n<pre lang=\"ruby\">\r\nstomp.publish(\"\/queue\/nodes\", \"service restart httpd\", {\"fqdn\" => \"web1.example.com\"})\r\n<\/pre>\n<p><\/code><\/p>\n<p>We are publishing a message with the text <em>service restart httpd<\/em> to a queue and we are setting a <em>fqdn<\/em> header.  <\/p>\n<p>Now if every server in our estate subscribed to this one queue with the knowledge you have at this point of Queues this would have the effect of sending this restart request to some random one of our servers, not ideal!<\/p>\n<p>The JMS specification allow for something called selectors to be used while subscribing to a destination:<\/p>\n<p><code><\/p>\n<pre lang=\"ruby\">\r\nstomp.subscribe(\"\/queue\/nodes\", {\"selector\" => \"fqdn = 'web1.example.com'\"})\r\n<\/pre>\n<p><\/code><\/p>\n<p>The <em>selector<\/em> header sets the logic to apply to every message which will help decide if you get the message on your subscription or not.  The selector language is defined using SQL 92 language and you can generally apply logic to any header in the message.<\/p>\n<p>This way we set up a queue for all our servers without the overhead of 1000s of threads.<\/p>\n<p>The choice for when to use a queue like this and when to use a traditional queue comes down to weighing up the overhead of validating all the SQL statements vs creating all the threads.  There are also some side effects if you have a cluster of brokers &#8211; the queue traffic gets duplicated to all cluster brokers where with traditional queues the traffic only gets send to a broker if that broker actually has any subscribers interested in this data.<\/p>\n<p>So you need to carefully consider the implications and do some tests with your work load, message sizes, message frequencies, amount of consumers etc.<\/p>\n<p><strong>Conclusion<\/strong><br \/>\nThere is a 3rd option that combines these 2 techniques.  You&#8217;d create queues sourcing from the topic based on JMS Selectors deciding what data hits what queue.  You would set up this arrangement in the ActiveMQ config file.<\/p>\n<p>This, as far as I am aware, covers all the major areas internal to ActiveMQ that you can use to apply some routing and duplication of messages.  <\/p>\n<p>These methods are useful and solves some problems but as I pointed out it&#8217;s not really that flexible.  In a later part of this series I will look into software routers from software like Apache Camel and how to write your own.<\/p>\n<p>From a technology choices point of view future self is now thanking past self for building the initial metrics system using MOM since rather than go back to the drawing board when our needs changed we were able to solve our problems by virtue of the fact that we built it on a flexible foundation using well known patterns and without changing much if any actual code. <\/p>\n<p>This series continue in <a href=\"http:\/\/www.devco.net\/archives\/2011\/12\/14\/common-messaging-patterns-using-stomp-%E2%80%93-part-5.php\">part 5<\/a>.<\/p>\n","protected":false},"excerpt":{"rendered":"<p>This is an ongoing post in a series of posts about Middlware for Stomp users, please read parts 1, 2 and 3 of this series first before continuing below. Back in Part 2 we wrote a little system to ship metrics from nodes into Graphite via Stomp. This solved the goals of the problem then [&hellip;]<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_et_pb_use_builder":"","_et_pb_old_content":"","footnotes":""},"categories":[7],"tags":[121,85,36,101,13,93],"_links":{"self":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/2365"}],"collection":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/comments?post=2365"}],"version-history":[{"count":15,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/2365\/revisions"}],"predecessor-version":[{"id":2406,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/2365\/revisions\/2406"}],"wp:attachment":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/media?parent=2365"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/categories?post=2365"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/tags?post=2365"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}