Я прочитал документ, он говорит, что для того, чтобы заставить потребляться идемпотентность rocketmq, предлагаю разобраться с ключом сообщения.
Вот мой код:
Message message = new Message();
message.setKey("ORDERID_100");
SendResult sendResult = producer.send(message);
consumer.subscribe("ons_test", "*", new MessageListener() {
public Action consume(Message message, ConsumeContext context) {
String key = message.getKey()
// order the business unique key to do idempotency
}
});
Что делаетэто значит?Если из-за того, что интернет прервет сообщение, повторите отправку, будут два разных ключа?