消息如何保证幂等性？ #

• 生产者方面： 可以对每条消息生成一个msgID，以控制消息重复投递

  java

  AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
  porperties.messageId(String.valueOF(UUID.randomUUID()))
  

  1
  2
  

• 消费者方面： 消息体中必须携带一个业务ID，如银行流水号，消费者可以根据业务ID去重，避免重复消费