Как я могу убедиться, что rocketmq сообщение Idempotency?Что это значит сделать это с ключом сообщения? - PullRequest
0 голосов
/ 18 октября 2018

Я прочитал документ, он говорит, что для того, чтобы заставить потребляться идемпотентность 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
    }
});

Что делаетэто значит?Если из-за того, что интернет прервет сообщение, повторите отправку, будут два разных ключа?

...