springboot整合activemq接收消息

痛定思痛。 2023-06-24 08:16 2阅读 0赞

1、在pom.xml中添加依赖包

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-activemq</artifactId>
            </dependency>

2、创建全局配置文件（application.properties）

spring.activemq.broker-url=tcp://localhost:61616
    spring.activemq.user=admin
    spring.activemq.password=admin
    spring.activemq.in-memory=true
    spring.activemq.pool.enabled=false

3、创建测试类（MsgHandler.java）

package com.jeff.receive;
    
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class MsgHandler { 
    
        // 使用JmsListener配置消费者监听的队列，其中text是接收到的消息
        @JmsListener(destination = "jeff_queue")
        public void receiveQueue(String text) { 
            System.out.println("####消息服务收到的报文为:" + text);
        }
    
    }

4、启动springboot项目，即可监听MQ的消息  
![在这里插入图片描述][20191221204213636.png]  
5、查看MQ的消息队列，消息已消费  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTczOTcyMA_size_16_color_FFFFFF_t_70]

[20191221204213636.png]: https://img-blog.csdnimg.cn/20191221204213636.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTczOTcyMA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191221205343421.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTczOTcyMA==,size_16,color_FFFFFF,t_70