In my previous post, I provided a quick overview of three basic concepts of RabbitMQ: exchange, routing keys and queues.
In this post, I will explain how to wire it all together.
What are the different types of exchanges?
There are four types: fanout, direct, topic and headers. They allow for increasing levels of filtering.
An exchange will dispatch its messages to queues that have the correct bindings defined.
Wait, what is a binding?
A binding is the connection between an exchange and a queue. A binding defines when a message that has been posted to an exchange will be put on a certain queue.
A binding consists of of three things:
- the exchange
- the routing key
- the queue
The important thing here is the combination of the exchange and the routing key. These will decide whether or not the message is put on the queue.
In the case of a fanout exchange, the routing key is ignored. All messages put on the exchange that is mentioned in the binding will end up in the queue.
If the binding mentions a direct exchange, the routing key of the message must match the routing key of the binding exactly. Only then will the message be put on the queue.
If the binding mentions a topic exchange, it gets a little more complex, but also more powerful. It allows you to filter out certain messages more granularly.
A binding to a direct exchange only allows messages on the queue if their routing key is exactly the same as the routing key of the binding. But in case of a topic exchange you can use wildcards.
This requires you to send messages to the exchange with a routing key that consists of multiple words, separated by dots, for example
You could then use this to route all purchases to a queue, by defining a binding with a routing key of
If a certain queue only needs the purchases of premium customers, you could use the routing key
You could definitely achieve the same with direct exchanges and multiple bindings, but you would need a binding for every routing key, making management more and more complex when more routing keys come into existence.
For example, say you have these routing keys:
If you wanted a queue to receive all
customer messages, you would need 4 bindings on a direct exchange. With a topic exchange, you only need one binding, with
customer.* as a routing key.
One final remark. There are two wildcards:
* will match exactly one word, whereas the
# will match zero or more words.
premiumcustomer.# will match
RabbitMQ configuration isn't that hard, but it allows a lot of flexibility. The key is in the bindings and how it is defined by the routing key and the type of exchange. My suggestion would be that simple projects can and should start with direct exchanges and only move to topic exchanges once there is a need for it (YAGNI, remember?).