rabbit MQ生产环境通过管理界面创建交换机踩坑记录

发布时间:2024年01月24日

问题复现

1:通过管理界面创建一个交换机(这里举例设置其durable=true)

在这里插入图片描述

2:代码配置如上图,将durable属性故意设置成与管理端不一致(此处代码中设置为false)

3:启动代码,此时代码报错如下。该结果符合预期

在这里插入图片描述
此处由于代码和管理页面设置的交换机参数不一致导致errorcode=406

4:保持代码依然为运行状态,通过管理端删除创建的错误参数交换机;删除之后代码依然报错(代码运行之后请保持一致运行)

在这里插入图片描述

生产问题描述

第一次发布时在管理端创建了错误参数的交换机,后续代码报错code=406,发现错误日志后通过管理端删除了错误的交换机并创建了正确的交换机。但是代码依然报错406。由于生产环境不便于重启,一直使用的是错误的channel实例即使创建了正确的交换机代码运行依然报错!

问题排查

原来日志已经一直在明确的告诉我了channel is already closed due to channel error,我却一直忽略了,以为虽然本次执行报错channel关闭但是他每次执行exchangeDeclare()方法时都会重新恢复channel;但是试验表名并非如此。。
我们创建的channel对象会继承ShutdownNotifierComponent类,该类中有一个ShutdownSignalException shutdownCause属性,一旦该属性有值后后续所有的exchangeDeclare操作都会报错且打印已有的shutdownCause,并不会去与mq交互;截图如下:
在这里插入图片描述
感觉该问题有点反直觉,记录一下 ~~~
GIthub关联的Discussions

测试代码如下:amqp-client版本为5.20.0


import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import lombok.extern.slf4j.Slf4j;


@Slf4j
public class MQTest {

    public static void main(String[] args) {
        try {
            ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setHost("192.168.1.1");
            connectionFactory.setPort(5672);
            connectionFactory.setUsername("admin");
            connectionFactory.setPassword("admin");
            Channel channel = connectionFactory.newConnection().createChannel();
            while (true) {
                log.info("create exchange");
                try {
                    channel.exchangeDeclare("ysl.test.direct", BuiltinExchangeType.DIRECT,
                            false, false, null);
                }catch (Exception e){
                    log.error("create exchange error",e);
                }
                Thread.sleep(5000);
            }
        }catch (Exception e){
            log.error("error",e);
        }
    }
}
文章来源:https://blog.csdn.net/weixin_44144211/article/details/135825953
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。