Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=

那利
2023-12-01

rabbitTemplate.convertAndSend()这个方法的传参传错了,你检查一下就能解决问题了

举个例子把:

我这里使用的使用的是路由模式

第一个参数:你使用的交换机的名称,MQConstants.HOTEL_EXCHANGE
第二个参数:路由key值,MQConstants.HOTEL_INSERT_KEY,
第三个参数:你发送的内容, hotel.getId()
rabbitTemplate.convertAndSend(MQConstants.HOTEL_EXCHANGE, MQConstants.HOTEL_INSERT_KEY, hotel.getId());

工具类:MQConstants的参数

public class MQConstants {
    /**
     * 交换机
     */
    public final static String HOTEL_EXCHANGE = "hotel.direct";
    /**
     * 监听新增和修改的队列
     */
    public final static String HOTEL_INSERT_QUEUE = "hotel.insert.queue";
    /**
     * 监听删除的队列
     */
    public final static String HOTEL_DELETE_QUEUE = "hotel.delete.queue";
    /**
     * 新增或修改的RoutingKey
     */
    public final static String HOTEL_INSERT_KEY = "hotel.insert";
    /**
     * 删除的RoutingKey
     */
    public final static String HOTEL_DELETE_KEY = "hotel.delete";
}

 类似资料: