1.Fanout Exchange介紹
Fanout Exchange 消息廣播的模式，不管路由鍵或者是路由模式，會把消息發(fā)給綁定給它的全部隊列，如果配置了routing_key會被忽略。
如上圖所示，即當(dāng)使用fanout交換器時，他會將消息廣播到與該交換器綁定的所有隊列上，這有利于你對單條消息做不同的反應(yīng)。
例如存在以下場景：一個web服務(wù)要在用戶完善信息時，獲得積分獎勵，這樣你就可以創(chuàng)建兩個對列，一個用來處理用戶信息的請求，另一個對列獲取這條消息是來完成積分獎勵的任務(wù)。
2.代碼示例
1）.Queue配置類
FanoutRabbitConfig.java類：
|
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
|
package com.example.rabbitmqfanout;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder;import org.springframework.amqp.core.FanoutExchange;import org.springframework.amqp.core.Queue;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class FanoutRabbitConfig { //創(chuàng)建隊列 @Bean public Queue AMessage() { return new Queue("fanout.A"); } //創(chuàng)建隊列 @Bean public Queue BMessage() { return new Queue("fanout.B"); } //創(chuàng)建隊列 @Bean public Queue CMessage() { return new Queue("fanout.C"); } //創(chuàng)建Fanout交換器 @Bean FanoutExchange fanoutExchange() { return new FanoutExchange("fanoutExchange"); } //將對列綁定到Fanout交換器 @Bean Binding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) { return BindingBuilder.bind(AMessage).to(fanoutExchange); } //將對列綁定到Fanout交換器 @Bean Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) { return BindingBuilder.bind(BMessage).to(fanoutExchange); } //將對列綁定到Fanout交換器 @Bean Binding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) { return BindingBuilder.bind(CMessage).to(fanoutExchange); } } |
2）.消息生產(chǎn)者
FanoutSender.java類:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
package com.example.rabbitmqfanout.rabbitmq;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;@Componentpublic class FanoutSender { @Autowired private AmqpTemplate rabbitTemplate; public void send() { String context = "hi, fanout msg "; System.out.println("Sender : " + context); this.rabbitTemplate.convertAndSend("fanoutExchange","", context); }} |
3）.消息消費者
FanoutReceiverA.java類：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
package com.example.rabbitmqfanout.rabbitmq;import org.springframework.amqp.rabbit.annotation.RabbitHandler;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Component@RabbitListener(queues = "fanout.A")public class FanoutReceiverA { @RabbitHandler public void process(String message) { System.out.println("fanout Receiver A : " + message); }} |
FanoutReceiverB.java類：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
package com.example.rabbitmqfanout.rabbitmq;import org.springframework.amqp.rabbit.annotation.RabbitHandler;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Component@RabbitListener(queues = "fanout.B")public class FanoutReceiverB { @RabbitHandler public void process(String message) { System.out.println("fanout Receiver B: " + message); }} |
FanoutReceiverC.java類：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
package com.example.rabbitmqfanout.rabbitmq;import org.springframework.amqp.rabbit.annotation.RabbitHandler;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Component@RabbitListener(queues = "fanout.C")public class FanoutReceiverC { @RabbitHandler public void process(String message) { System.out.println("fanout Receiver C: " + message); }} |
4）.測試
FanoutTest.java類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
package com.example.rabbitmqfanout.rabbitmq;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class)@SpringBootTestpublic class FanoutTest { @Autowired private FanoutSender sender; @Test public void fanoutSender() throws Exception { sender.send(); }} |
以上所述是小編給大家介紹的spring boot整合RabbitMQ（Fanout模式），希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對服務(wù)器之家網(wǎng)站的支持！
原文鏈接：http://www.cnblogs.com/web424/p/6767713.html
