Spring boot rabbitmq在vhost'/'中没有交换''xxxxxxx''

Question

我写一个简单的Rabbitmq生产者与Spring启动2.2.7。

在代理端，我设置了一个直接交换示例，一个名为samples的队列。默认值，并将它们绑定在一起添加示例。默认绑定键。

运行应用程序时，我得到以下错误

Attempting to connect to: [127.0.0.1:5672]
2020-05-14 15:13:39.232  INFO 28393 --- [nio-8080-exec-1] o.s.a.r.c.CachingConnectionFactory       : Created new connection: rabbitConnectionFactory#2f860823:0/SimpleConnection@3946e760 [delegate=amqp://open-si@127.0.0.1:5672/, localPort= 34710]
2020-05-14 15:13:39.267 ERROR 28393 --- [ 127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange '"samples"' in vhost '/', class-id=60, method-id=40)

rabbitmq服务器配置是正确的，因为我有一个python生产者已经成功地将消息放入“samples.default”队列。

在SpringBoot中，我使用了jackson序列化，但我认为这不是这里的问题，因为我在没有Jakson序列化配置的情况下测试了代码，问题仍然是一样的。

我的代理配置是在应用程序中设置的。特性：

#spring.rabbitmq.host=localhost
spring.rabbitmq.addresses=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=xxxx
spring.rabbitmq.password=xxxx

broker.exchange = "samples"
broker.routingKey = "samples.default"

请注意，使用Spring。兔子。主机不工作，因为它会导致使用我的internet提供商地址！

在BrokerConf配置类中：

@Configuration
public class BrokerConf {

    @Bean("publisher")
    MessagePublisher<BaseSample> baseSamplePublisher(RabbitTemplate rabbitTemplate) {
        return new MessagePublisher<BaseSample>(rabbitTemplate);
    }


    @Bean
    public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) {
        final var rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(producerJackson2MessageConverter());
        return rabbitTemplate;
    }

    @Bean
    public MessageConverter producerJackson2MessageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}

发布者基类为：

@Component
public class MessagePublisher<T> {

    private static final Logger log = LoggerFactory.getLogger(MessagePublisher.class);
    private final RabbitTemplate rabbitTemplate;

    public MessagePublisher(RabbitTemplate r) {
        rabbitTemplate = r;
    }

    public void publish(List<BaseSample> messages, String exchange, String routingKey) {
            for (BaseSample message: messages) {
                rabbitTemplate.convertAndSend(exchange, routingKey, message);
            }
    }

}

我用在Rest控制器上

private static final Logger logger = LoggerFactory.getLogger(SamplesController.class);
@Autowired
private MessagePublisher<BaseSample> publisher;

@Value("${broker.exchange}")
private String exchange;
@Value("${broker.routingKey}")
private String routingKey;


@PutMapping(value = "/new", produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<SampleAck> add(@RequestBody List<BaseSample> samples) {

    publisher.publish(samples, exchange, routingKey);

    return ResponseEntity.ok(new SampleAck(samples.size(), new Date()));

}

因此，代理连接正常，但找不到交换

并且rabbitmq资源存在

xxxxxx@xxxxxxx:~/factory/udc-collector$ sudo rabbitmqctl list_exchanges
Listing exchanges for vhost / ...
name    type
amq.topic   topic
amq.rabbitmq.trace  topic
amq.match   headers
amq.direct  direct
amq.fanout  fanout
    direct
amq.rabbitmq.log    topic
amq.headers headers
samples direct

xxxx@xxxxx:~/factory/udc-collector$ sudo rabbitmqctl list_queues
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
name    messages
samples.default 2

任何想法？

提前感谢。

Answer 1

错误似乎很明显：

vhost中不交换“样本”

broker.exchange = "samples"
broker.routingKey = "samples.default"

删除引号

broker.exchange=samples
broker.routingKey=samples.default