@RabbitListener自动绑定交换机队列报错，配置值丢失排查

核心原因 #

你的类实现了DomainEventHandler<EnterpriseCertificateApplyEvent>（该接口继承自Spring的ApplicationListener），Spring容器会优先将这个类识别为Spring事件监听器，而非RabbitMQ消息监听器。这会导致@RabbitListener中的@QueueBinding配置被完全忽略，转而自动以事件类EnterpriseCertificateApplyEvent的名称生成队列相关配置，同时交换机名称因未被正确读取而留空，最终抛出Exchange name required异常。

解决方案 #

方案1：拆分职责，分离Spring事件与RabbitMQ消息处理 #

将Spring事件监听器和RabbitMQ消息监听器拆分为两个独立的类，各自承担单一职责：

• 一个类专门实现DomainEventHandler处理Spring事件
• 另一个类单独使用@RabbitListener处理RabbitMQ消息

示例拆分后的RabbitMQ监听器类：

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import tp.application.SuperviseService;

import javax.annotation.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Component
@RabbitListener(bindings = @QueueBinding(
        exchange = @Exchange(name = "trace_exchange"),
        value = @Queue(value = "trace_queue")
))
public class CertificateApplyRabbitMQListener {

    private static final Logger LOGGER = LoggerFactory.getLogger(CertificateApplyRabbitMQListener.class);

    @Resource
    SuperviseService superviseService;

    @RabbitHandler
    public void handleCertificateApplyEvent(EnterpriseCertificateApplyEvent event) {
        superviseService.onCertificateApply(event);
    }
}

方案2：移除Spring事件监听器接口实现 #

如果该类仅需处理RabbitMQ消息，不需要作为Spring事件监听器，直接删除implements DomainEventHandler<EnterpriseCertificateApplyEvent>，并调整方法签名：

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import tp.application.SuperviseService;

import javax.annotation.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author jh
 * @date 2023/2/16 23:04
 */
@Component
@RabbitListener(bindings = @QueueBinding(
        exchange = @Exchange(name = "trace_exchange"),
        value = @Queue(value = "trace_queue")
))
public class CertificateApplyEventHandler {

    private static final Logger LOGGER = LoggerFactory.getLogger(CertificateApplyEventHandler.class);

    @Resource
    SuperviseService superviseService;

    @RabbitHandler
    public void handleCertificateApplyEvent(EnterpriseCertificateApplyEvent event) {
        superviseService.onCertificateApply(event);
    }
}

额外简化配置建议 #

如果仅处理单一类型的RabbitMQ消息，可直接将@RabbitListener标注在方法上，省略@RabbitHandler：

@Component
public class CertificateApplyEventHandler {

    private static final Logger LOGGER = LoggerFactory.getLogger(CertificateApplyEventHandler.class);

    @Resource
    SuperviseService superviseService;

    @RabbitListener(bindings = @QueueBinding(
            exchange = @Exchange(name = "trace_exchange"),
            value = @Queue(value = "trace_queue")
    ))
    public void handleCertificateApplyEvent(EnterpriseCertificateApplyEvent event) {
        superviseService.onCertificateApply(event);
    }
}

内容的提问来源于stack exchange，提问作者D-Mer