java - 在 RabbitMq 中插入记录时防止重复

Question

请建议如何防止使用 java 使用值在 RabbitMQ 队列中插入重复记录。

示例:

{
  "jsonObject" : {
     "code" : "ABC",
     "number" : "123456",
     "Name"  : "Narasimha"
  } 
}

如果 RabbitMq 中有一条记录可用。如果尝试再插入一条具有相同代码和编号的记录，则不应允许插入 RabbitMQ。

Answer 1

使用 RabbitMQ 无法做到这一点，amqp 正文是一个缓冲区，而 RMQ 不知道有关正文内容的任何信息。

您应该处理消费者端的重复。

阅读此处:https://www.rabbitmq.com/reliability.html

At the Consumer

In the event of network failure (or a node crashing), messages can be duplicated, and consumers must be prepared to handle them. If possible, the simplest way to handle this is to ensure that your consumers handle messages in an idempotent way rather than explicitly deal with deduplication.