快捷導(dǎo)航

spring boot整合RabbitMQ實(shí)例詳解（Fanout模式）

更新時(shí)間：2017年04月26日 14:24:46 作者：牛頭人

這篇文章主要介紹了spring boot整合RabbitMQ的實(shí)例講解（Fanout模式）,非常不錯(cuò)，具有參考借鑒價(jià)值，需要的朋友可以參考下

1.Fanout Exchange介紹

Fanout Exchange 消息廣播的模式，不管路由鍵或者是路由模式，會(huì)把消息發(fā)給綁定給它的全部隊(duì)列，如果配置了routing_key會(huì)被忽略。

如上圖所示，即當(dāng)使用fanout交換器時(shí)，他會(huì)將消息廣播到與該交換器綁定的所有隊(duì)列上，這有利于你對(duì)單條消息做不同的反應(yīng)。

例如存在以下場(chǎng)景：一個(gè)web服務(wù)要在用戶完善信息時(shí)，獲得積分獎(jiǎng)勵(lì)，這樣你就可以創(chuàng)建兩個(gè)對(duì)列，一個(gè)用來(lái)處理用戶信息的請(qǐng)求，另一個(gè)對(duì)列獲取這條消息是來(lái)完成積分獎(jiǎng)勵(lì)的任務(wù)。

2.代碼示例

1）.Queue配置類

FanoutRabbitConfig.java類：

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;
@Configuration
public class FanoutRabbitConfig {
  //創(chuàng)建隊(duì)列
  @Bean
  public Queue AMessage() {
    return new Queue("fanout.A");
  }
  //創(chuàng)建隊(duì)列
  @Bean
  public Queue BMessage() {
    return new Queue("fanout.B");
  }
  //創(chuàng)建隊(duì)列
  @Bean
  public Queue CMessage() {
    return new Queue("fanout.C");
  }
  //創(chuàng)建Fanout交換器
  @Bean
  FanoutExchange fanoutExchange() {
    return new FanoutExchange("fanoutExchange");
  }
  //將對(duì)列綁定到Fanout交換器
  @Bean
  Binding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(AMessage).to(fanoutExchange);
  }
  //將對(duì)列綁定到Fanout交換器
  @Bean
  Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(BMessage).to(fanoutExchange);
  }
  //將對(duì)列綁定到Fanout交換器
  @Bean
  Binding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(CMessage).to(fanoutExchange);
  }  
}

2）.消息生產(chǎn)者

FanoutSender.java類:

package com.example.rabbitmqfanout.rabbitmq;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public 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）.消息消費(fèi)者

FanoutReceiverA.java類：

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類：

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類：

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）.測(cè)試

FanoutTest.java類：

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)
@SpringBootTest
public class FanoutTest {
  @Autowired
  private FanoutSender sender;
  @Test
  public void fanoutSender() throws Exception {
    sender.send();
  }
}

以上所述是小編給大家介紹的spring boot整合RabbitMQ（Fanout模式），希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: