Working with AMQP

Exclusive offer: get 50% off this eBook here
RabbitMQ Cookbook

RabbitMQ Cookbook — Save 50%

Over 70 practical recipes to help you develop messaging applications using RabbitMQ with the help of plenty of real-life examples with this book and ebook

$26.99    $13.50
by Gabriele Santomaggio Sigismondo Boschi | December 2013 | Cookbooks Open Source

The article by Sigismondo Boschi and Gabriele Santomaggio, the authors of RabbitMQ Cookbook, introduces the basic concepts of AMQP, the Advanced Message Queuing Protocol, on which RabbitMQ is based. It shows how the fire-and-forget messaging model works and how to use it from clients.

(for more resources related to this topic, see here.)

Broadcasting messages

In this example we are seeing how to send the same message to a possibly large number of consumers.

This is a typical messaging application, broadcasting to a huge number of clients. For example, when updating the scoreboard in a massive multiplayer game, or when publishing news in a social network application.

In this article we are discussing both the producer and consumer implementation.

Since it is very typical to have consumers using different technologies and programming languages, we are using Java, Python, and Ruby to show interoperability with AMQP.

We are going to appreciate the benefits of having separated exchanges and queues in AMQP.

Getting ready

To use this article you will need to set up Java, Python and Ruby environments as described.

How to do it…

To cook this article we are preparing four different codes:

  • The Java publisher
  • The Java consumer
  • The Python consumer
  • The Ruby consumer

To prepare a Java publisher:

  1. Declare a fanout exchange:

    channel.exchangeDeclare(myExchange, "fanout");

  2. Send one message to the exchange:

    channel.basicPublish(myExchange, "", null, jsonmessage.getBytes());

Then to prepare a Java consumer:

  1. Declare the same fanout exchange declared by the producer:

    channel.exchangeDeclare(myExchange, "fanout");

  2. Autocreate a new temporary queue:

    String queueName = channel.queueDeclare().getQueue();

  3. Bind the queue to the exchange:

    channel.queueBind(queueName, myExchange, "");

  4. Define a custom, non-blocking consumer.
  5. Consume messages invoking channel.basicConsume()

The source code of the Python consumer is very similar to the Java consumer, so there is no need to repeat the needed steps.

In the Ruby consumer you need to use require "bunny" and then use the URI connection.

We are now ready to mix all together, to see the article in action:

  1. Start one instance of the Java producer; messages start getting published immediately.
  2. Start one or more instances of the Java/Python/Ruby consumer; the consumers receive only the messages sent while they are running.
  3. see that the consumer has lost the messages sent while it was down.

How it works…

Both the producer and the consumers are connected to RabbitMQ with a single connection, but the logical path of the messages is depicted in the following figure:

In step 1 we have declared the exchange that we are using. The logic is the same as in the queue declaration: if the specified exchange doesn't exist, create it; otherwise, do nothing.

The second argument of exchangeDeclare() is a string, specifying the type of the exchange, fanout in this case.

In step 2 the producer sends one message to the exchange. You can just view it along with the other defined exchanges issuing the following command on the RabbitMQ command shell:

rabbitmqctl list_exchanges

The second argument in the call to channel.basicPublish() is the routing key, which is always ignored when used with a fanout exchange. The third argument, set to null, is the optional message property. The fourth argument is just the message itself.

When we started one consumer, it created its own temporary queue (step 9). Using the channel.queueDeclare() empty overload, we are creating a nondurable, exclusive, autodelete queue with an autogenerated name.

Launching a couple of consumers and issuing rabbitmqctl list_queues, we can see two queues, one per consumer, with their odd names, along with the persistent myFirstQueue as shown in the following screenshot:

In step 5 we have bound the queues to myExchange. It is possible to monitor these bindings too, issuing the following command:

rabbitmqctl list_bindings

The monitoring is a very important aspect of AMQP; messages are routed by exchanges to the bound queues, and buffered in the queues.

