2. 程式人生 > >springboot整合mq同時監聽queue和topic

springboot整合mq同時監聽queue和topic

阿新 • • 發佈：2018-11-10

前言：springboot和mq整合的時候，預設情況下，要麼只能監聽queue要麼只能監聽topic，而不能二者兼得。

在application.properties檔案中通過如下配置項，切換監聽訊息的型別。

1

2

#為true時是topic模式，為false是queue模式

spring.jms.pub-sub-domain=true

如果想同時監聽queue和topic怎麼辦？實現步驟如下：

 

1:取消mq的預設配置,選擇自定義配置

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

//MQ configuration class

@Configuration

public class MqConfig {

  @Bean

  public Queue queue(){

      return new ActiveMQQueue(

"mvp.queue");

  }

  @Bean

  public Topic topic(){

      return new ActiveMQTopic("mvp.topic");

  }

  @Bean

  public ActiveMQConnectionFactory connectionFactory() {

      

return new ActiveMQConnectionFactory("zhu", "zhu.123", "tcp://192.168.25.134:61616");

  }

  //這個bean的id是jmsListenerContainerTopic

  @Bean

  public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ActiveMQConnectionFactory connectionFactory) {

      DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();

      bean.setPubSubDomain(true);

      bean.setConnectionFactory(connectionFactory);

      return bean;

  }

  //這個bean的id是jmsListenerContainerQueue

  @Bean

  public JmsListenerContainerFactory<?> jmsListenerContainerQueue(ActiveMQConnectionFactory connectionFactory) {

      DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();

      bean.setConnectionFactory(connectionFactory);

      return bean;

  }

  @Bean

  public JmsMessagingTemplate jmsMessagingTemplate(ActiveMQConnectionFactory connectionFactory){

      return new JmsMessagingTemplate(connectionFactory);

  }

}

2:傳送點對點訊息

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

@RestController

public class QueueController {

 

    @Autowired

    private Queue queue;

 

    @Autowired

    private JmsMessagingTemplate jmsMessagingTemplate;

 

    @RequestMapping("/send")

    public void send() {

        jmsMessagingTemplate.convertAndSend(queue, "一殺");

    }

 

}

3:監聽點對點訊息

1

2

3

4

5

6

7

8

9

@Component

public class QueueConsumer {

 

    @JmsListener(destination="mvp.queue",containerFactory="jmsListenerContainerQueue") 

   public void readMessage(String text){ 

      System.out.println("接收到訊息："+text); 

   }  

 

}

4:傳送topic訊息

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

@RestController

public class TopicController {

 

    @Autowired

    private Topic topic;

 

    @Autowired

    private JmsMessagingTemplate jmsMessagingTemplate;

 

    @RequestMapping("/send1")

    public void send() {

        jmsMessagingTemplate.convertAndSend(topic, "topic-message");

    }

 

}

 

5:監聽topic訊息

1

2

3

4

5

6

7

8

9

@Component

public class TopicConsumer {

 

    @JmsListener(destination="mvp.topic",containerFactory="jmsListenerContainerTopic") 

   public void readMessage(String text){ 

      System.out.println("接收到訊息："+text); 

   }  

 

}

到此:就可以實現在一個springboot工程中既能監聽topic也可以監聽queue。

完整demo程式碼：https://pan.baidu.com/s/15pE2fuuYyi5v2FpiiON4OQ

 

 

相關推薦

springboot整合mq同時監聽queue和topic

前言：springboot和mq整合的時候，預設情況下，要麼只能監聽queue要麼只能監聽topic，而不能二者兼得。 在application.properties檔案中通過如下配置項，切換監聽訊息的型別。 1 2 #為true時是topic模式，為

Android 監聽簡訊(同時監聽廣播和資料庫)

暗釦，強烈譴責這種侵害使用者利益的行為。。。 下面給大家介紹Android暗釦原理.......  Android4.4以下的系統玩遊戲就要小心了哈 暗釦方式之一：簡訊訂購，即監聽--------攔截------------處理簡訊。 暗釦方式之二：模擬人為操作（又叫模擬流

springboot---監聽ApplicationListener和ApplicationEvent簡單使用

監聽ApplicationListener和ApplicationEvent簡單使用 本來想實現一個功能就是，在登入成功之後，將一些使用者的資訊，放入到session裡面，本來想，在登入介面成功回撥之後，在寫，但是想做一個監聽的動作，監聽著登入成功的介面，之後走到監聽函式裡面，進行業務處理。

Nginx同時監聽IPV6+IPV4，實現正向和反向

nginx.conf 配置如下 user root; worker_processes 8; #error_log /opt/server/department/nginx/logs/error.log warn; error_log /opt/server/department

如果有2個ApacheMQ的客戶端同時監聽一個Queue會怎麼樣

我們知道Topic，是傳送一個訊息，多個監聽的客戶端都可以消費到訊息內容。而傳送一個訊息到Queue，只能一個監聽的客戶端可以消費。那麼，如果我有2個客戶端都去監聽同一個Queue，可以嗎？結果會怎麼樣？實際測試結果是逐一交叉監聽消費了訊息。這樣的情況，可以利用微服務➕MQ簡

