1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
# RabbitMQ Random Exchange Type
This exchange type is for load-balancing among consumers. It's basically
a direct exchange, with the exception that, instead of each consumer bound
to that exchange with the same routing key getting a copy of the message,
the exchange type randomly selects a queue to route to.
There is no weighting or anything, so maybe load "balancing" might be a bit
of a misnomer. It uses Erlang's crypto:rand_uniform/2 function, if you're
interested.
## Installation
Install the corresponding .ez files from our
[GitHub releases](https://github.com/rabbitmq/rabbitmq-random-exchange/releases) or [Community Plugins page](https://www.rabbitmq.com/community-plugins.html).
Then run the following command:
```bash
rabbitmq-plugins enable rabbitmq_random_exchange
```
## Building from Source
Please see [RabbitMQ Plugin Development guide](https://www.rabbitmq.com/plugin-development.html).
To build the plugin:
git clone git://github.com/rabbitmq/rabbitmq-random-exchange.git
cd rabbitmq-random-exchange
make
Then copy all the `*.ez` files inside the `plugins` folder to the [RabbitMQ plugins directory](https://www.rabbitmq.com/relocate.html)
and enable the plugin:
[sudo] rabbitmq-plugins enable rabbitmq_random_exchange
## Usage
To create a _random_, just declare an exchange providing the type `"x-random"`.
```java
channel.exchangeDeclare("logs", "x-random");
```
and bind several queues to it. Routing keys will be ignored by modern releases
of this exchange plugin: the binding and its target queue (exchange) are picked
entirely randomly.
### Extended Example
This example uses [Bunny](http://rubybunny.info) and demonstrates
how the plugin is mean to be used with 3 queues:
``` ruby
#!/usr/bin/env ruby
require 'bundler'
Bundler.setup(:default)
require 'bunny'
c = Bunny.new; c.start
ch = c.create_channel
rx = ch.exchange("x.rnd", durable: true, type: "x-random")
q1 = ch.queue("r1").bind(rx)
q2 = ch.queue("r2").bind(rx)
q3 = ch.queue("r3").bind(rx)
ch.confirm_select
100.times do
rx.publish(rand.to_s, routing_key: rand.to_s)
end
ch.wait_for_confirms
# the consumer part is left out: see
# management UI
puts "Done"
```
## License
See [LICENSE](./LICENSE).
|
