关于SpringBoot整合RabbitMQ启动的时候报错：Failed to check/redeclare auto-delete queue(s).

「爱情、让人受尽委屈。」 2024-03-16 19:43 55阅读 0赞

## 问题 ##

在SpringBoot项目中使用RabbitMQ报错，之前启动过一次但是MQ重装以后，再启动就报错了

## 思路 ##

*  XML依赖有没有错

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

*  yaml文件配置错误

logging:
      pattern:
        dateformat: MM-dd HH:mm:ss:SSS
    spring:
      rabbitmq:
        host: # rabbitMQ的ip地址
        port: # rabbitMQ的端口
        username: # rabbitMQ的用户名
        password: # rabbitMQ的密码
        virtual-host: /
        listener:
          simple:
            prefetch: 1 # 批量发送的情况下，也是取一个执行一个

*  SpringBoot中的配置文件配置不对

package cn.itcast.mq.helloworld;
    
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class ConsumerTest {
        
    
        public static void main(String[] args) throws IOException, TimeoutException {
        
            // 1.建立连接
            ConnectionFactory factory = new ConnectionFactory();
            // 1.1.设置连接参数，分别是：主机名、端口号、vhost、用户名、密码
            factory.setHost("192.168.75.133");
            factory.setPort(5672);
            factory.setVirtualHost("/");
            factory.setUsername("root");
            factory.setPassword("123456");
            // 1.2.建立连接
            Connection connection = factory.newConnection();
    
            // 2.创建通道Channel
            Channel channel = connection.createChannel();
    
            // 3.创建队列
            String queueName = "simple.queue";
            channel.queueDeclare(queueName, false, false, false, null);
    
            // 4.订阅消息，第一次执行只是先建立连接，并不会接收到消息，建立连接以后才会接收到消息，回调的操作，说明了异步
            channel.basicConsume(queueName, true, new DefaultConsumer(channel){
        
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope,
                                           AMQP.BasicProperties properties, byte[] body) throws IOException {
        
                    // 5.处理消息
                    String message = new String(body);
                    System.out.println("接收到消息：【" + message + "】");
                }
            });
            System.out.println("等待接收消息。。。。");
        }
    }

## 解决细节 ##

### xml依赖 ###

*  如果是依赖配置错误，直接换我这个就可以了

### yaml配置文件 ###

*  IP

如果RabbitMQ是部署其他服务器的，不是本地计算机，那么就访问RabbitMQ的网页，然后使用命令行ping一下RabbitMQ对应的IP

如果ping不通，那么就检查一下RabbitMQ所在的服务器是不是防火墙的对应端口没有放通

*  端口

**我们使用WEB页面访问RabbitMQ的时候使用的端口一般是15672，但是我们在YAML配置文件和SpringBoot的配置中应该写`5672`**

*  用户信息

用户的级别应当是当前项目的需求级别  
MQ分为很多个级别  
![在这里插入图片描述][64150f0ee7984429b8d9164202abd766.png]  
但是在现实的时候  
![在这里插入图片描述][7388602b06054e979bc6e405777c6f20.png]  
会出现两个管理，会导致我们选错  
我们应当选择**management**而不是**administrator**，因为后者只提供简单的登录功能

[64150f0ee7984429b8d9164202abd766.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/bb04a6da7ce24bfc933ed9e637df5a17.png
[7388602b06054e979bc6e405777c6f20.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/23d2f8c0a2a044c191bc260a4f0c569b.png