Google PubSub和来自该主题的复制消息

Question

如何防止重复味精在谷歌云PubSub中发生？

void messageReceiver(PubsubMessage pubsubMessage, AckReplyConsumer ackReply) {

        submitHandler.handle(toMessage(pubsubMessage))
                .doOnSuccess((response) -> {
                    log.info("Acknowledging the successfully processed message id: {}, response {}", pubsubMessage.getMessageId(), response);
                    ackReply.ack();  // <---- acknowledged
                })
                .doOnError((e) -> {
                    log.error("Not acknowledging due to an exception", e);
                    ackReply.nack();
                })
                .doOnTerminate(span::finish)
                .subscribe();
    }

Answer 1

Google Cloud Pub/Sub使用“至少一次”交付。从文档中：

通常，Cloud Pub/Sub将每个消息按发布顺序发送一次。但是，消息有时可能会不按顺序传递或不止一次传递。通常，在处理消息时，支持多次传递要求订阅服务器是幂等的。

这意味着它保证它将以1:N倍的速度传递消息，因此，如果您不通过其他先删除重复的东西将消息传递出去，您可能会多次获得消息。您不能定义一个设置来保证准确地交付一次。文档确实引用了您可以使用Cloud Dataflow的Pubsubio获得您想要的行为，但该解决方案似乎不受欢迎：

• 确认截止日期：如果您的代码在截止日期之前没有确认消息，则再次发送消息。默认值是10秒。您可以指定的最大自定义截止日期为600秒（10分钟）。

如果是这种情况，只要在最后期限内确认你的信息，你就不会经常看到这些重复的信息了。