上一期我們講了SpringBoot集成activeMQ實(shí)現(xiàn)Queue模式點(diǎn)對(duì)點(diǎn)通信，這一期我們接著講SpringBoot集成activeMQ實(shí)現(xiàn)Topic發(fā)布/訂閱模式通信。

發(fā)布/訂閱模式通信是對(duì)點(diǎn)對(duì)點(diǎn)通信模式的擴(kuò)展。Queue模式下一個(gè)人發(fā)送的消息只能由一個(gè)人接收，而Topic模式下，A發(fā)送的消息，可以被所有監(jiān)聽(tīng)A的對(duì)象的接收，即：

①：一個(gè)消息可以被多個(gè)服務(wù)接收

②：訂閱一個(gè)主題的消費(fèi)者，只能消費(fèi)自它訂閱之后發(fā)布的消息。

③：消費(fèi)端如果在生產(chǎn)端發(fā)送消息之后啟動(dòng)，是接收不到消息的，除非生產(chǎn)端對(duì)消息進(jìn)行了持久化(例如廣播，只有當(dāng)時(shí)聽(tīng)到的人能聽(tīng)到信息)

下面我們來(lái)看看代碼中的實(shí)現(xiàn)：

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

②：application.yml的配置

較Queue模式下多配置了一個(gè)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

③：關(guān)于queue的配置ActivemqConfig.java

因?yàn)閍ctiveMQ默認(rèn)不接受Topic消息，所以需要配置topicListenerContainer來(lái)開(kāi)啟

@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注解默認(rèn)只接收queue消息,如果要接收topic消息,需要設(shè)置containerFactory

*/

@Bean

public JmsListenerContainerFactory> topicListenerContainer(ConnectionFactory activeMQConnectionFactory) {

DefaultJmsListenerContainerFactory topicListenerContainer = new DefaultJmsListenerContainerFactory();

topicListenerContainer.setPubSubDomain(true);

topicListenerContainer.setConnectionFactory(activeMQConnectionFactory);

return topicListenerContainer;

}

}

④：創(chuàng)建生產(chǎn)者

@RequestMapping("/registerTopic")

public String registerTopic(String name) {

long startTime = System.currentTimeMillis();

// 數(shù)據(jù)庫(kù)的操作

try {

Thread.sleep(50);

// 為了提高用戶體驗(yàn)

// 發(fā)短信，去調(diào)用別人的API

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

// Thread.sleep(1000);

// 發(fā)郵件，qq發(fā)郵件的smtp

JSONObject json = new JSONObject();

json.put("type

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。