谷粒商城----rabbitmq

@Slf4j
@Configuration
public class OrderRabbitConfig {
//  @Autowired
  private RabbitTemplate rabbitTemplate;
  @Primary
  @Bean
  public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    this.rabbitTemplate = rabbitTemplate;
    rabbitTemplate.setMessageConverter(messageConverter());
    // 设置回调
    initRabbitTemplate();
    return rabbitTemplate;
  }
  @Bean
  public MessageConverter messageConverter(){
    return new Jackson2JsonMessageConverter();
  }
  /**
   * 1.设置确认回调： ConfirmCallback
   * 先在配置文件中开启 publisher-confirms: true
   * @PostConstruct: MyRabbitConfig对象创建完成以后 执行这个方法
   *
   *  2.消息抵达队列的确认回调
   * 　  开启发送端消息抵达队列确认
   *     publisher-returns: true
   *      只要抵达队列，以异步优先回调我们这个 returnconfirm
   *     template:
   *       mandatory: true
   *  3.消费端确认(保证每一个消息被正确消费才可以broker删除消息)
   *    1.默认是自动确认的 只要消息接收到 服务端就会移除这个消息
   *
   *    如何签收:
   *      签收: channel.basicAck(deliveryTag, false);
   *      拒签: channel.basicNack(deliveryTag, false,true);
   *  配置文件中一定要加上这个配置
   *    listener:
   *       simple:
   *         acknowledge-mode: manual
   */
//  @PostConstruct
  public void initRabbitTemplate(){
    /**
     *    设置确认回调  消息到达broker
     *  correlationData: 消息的唯一id
     *  ack： 消息是否成功收到
     *  cause：失败的原因
     */
    rabbitTemplate.setConfirmCallback(
        (correlationData, ack , cause) ->
            log.info("\nbroker收到消息: " + correlationData + "\tack: " + ack + "\tcause： " + cause));
    /**
     * 只要消息没有投递给指定的队列，就触发这个失败回调
     *
     * message: 投递失败的消息详细信息
     * replyCode: 回复的状态码
     * replyText: 回复的文本内容
     * exchange: 当时这个发送给那个交换机
     * routerKey: 当时这个消息用那个路由键
     */
    rabbitTemplate.setReturnCallback(
        (message, replyCode, replyText, exchange, routerKey)
            -> log.error("Fail Message [" + message + "]" + "\treplyCode: " + replyCode + "\treplyText:" + replyText + "\texchange:" + exchange + "\trouterKey:" + routerKey));
  }
}

@Bean
  public Exchange orderEventExchange(){
    return new TopicExchange( RabbitInfo.Order.exchange,
        true, false);
  }
  /**
   * String name, boolean durable, boolean exclusive,
   * boolean autoDelete,
   * @Nullable Map<String, Object> arguments
   */
  @Bean
  public Queue orderDelayQueue(){
    Map<String ,Object> arguments = new HashMap<>();
    arguments.put("x-dead-letter-exchange", RabbitInfo.Order.exchange);
    // 死信队列的re路由key
    arguments.put("x-dead-letter-routing-key",  RabbitInfo.Order.releaseRoutingKey);
    arguments.put("x-message-ttl",  RabbitInfo.Order.ttl);
    Queue queue = new Queue( RabbitInfo.Order.delayQueue, true, false, false, arguments);
    return queue;
  }
  @Bean
  public Queue orderReleaseOrderQueue(){
    Queue queue = new Queue( RabbitInfo.Order.releaseQueue,
        true,
        false,
        false);
    return queue;
  }
  /**
   * String destination, DestinationType destinationType, String exchange, String routingKey, @Nullable Map<String, Object> arguments
   */
  @Bean
  public Binding orderCreateOrderBinding(){
    return new Binding( RabbitInfo.Order.delayQueue, Binding.DestinationType.QUEUE,
        RabbitInfo.Order.exchange,  RabbitInfo.Order.delayRoutingKey, null);
  }
  @Bean
  public Binding orderReleaseOrderBinding(){
    return new Binding( RabbitInfo.Order.releaseQueue, Binding.DestinationType.QUEUE,
        RabbitInfo.Order.exchange,  RabbitInfo.Order.releaseRoutingKey, null);
  }

@ResponseBody
  @GetMapping("/test/createOrder")
  public String createOrderTest(){
    OrderEntity orderEntity = new OrderEntity();
    orderEntity.setOrderSn(UUID.randomUUID().toString().replace("-",""));
    orderEntity.setModifyTime(new Date());
    rabbitTemplate.convertAndSend("order-event-exchange", "order.create.order", orderEntity);
    return "下单成功";
  }