上一期我們講了SpringBoot集成activeMQ實現Queue模式點對點通信，這一期我們接著講SpringBoot集成activeMQ實現Topic發布/訂閱模式通信。

發布/訂閱模式通信是對點對點通信模式的擴展。Queue模式下一個人發送的消息只能由一個人接收，而Topic模式下，A發送的消息，可以被所有監聽A的對象的接收，即：

①：一個消息可以被多個服務接收

②：訂閱一個主題的消費者，只能消費自它訂閱之后發布的消息。

③：消費端如果在生產端發送消息之后啟動，是接收不到消息的，除非生產端對消息進行了持久化(例如廣播，只有當時聽到的人能聽到信息)

下面我們來看看代碼中的實現：

①：pom.xml和Queue模式下的配置相同

②：application.yml的配置

較Queue模式下多配置了一個topic: wucy-topic

spring:

activemq:

broker-url: tcp://127.0.0.1:61616

user: admin

password: admin

queue: wucy-queue

topic: wucy-topic

server:

port: 8080

③：關于queue的配置ActivemqConfig.java

因為activeMQ默認不接受Topic消息，所以需要配置topicListenerContainer來開啟

@Configuration

public class ActivemqConfig {

@Value("${queue}")

private String queue;

@Value("${topic}")

private String topic;

@Bean

public Queue wucyQueue() {

return new ActiveMQQueue(queue);

}

@Bean

public Topic wucyTopic() {

return new ActiveMQTopic(topic);

}

/**

* JmsListener注解默認只接收queue消息,如果要接收topic消息,需要設置containerFactory

*/

@Bean

public JmsListenerContainerFactory> topicListenerContainer(ConnectionFactory activeMQConnectionFactory) {

DefaultJmsListenerContainerFactory topicListenerContainer = new DefaultJmsListenerContainerFactory();

topicListenerContainer.setPubSubDomain(true);

topicListenerContainer.setConnectionFactory(activeMQConnectionFactory);

return topicListenerContainer;

}

}

④：創建生產者

@RequestMapping("/registerTopic")

public String registerTopic(String name) {

long startTime = System.currentTimeMillis();

// 數據庫的操作

try {

Thread.sleep(50);

// 為了提高用戶體驗

// 發短信，去調用別人的API

// mqServer.send("發送短信*******");

// Thread.sleep(1000);

// 發郵件，qq發郵件的smtp

JSONObject json = new JSONObject();

json.put("type

總結

以上是生活随笔為你收集整理的activemq 开启监听_SpringBoot集成ActiveMQ怎么实现Topic发布/订阅模式通信？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。