快捷導(dǎo)航

springboot?集成activemq項(xiàng)目配置方法

更新時(shí)間：2024年04月25日 11:38:19 作者：恰子李

這篇文章主要介紹了springboot?集成activemq項(xiàng)目配置方法,e-car項(xiàng)目配置通過引入activemq依賴,本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧

一：說明

1-在兩個(gè)不同的應(yīng)用發(fā)送和接收消息
2-消息發(fā)送應(yīng)用是 e-car 項(xiàng)目，接收端是 tcm-chatgpt項(xiàng)目，當(dāng)然，同一個(gè)項(xiàng)目也是可以發(fā)送和接收的

二：e-car項(xiàng)目配置

1 引入activemq依賴

<!-- 集成 ActiveMQ -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

2 application啟動(dòng)類配置消息監(jiān)聽

加上 @EnableJms 注解，開啟JMS

@EnableJms // 開啟JMS
@SpringBootApplication(scanBasePackages="com.nrbc.ecar")
@MapperScan("com.nrbc.ecar.dao.mapper")
public class EcarAppClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(EcarAppClientApplication.class, args);
    }
}

3 application.yml配置

1 注意：開啟主題策略，默認(rèn)是關(guān)閉開啟主題模式，要設(shè)置為true
如果要使用隊(duì)列模式，pub-sub-domain 要設(shè)置為false jms:
pub-sub-domain: false 同時(shí)使用jms的Queue(隊(duì)列)和Topic(發(fā)布訂閱)，可查看這邊文章：文章鏈接

spring:
  # activemq相關(guān)配置
  activemq:
    broker-url: tcp://localhost:61616
    user: liping
    password: liping
    packages:
      # 配置信任所有的包，這個(gè)配置為了支持發(fā)送對(duì)象消息(如果傳遞的是對(duì)象則需要設(shè)置為true，默認(rèn)是傳字符串)
      trust-all: true
  # 開啟主題策略，默認(rèn)是關(guān)閉 開啟主題模式
  jms:
    pub-sub-domain: true
# 配置activemq隊(duì)列的名稱和主題名稱
amq:
  qname:
    queueName-1:
      queueName-1
  topicName:
    name-1:
      topic-prot-1
    name-2:
      topic-prot-2

4 MQConfig.java 配置類

/**
 * 專門配置mq通道的配置類
 */
@Slf4j
@Configuration
public class MQConfig {
    @Value("${amq.topicName.name-1}")
    private String tpName;
    @Bean(name = "queueName")
    Queue queueName() {
        return new ActiveMQQueue("test_queue");
    }
    /**
     * 主題(發(fā)布\訂閱模式)通道
     * @author kazaf
     * @date 2024/4/24 16:43
     */
    @Bean(name = "topic1")
    Topic queueFind() {
        log.info("${amq.topicName.name-1}=" + tpName);
        return new ActiveMQTopic("topic-model");
    }
    @Bean(name = "topic2")
    Topic topic2() {
        return new ActiveMQTopic("topic-model2");
    }
    @Bean(name = "topic3")
    Topic topic3() {
        return new ActiveMQTopic(tpName);
    }
}

5 ecar 項(xiàng)目中的監(jiān)聽

/**
 * 專門配置mq通道的配置類
 */
@Slf4j
@Component
public class MQListener {
    /*@JmsListener(destination = "test_queue")
    public void jiant (String message) {
        System.out.println("監(jiān)聽到消息》：" + message);
        log.info("監(jiān)聽到消息---》：" + message);
    }*/
    @JmsListener(destination = "topic-model")
    public void reciveTopic(String message) {
        log.info("11接收主題消息》："+message);
    }
    @JmsListener(destination = "topic-model2")
    public void topicReceive2(String message) {
        log.info("topic-2監(jiān)聽到消息---》：" + message);
    }
    /**
     * 主題名稱從配置文件中動(dòng)態(tài)獲取 
     */
    @JmsListener(destination = "${amq.topicName.name-1}")
    public void topicReceive3(String message) {
        log.info("topic-3監(jiān)聽到消息---》：" + message);
    }
}

6 junit 發(fā)送消息

調(diào)用類需要注入消息模板，隊(duì)列名稱或者主題名稱
也可以編寫接口發(fā)送，demo隨個(gè)人習(xí)慣

@Slf4j
@SpringBootTest(classes = EcarAppClientApplication.class)
@RunWith(SpringRunner.class)
public class ActivemqTest {
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    @Autowired
    private Queue queueName;
    @Autowired
    private Topic topic1;
    @Autowired
    private Topic topic2;
    @Autowired
    private Topic topic3;
    @Test
    public void queueSender()  {
        String message="我是隊(duì)列發(fā)出的信息";
        jmsMessagingTemplate.convertAndSend(queueName, message);
        log.info("queueSender發(fā)送--》："+message);
//        TimeUnit.SECONDS.sleep(60);
    }
    /**
     * 發(fā)送 主題消息（廣播）
     * @author kazaf
     * @date 2024/4/24 17:09
     */
    @Test
    public void topicSender()  {
        String message="我是topic-1a";
        jmsMessagingTemplate.convertAndSend(topic1, message);
        log.info("topicSender發(fā)送--》："+message);
        String message2="我是topic2";
        jmsMessagingTemplate.convertAndSend(topic2, message2);
        log.info("topic2Sender發(fā)送--》："+message2);
        String message3="我是topic3發(fā)送的";
        jmsMessagingTemplate.convertAndSend(topic3, message3);
        log.info("topic3Sender發(fā)送--》："+message3);
    }
}

三：tcm-chatgpt項(xiàng)目配置

1、2、3、5 跟e-car項(xiàng)目一樣的配置 5 MQListener.java 監(jiān)聽消息

代碼

/**
 * @Description: mq監(jiān)聽類
 * @Author: kazaf
 * @Date: 2024-04-24 9:34
 */
@Slf4j
@Component
public class MQListener {
    @JmsListener(destination = "test_queue")
    public void onMessage(String message) {
        System.out.print(message);
        //獲取到消息后可以干一些事情
        log.info("恰恰監(jiān)聽到的消息》："+message);
    }
    @JmsListener(destination = "topic-model")
    public void reciveTopic(String message) {
        log.info("11接收主題消息》："+message);
    }
    @JmsListener(destination = "topic-model2")
    public void reciveTopic2(String message) {
        log.info("22接收主題消息》："+message);
    }
}

測試

啟動(dòng)activemq服務(wù)