谷歌PubSub/Gmail Webhook：发送电子邮件时始终接收来自PubSub的多个POST请求

Question

我看到的问题是，当我向另一个用户发送消息时，PubSub似乎在一秒钟内两次使用略有不同的history_id和message_id，但订阅名称和用户电子邮件都是相同的。

我知道PubSub保证至少一次交付，所以接收重复的消息并不是不合理的，但因为它一直在发生，而且message_id不同，我认为根据下面的PubSub文档，可能会有多个推送请求：

Cloud pub/sub为每个消息分配唯一的message_id，该消息可用于检测订阅者接收的重复消息。但是，这将不允许您检测同一数据上的多个发布请求所产生的重复项。

1. 确保在我的Google云控制台上只有一个主题/订阅。
2. 将Ack截止日期设置为10到600秒之间的不同值。
3. 调用service.users().stop()以确保没有多次调用watch()，然后再次开始watch().

我已经调查了PubSubIO，以确保准确地一次交付，但我认为如果我一直收到多条PubSub，我设置Webhook的方式肯定有根本性的问题。

编辑：这是我必须观察我的Gmail帐户变化的代码。我正在使用一个具有域范围权限的服务帐户，以便访问整个域中的帐户

public static Map<String, String> watchInbox(Gmail service) throws IOException {
    Map<String, String> watchInboxResponse = new HashMap<>();
    List<String> labelsToWatch = Arrays.asList("INBOX", "SENT");
    String topicName = "projects/subscription-name/topics/topic-name";

    WatchRequest request = new WatchRequest();
    request.setLabelIds(labelsToWatch);
    request.setTopicName(topicName);

    WatchResponse response = service.users().watch("me", request).execute();

    watchInboxResponse.put("historyId", response.getHistoryId().toString());
    watchInboxResponse.put("expiration", response.getExpiration().toString());
    return watchInboxResponse;
}

我将historyid和Expersion插入到数据库中，并在收到webhook调用时使用它来检查是否需要再次调用watch()，如果从上次调用watch已经超过24小时（如Google所建议的）。

Answer 1

我在实现Google Pub/Sub观看请求时也有类似的行为。

当你写邮件时，Gmail所做的是创建系统标签“发送和草稿”，并不断地用新的messageId和标签“发送和草稿”保存草稿，你订阅了对“收件箱和发送”的任何更改，所以你会在你的webhook上被击中两次或更多时间！！

来自Gmail的消息总是包含标签，你必须过滤那些有标签草稿的消息。

//Explicitly avoid further processing
 bool isdraft = y.Message.LabelIds.Contains("DRAFT");