在 Java 中从 GCP 发布/订阅重试消息需要哪些设置

Question

我是 GCP 发布/订阅的新手，并尝试重新发送未确认的消息 (ack/nack)。在 GCP 控制台仪表板的订阅中，我提到过：

在我的 java 代码中，我创建了一个订阅者

public Subscriber createSubscriber(String subscriptionId, MessageReceiver receiver) throws MessagingException {
        Subscriber subscriber = null;
        ProjectSubscriptionName subscriptionName = null;
        String projectId = getProjectId();
        if (Objects.isNull(projectId) || Objects.isNull(subscriptionId)) {
            throw new MessagingException(MessagingErrorCodes.MIX90810
                    + " Project Id/Subscription Id is null for subscriptionId = " + subscriptionId + " projectId= "
                    + projectId, MessagingErrorCodes.MIX90810);
        }
        try {
            subscriptionName = ProjectSubscriptionName.of(projectId, subscriptionId);
            subscriber = Subscriber.newBuilder(subscriptionName, receiver).setExecutorProvider(getExecutorProvider()).build();
        } catch (Exception e) {
            throw new MessagingException(MessagingErrorCodes.MAX34540
                            + " Error occurred while creating the subscriber for the subscriptionId = " + subscriptionId
                            + "projectId " + projectId + "subscriptionName= " + subscriptionName,
                    MessagingErrorCodes.MAX34540, e);
        }
    enter code here
        return subscriber;
    }

我第一次收到关于我的 receiveMessage(PubsubMessage 消息，AckReplyConsumer 消费者) 的消息，但如果我没有确认消息，则不会再次收到消息。但是如果发送 nack 它会再次发送消息。

@Service
public class MyMessageReceiver implements MessageReceiver {

    @Override
    public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
        System.out.println(message.getMessageId());
    }
}

我是否需要提及其他配置以启用重试以防不确认消息？

Answer 1

关于重试策略，documentation 表示 Pub/Sub 仅在确认截止日期到期或订阅者不接受消息时才会尝试重新传递消息。一旦确认截止日期过去，该消息将成为重新传递的候选者。重新交付可能不会立即进行，因为重新交付是在尽力而为的基础上执行的。

正如 cmets 中已经提到的，DEFAULT_MAX_ACK_EXTENSION_PERIOD 在Subscriber.java 中设置为 60 分钟，这就是造成此延迟的原因。 Ack 截止日期将继续延长（由客户端库作为本机功能），直到达到此持续时间。意思是，未确认的消息被订阅者租用了 60 分钟，并且在此期间没有资格重新传递。 setMaxAckExtensionPeriod(Duration maxAckExtensionPeriod) 用于将自定义值设置为消息的确认截止日期将延长到的最大期限。

还请注意，这些值都不能保证邮件不会在该时间范围内重新传递。由于网络或服务器故障，消息可能会在maxAckExtensionPeriod 之前重新传递。