伺服器端預先建立子程序(work)同時監聽服務埠和驚群現象

背景 原文連結： http://blog.csdn.net/ordeder/article/details/21721141 1.程序A在n埠上監聽，即呼叫listen(listenfd,backlog); 2.之後A呼叫fork產生子程序B，此時B拷貝了A的listenf

TCP和UDP可以同時監聽相同的端口嗎

nec 連接 pro water netstat 就是 prot 協議名稱 使用 同一臺機器的同一個端口只可以被一個進程使用，一般用於tcp，或者udp。那一個進程使用同一個端口同時監聽tcp、udp請求，是否可以呢？ 答案：可以。 端口可以形象地比喻成操作系統上的編號唯一

SpringBoot入門之事件監聽

int () AI stat boot.s over style 資源 nvi 　　spring boot在啟動過程中增加事件監聽機制，為用戶功能拓展提供極大的便利，sptingboot支持的事件類型有以下五種： ApplicationStartingEvent Appl

ASP.NET Core 發布之後通過命令控制監聽地址和環境變量

運行 mman oid build ted inf str comm staging 添加Command支持 新建一個ASP.NET Core 項目，打開Program.cs 添加下面的代碼: public class Program { public static

springboot熱部署以及監聽文件的設置筆記1

maven cti pid using tool artifact pen 生產環境 觸發 1.使用Dev-tool熱部署 　　網址：https://docs.spring.io/spring-boot/docs/2.1.0.BUILD-SNAPSHOT/reference

activemq安裝運行及其在springboot中的queue和topic使用

listen conn sendto pub package 密碼 topic red int 安裝activemq 運行 springboot使用 依賴 配置 Producer Consumer ComsumerTopic 使用 安裝activemq http:

netty同埠監聽tcp和websocket協議

前言： 　　軟體通訊七層結構（osi模型）中由協議套協議最終組成最高階應用層協議（http等等），下三層結構偏向與資料通訊，上三層更偏向於資料處理，中間的傳輸層則是連線上三層與下三層之間的橋樑，每一層都做不同的工作，上層協議依賴與下層協議。 　　七層結構的最主要功能就是幫助不同系統的主機在不同的網

服務監聽IP和埠，訪問127.0.0.1有效，訪問IP地址無效

記錄一下自己犯2的經歷、 使用nodejs搭建了個簡易的檔案伺服器，使用127.0.0.1(localhost)訪問沒問題，然後換成內網IP(192.168.xxx.xxx)就不好使了，網上各種找原因，神馬防火牆了、埠映射了（我的是mac os）、iptables、pfctl、localtunn

為什麽有監聽socket和連接socket,為什麽產生兩個socket

中產 能夠 新的 被占用 con 提高 tro 客戶端 分層 為什麽有監聽socket和連接socket,為什麽產生兩個socket 先看一半的socket建立連接的雙方的過程: 客戶端: socket()---->創建出 active_socket_fd (clie

為什麼有監聽socket和連線socket,為什麼產生兩個socket

為什麼有監聽socket和連線socket,為什麼產生兩個socket 先看一半的socket建立連線的雙方的過程: 客戶端: socket()---->創建出 active_socket_fd (client_socket_fd) bind()--->把active_socket_fd與

vue watch怎樣同時監聽兩個值的變化並執行方法？

用computed定義一個address物件吧，然後再去watch addres data() { return { city: '', country: '' } }, computed: { address() { const { city, countr

Erlang TCP Socket監聽程序和接收程序

Erlang TCP Socket監聽程序和接收程序的說明 轉自：https://blog.csdn.net/summerhust/article/details/8740973 一旦打開了一個使用ＴＣＰ連線的套接字，它就始終保持開啟狀態，直至任何一方關閉它或因為一個錯誤而終止。在建立一

C#實現Socket通訊(同時監聽多客戶端)

//建立socket物件 //第一個引數：設定網路定址的協議、第二引數設定資料傳輸的方式、第三個引數設定通訊協議 Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketT

SpringBoot整合RabbitMQ，實現訊息傳送和消費

下載安裝Erlang和RabbitMQ Erlang和RabbitMQ：https://www.cnblogs.com/theRhyme/p/10069611.html   專案建立和依賴 推薦SpringCloud專案線上建立：https://start.spring.io/ 不用上面這

單執行緒實現同時監聽多個埠（windows平臺c++程式碼）

前言 　　多年前開發了一套網路庫，底層實現採用IOCP（完成埠）。該庫已在公司多個程式中應用；經過多次修改，長時間檢驗，已經非常穩定高效。 最近把以前的程式碼梳理了一下，又加進了一些新的思路。程式碼結構更加合理，效能也有所提升。打算將該庫一些的知識點寫出來，以供參考。 服務端要在多個埠監聽，這種場合並不多見。