rabbitmq中routingkey的作用说明

@Component
public class RabbitOrderSender {
    //自动注入RabbitTemplate模板类
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Autowired
    private BrokerMessageLogMapper brokerMessageLogMapper;
    //回调函数: confirm确认
    final RabbitTemplate.ConfirmCallback confirmCallback = new RabbitTemplate.ConfirmCallback() {
        @Override
        public void confirm(CorrelationData correlationData, boolean ack, String cause) {
            System.err.println("correlationData: " + correlationData);
            String messageId = correlationData.getId();
            if(ack){
                //如果confirm返回成功 则进行更新
                brokerMessageLogMapper.changeBrokerMessageLogStatus(messageId, Constants.ORDER_SEND_SUCCESS, new Date());
            } else {
                //失败则进行具体的后续操作:重试 或者补偿等手段
                System.err.println("异常处理...");
            }
        }
    };
    //发送消息方法调用: 构建自定义对象消息
    public void sendOrder(Order order) throws Exception {
        // 通过实现 ConfirmCallback 接口，消息发送到 Broker 后触发回调，确认消息是否到达 Broker 服务器，也就是只确认是否正确到达 Exchange 中
        rabbitTemplate.setConfirmCallback(confirmCallback);
        //消息唯一ID
        CorrelationData correlationData = new CorrelationData(order.getMessageId());
        rabbitTemplate.convertAndSend("order-exchange", "order.ABC", order, correlationData);
    }
}

@Component
public class OrderReceiver {
    //配置监听的哪一个队列，同时在没有queue和exchange的情况下会去创建并建立绑定关系
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = "order-queue",durable = "true"),
            exchange = @Exchange(name="order-exchange",durable = "true",type = "topic"),
            key = "order.*"
        )
    )
    @RabbitHandler//如果有消息过来，在消费的时候调用这个方法
    public void onOrderMessage(@Payload Order order, @Headers Map<String,Object> headers, Channel channel) throws IOException {
        //消费者操作
        System.out.println("---------收到消息，开始消费---------");
        System.out.println("订单ID："+order.getId());
        
        Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
        
        boolean multiple = false;
        //ACK,确认一条消息已经被消费。不然的话，在RabbitMQ首页会有Unacked显示为未处理数1.
        channel.basicAck(deliveryTag,multiple);
    }
}

ConnectionFactory connectionFactory = new ConnectionFactory();
// 获取到tcp连接
Connection connection = connectionFactory.newConnection();
 //从tcp连接中创建通道
 Channel channel = connection.createChannel();
/ 声明exchange
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
// 声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
channel.queueDeclare(QUEUE_NAME2, false, false, false, null);
// 绑定队列到交换机
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "");
// 绑定队列到交换机 - aaa 是路由键3名称(其实这里无作用)
channel.queueBind(QUEUE_NAME2, EXCHANGE_NAME, "aaa");

// 消息内容
String message = "qqqqqqqq";
channel.basicPublish(EXCHANGE_NAME, "aaa", null, message.getBytes()); // 这里路由键aaa有没有都一样，可以写任何值