我需要在配置文件中添加任何其他内容吗？

Question

这是我的配置类。

@Configuration
public class MessageConfig {

public static final String KEY = "anil_key";
public static final String EXCHANGE = "anil_exchange_one";
public static final String QUEUE = "anil_queue";

@Bean
public Queue queue() {

    return new Queue(QUEUE, false);
}

@Bean
public DirectExchange exchange() {
    return new DirectExchange(EXCHANGE);
}

@Bean
public Binding binding(Queue queue, DirectExchange exchange) {

    return BindingBuilder.bind(queue).to(exchange).with(KEY);

}

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

@Bean
public AmqpTemplate template(ConnectionFactory connectionFactory) {
    final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    rabbitTemplate.setMessageConverter(converter());
    return rabbitTemplate;
}

这是我的发布者类

@RestController
@RequestMapping("/order")
public class Publisher {
@Autowired
private AmqpTemplate rabbitTemplate;

@PostMapping("/{restaurentName}")
public String bookOrder(@RequestBody Order order,@PathVariable String restaurentName) {
    
order.setOrderId(UUID.randomUUID().toString());

OrderStatus status = new OrderStatus(order,"progress","successfully received");

rabbitTemplate.convertAndSend(MessageConfig.EXCHANGE, MessageConfig.KEY, status);

return "success";
    
}

我遇到了错误。

2020-10-04 14:28:24.628 错误 17008 --- [127.0.0.1:5672] o.s.a.r.c.CachingConnectionFactory：通道关闭：通道错误；协议方法：#method(reply-code=404, reply-text=NOT_FOUND - 在 vhost '/' 中没有交换 'anil_exchange_one', class-id=60, method-id=40)。

Answer 1

您需要 RabbitAdmin @Bean 来声明交换/队列/绑定。

@Bean
RabbitAdmin admmin(ConnectionFactory cf) {
    return new Rabbitadmin(cf);
}