Exchanges do not buffer messages; they are just logical elements.

The fanout exchange routes messages by just placing a copy of them in each bound queue. So, no bound queues and all the messages are just received by no one consumer.

As soon as we close one consumer, we implicitly destroy its private temporary queue (that's why the queues are autodelete; otherwise, these queues would be left behind unused, and the number of queues on the broker would increase indefinitely), and messages are not buffered to it anymore.

When we restart the consumer, it will create a new, independent queue and as soon as we bind it to myExchange, messages sent by the publisher will be buffered into this queue and pulled by the consumer itself.

There's more…

When RabbitMQ is started for the first time, it creates some predefined exchanges. Issuing rabbitmqctl list_exchanges we can observe many existing exchanges, in addition to the one that we have defined in this article:

All the amq.* exchanges listed here are already defined by all the AMQP-compliant brokers and can be used instead of defining your own exchanges; they do not need to be declared at all.

We could have used amq.fanout in place of myLastnews.fanout_6, and this is a good choice for very simple applications. However, applications generally declare and use their own exchanges.

See also

With the overload used in the article, the exchange is non-autodelete (won't be deleted as soon as the last client detaches it) and non-durable (won't survive server restarts). You can find more available options and overloads at http://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/.

Summary

In this article, we are mainly using Java since this language is widely used in enterprise software development, integration, and distribution. RabbitMQ is a perfect fit in this environment.

resources for article:


further resources on this subject:


RabbitMQ Cookbook Over 70 practical recipes to help you develop messaging applications using RabbitMQ with the help of plenty of real-life examples with this book and ebook
Published: December 2013
eBook Price: $26.99
Book Price: $44.99
See more
Select your format and quantity:

About the Author :


Gabriele Santomaggio

Gabriele Santomaggio has worked in the IT industry for more than 15 years. He is a developer, and very keen on middleware and distributed applications. Currently, he is working on high-performance Java applications.

He is the member of a big IT Italian community (www.indigenidigitali.com/) where he has published some posts about Amazon Web Services and message-oriented middleware (http://blog.indigenidigitali.com/tag/gabriele-santomaggio/).

He likes running and listening to jazz music.

Sigismondo Boschi

Sigismondo Boschi is a software developer currently involved in projects of messaging and networking distributed applications.

Prior to this, he has had more than 10 years' experience working with distributed applications and message-passing paradigms. He first acquired a PhD in Computational Physical Chemistry from the University of Bologna, and then has worked in the Development of Scientific High Performance Computing Projects.

Books From Packt


 Instant RabbitMQ Messaging Application Development How-to [Instant]
Instant RabbitMQ Messaging Application Development How-to [Instant]

HornetQ Messaging Developer’s Guide
HornetQ Messaging Developer’s Guide

 Instant Apache ActiveMQ Messaging Application Development How-to [Instant]
Instant Apache ActiveMQ Messaging Application Development How-to [Instant]

 Instant Apache Camel Message Routing [Instant]
Instant Apache Camel Message Routing [Instant]

 Instant Apache Camel Messaging System [Instant]
Instant Apache Camel Messaging System [Instant]

JavaScript and JSON Essentials
JavaScript and JSON Essentials

 Developing RESTful Services with JAX-RS 2.0, WebSockets, and JSON
Developing RESTful Services with JAX-RS 2.0, WebSockets, and JSON

 Instant GSON [Instant]
Instant GSON [Instant]


Code Download and Errata
Packt Anytime, Anywhere
Register Books
Print Upgrades
eBook Downloads
Video Support
Contact Us
Awards Voting Nominations Previous Winners
Judges Open Source CMS Hall Of Fame CMS Most Promising Open Source Project Open Source E-Commerce Applications Open Source JavaScript Library Open Source Graphics Software
Resources
Open Source CMS Hall Of Fame CMS Most Promising Open Source Project Open Source E-Commerce Applications Open Source JavaScript Library Open Source Graphics Software