spring boot集成Active MQ 报错Consider revisiting the entries above or defining a bean of type

淩亂°似流年 2022-12-04 14:57 60阅读 0赞

如何在Windows环境安装和启动Active MQ请看上一篇博文：

[https://blog.csdn.net/h\_j\_c\_123/article/details/108454607][https_blog.csdn.net_h_j_c_123_article_details_108454607]

首先我们使用idea新建一个spring boot工程，不会新建工程的请看该篇博文：

[https://blog.csdn.net/h\_j\_c\_123/article/details/93477170][https_blog.csdn.net_h_j_c_123_article_details_93477170]

然后我们开始说明如何继承：

首先添加依赖：

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

<dependency>
       <groupId>org.messaginghub</groupId>
       <artifactId>pooled-jms</artifactId>
    </dependency>

有的博客还会说连接池使用下面这个依赖：

但是经过尝试这个依赖会报错：

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*  
APPLICATION FAILED TO START  
\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

Description:

Field jmsMessagingTemplate in com.dream.controller.ProviderController required a bean of type 'org.springframework.jms.core.JmsMessagingTemplate' that could not be found.

The injection point has the following annotations:  
    - @org.springframework.beans.factory.annotation.Autowired(required=true)

The following candidates were found but could not be injected:  
    - Bean method 'jmsMessagingTemplate' in 'JmsAutoConfiguration.MessagingTemplateConfiguration' not loaded because Ancestor org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration did not match

Action:

Consider revisiting the entries above or defining a bean of type 'org.springframework.jms.core.JmsMessagingTemplate' in your configuration.

报这个错的原因说是JmsMessagingTemplate无法注入，后来百度百科了一下说是spring boot版本的问题。

然后我们先在启动类上加上@EnableJms允许启动MQ

@SpringBootApplication
    // 允许启动ActiveMQ
    @EnableJms
    public class BootMqApplication {
    
       public static void main(String[] args) {
          SpringApplication.run(BootMqApplication.class, args);
       }
    
    }

然后就可以创建生产者：

点对点的生产者消息队列：

首先配置文件（点对点和发布订阅模式写在一起了）：

server.port=8088
    #61616是程序连接activemq的通讯地址
    spring.activemq.broker-url=tcp://127.0.0.1:61616
    spring.activemq.user=admin
    spring.activemq.password=admin
    spring.activemq.pool.enabled=true
    spring.activemq.pool.max-connections=10
    spring.activemq.pool.idle-timeout=30000
    spring.activemq.in-memory=false
    #如果是点对点（queue），那么此处默认应该是false，如果发布订阅，那么一定设置为true
    spring.jms.pub-sub-domain=true

配置消息队列：

@Configuration
    public class BeanConfig {
        //    定义存放消息的队列 点对点模式
        @Bean
        public Queue queue() {
            return new ActiveMQQueue("active.queue");
        }
    }

新建生产者：ProviderController

注入消息队列：

//    注入存放消息的队列
    @Autowired
    private Queue queue;

//    注入spring boot封装的工具
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

// 发送消息队列   
     @RequestMapping(value = "/sendQueue")
        public void sendQueue(String name) {
    //        方法一：添加消息到消息队列
            jmsMessagingTemplate.convertAndSend(queue, name);
    //        方法二：这种方式不需要手动创建queue，系统会自行创建名为test的队列
    //        jmsMessagingTemplate.convertAndSend("test", name);
        }

然后我们来看消费者：

@Component
    public class ConsumerService {
        @Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
    
        // 使用JmsListener配置消费者监听的队列，其中name是接收到的消息
        @JmsListener(destination = "active.queue")
        // SendTo 会将此方法返回的数据, 写入到 OutQueue 中去.
        @SendTo(value = "SQueue")
        public String handleMessage(String name) {
            System.out.println("成功接受Name" + name);
            return "成功接受Name" + name;
        }
    }

至此，我们的一个基础的消息队列完成，然后我们来看一下点对点的消息模式效果：

发送数据：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70][]

结果截图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 1][]

点对点的时候记得把

#spring.jms.pub-sub-domain=true注释掉或者改成false

下面来看发布和订阅模式：

配置消息队列-订阅模式：

@Configuration
    public class BeanConfig {
        // 发布订阅模式
        @Bean
        public Topic topic() {
            return new ActiveMQTopic("active.topic");
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 2][]

//    订阅发布模式
        @RequestMapping(value = "/sendTopic")
        public String sendTopic(String message) {
    //        指定消息发送的目的地和内容
            jmsMessagingTemplate.convertAndSend(topic, message);
            return "消息发送成功！message=" + message;
        }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 3][]

新建消费者：

//    监听和接收主题消息1
        @JmsListener(destination = "active.topic")
        public void readActiveTopic1(String message) {
            System.out.println("Customer1接受到：" + message);
        }
    
    
        //    监听和接收主题消息2
        @JmsListener(destination = "active.topic")
        public void readActiveTopic2(String message) {
            System.out.println("Customer2接受到：" + message);
        }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 4][]

下面来验证数据：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 6][]

这样一个简单的spring boot和Active MQ的集成就完成了。

码云地址：[https://gitee.com/hjc2/springboot.git][https_gitee.com_hjc2_springboot.git]

[https_blog.csdn.net_h_j_c_123_article_details_108454607]: https://blog.csdn.net/h_j_c_123/article/details/108454607
[https_blog.csdn.net_h_j_c_123_article_details_93477170]: https://blog.csdn.net/h_j_c_123/article/details/93477170
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70]: /images/20221123/e8d1f7bdf77b4576ac743ae91529025a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 1]: /images/20221123/c46a03308f9f4cceb77144722352661d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 2]: /images/20221123/a580be45a2d9438382c696c25d45846d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 3]: /images/20221123/94a0e5bc706d427088d23e91bb5163e9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 4]: /images/20221123/a82ce33eef7b4b1e9a4b07b292c819d2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 5]: /images/20221123/e5ff8fbd5a024929964f131e79bb13e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hfal9jXzEyMw_size_16_color_FFFFFF_t_70 6]: /images/20221123/538deebab56847bc920caa7e2b81fc15.png
[https_gitee.com_hjc2_springboot.git]: https://gitee.com/hjc2/springboot.git