spring boot如何使用RabbitMQ實現topic主題

這篇文章將為大家詳細講解有關spring boot如何使用RabbitMQ實現topic主題，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

主題交換器

使用主題交換器時不能采用任意寫法的路由鍵，路由鍵的形式應該是由點分割的單詞。用什么詞都行，通常都是能表明意義的。例如"stock.usd.nyse", "nyse.vmw", "quick.orange.rabbit"。但字數大小被限制在最多255字節。

使用主題交換器定義路由鍵需要注意點2點

1. *星號代表一個單詞。

2. #井號代表0個或多個單詞。

定義符合主題交換器的路由鍵

在這個例子中，我們將發送所有描述動物的消息。這個消息將會和由3個單詞2個點構成的路由鍵一起發送。第一個單詞是表述速度，第二個描述顏色，第三個描述種類："<speed>.<colour>.<species>"。

創建三種綁定，Q1和鍵"*.orange.*"綁定，Q2和"*.*.rabbit" 、"lazy.#"綁定。

三種綁定關系的概述為：

1. Q1 對橙色的動物感興趣。（隊列1）

2. Q2 對所有關于兔子和所有關于慢速的動物感興趣。（隊列2）

一個和路由鍵被設置成"quick.orange.rabbit"的消息將會被傳遞到Q1、Q2這兩個隊列中。"lazy.orange.elephant" 也會這樣。"quick.orange.fox"會去第一個隊列，"lazy.brown.fox"會去第二個隊列，"lazy.pink.rabbit"會去第二個隊列及時它匹配了2次綁定。"quick.brown.fox"因為不匹配哪也去不了，會被丟棄。

那么像"orange" 、 "quick.orange.male.rabbit"這樣的呢？因為沒有匹配到任何綁定也會被丟棄。

那么像"lazy.orange.male.rabbit"也是四個詞的路由鍵呢？，由于匹配到了lazy.#這個將會被傳遞到第二個隊列中。

主題交換器的小技巧

主題交換器是牛逼的并且表現的與其它交換器相似。

1. 當一個隊列和 "#" 綁定鍵綁定時，該隊列能收到所有的消息，這點與扇形（fanout）交換器類似。

2. 當不使用 "*" and "#" 時，主題交換器就與直連交換器沒啥兩樣。

代碼示例

代碼與之前的路由代碼沒啥兩樣，請看

Config.java

package com.zb.rabbitMQtest.t5topics.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 張博
 */
@Configuration(value = "t5Config")
public class Config {

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:45
   * @apiNote 定義主題交換器
   */
  @Bean
  public TopicExchange topicExchange() {
    return new TopicExchange("topic-exchange");
  }

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:48
   * @apiNote 定義自動刪除匿名隊列
   */
  @Bean
  public Queue autoDeleteQueue0() {
    return new AnonymousQueue();
  }

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:48
   * @apiNote 定義自動刪除匿名隊列
   */
  @Bean
  public Queue autoDeleteQueue1() {
    return new AnonymousQueue();
  }

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:48
   * @param topicExchange 主題交換器
   * @param autoDeleteQueue0 自動刪除隊列
   * @apiNote 綁定使用路由鍵為 orange 的 autoDeleteQueue0 隊列到主題交換器上
   * @return Binding
   */
  @Bean
  public Binding binding0a(TopicExchange topicExchange, Queue autoDeleteQueue0) {
    return BindingBuilder.bind(autoDeleteQueue0).to(topicExchange).with("*.orange.*");
  }

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:48
   * @param topicExchange 主題交換器
   * @param autoDeleteQueue1 自動刪除隊列
   * @apiNote 綁定使用路由鍵為 black 的 autoDeleteQueue1 隊列到主題交換器上
   * @return Binding
   */
  @Bean
  public Binding binding1a(TopicExchange topicExchange, Queue autoDeleteQueue1) {
    return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("*.*.rabbit");
  }

  /**
   * 創建人：張博
   * 時間：2018/3/5 上午10:48
   * @param topicExchange 主題交換器
   * @param autoDeleteQueue1 自動刪除隊列
   * @apiNote 綁定使用路由鍵為 green 的 autoDeleteQueue1 隊列到主題交換器上
   * @return Binding
   */
  @Bean
  public Binding binding1b(TopicExchange topicExchange, Queue autoDeleteQueue1) {
    return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("lazy.#");
  }
}

Receiver.java

package com.zb.rabbitMQtest.t5topics.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author 張博
 */
@Component(value = "t5Receiver")
public class Receiver {

  @RabbitListener(queues = "#{autoDeleteQueue0.name}")
  public void receiver0(String str) {
    System.out.println("receiver0++++++++++:" + str);
    //try {
    //  Thread.sleep(1000);
    //} catch (InterruptedException e) {
    //  e.printStackTrace();
    //}
  }

  @RabbitListener(queues = "#{autoDeleteQueue1.name}")
  public void receiver1(String str) {
    System.out.println("receiver1++++++++++:" + str);
    //try {
    //  Thread.sleep(1000);
    //} catch (InterruptedException e) {
    //  e.printStackTrace();
    //}
  }
}

Send.java

package com.zb.rabbitMQtest.t5topics.send;

import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author 張博
 */
@Component(value = "t5Send")
public class Send {

  @Autowired
  private TopicExchange topicExchange;

  @Autowired
  private RabbitTemplate rabbitTemplate;

  private String[] keys = {"quick.orange.rabbit",
      "lazy.orange.elephant", "quick.orange.fox",
      "lazy.brown.fox", "lazy.pink.rabbit", "quick.brown.fox"};

  public void send() {
    String message = "哈哈哈";
    for (int i = 0; i < 5; i++) {
      System.out.println("send++++++++++:".concat(message));
      rabbitTemplate.convertAndSend(topicExchange.getName(), keys[5], message);
    }
  }
}

SendTest.java

package com.zb.rabbitMQtest.t5topics.send;

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;

/**
 * @author 張博
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class SendTest {

  @Autowired
  private Send send;
  @Test
  public void send() throws Exception {
    send.send();
  }
}

關于“spring boot如何使用RabbitMQ實現topic主題”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。