为什么我在尝试访问 RabbitMQ 中的 URL 时会出现 Channel 错误？答案

【问题标题】：Why I am getting Channel error when I am trying to hit the URL in RabbitMQ?为什么我在尝试访问 RabbitMQ 中的 URL 时会出现 Channel 错误？
【发布时间】：2021-03-05 17:35:25
【问题描述】：

我是 RabbitMQ 的新手，我正面临通道错误。我的程序非常简单明了：

配置文件：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
javainuse.rabbitmq.exchange=javainuse.exchange
javainuse.rabbitmq.queue=javainuse.queue
javainuse.rabbitmq.routingkey=javainuse.routingkey
server.port=8081

下级是RabbitMQConfig.java。此类包含以下 bean：Queue、DirectExchange、Binding 和 MessageConverter。

@Configuration
public class RabbitMQConfig {
    
    @Bean("myTemplate")
    public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        return rabbitTemplate; 
    }
}

下级是RabbitMQSender.java。它调用myTemplate 将消息发送到队列。

@Service
public class RabbitMQSender {
        
    public void send(Person person) {
        rabbitTemplate.convertAndSend(exchange, routingkey, person);
        System.out.println("Send msg = " + person);
    }
}

下面是控制器，即RabbitController.java。这是我项目中唯一的控制器。

public class RabbitController {
        
    @GetMapping(value = "/producer")
    public String producer(@RequestParam("empName") String empName, @RequestParam("empId") String empId) {
        
        person.setName(empName);
        person.setId(empId);
        rabbitMQSender.send(person);
        
        return "Message sent to the RabbitMQ JavaInUse Successfully";
    }
}

我有一个 Pojo，即只有两个变量 id 和 name 的 Person。但是，当我尝试点击以下 URL 时，会创建队列：

http://localhost:8081/javainuse-rabbitmq/producer?empName=Ria&empId=emp003

我认为这是一个愚蠢的错误。请帮我解决这个问题。

【问题讨论】：

标签： java spring-boot rabbitmq

【解决方案1】：

我相信你已经像这样定义了你的 Exchange bean：

@Bean
public DirectExchange exchange(@Value("{javainuse.rabbitmq.exchange}") String exchangeName) {
    // ...
}

您错过了@Value 中的 $ 登录。尝试像这样定义 bean：

@Bean
public DirectExchange exchange(@Value("${javainuse.rabbitmq.exchange}") String exchangeName) {
    // ...
}

【讨论】：