在使用JavaMail API时，如何确保多服务器环境中的一个服务器只读取一次电子邮件

Question

我有一个要求，作为其中的一部分，我想阅读outlook收到的电子邮件，然后做一些处理。我正在使用JavaMail API和IMAP协议来实现这一点。我编写了一个java类，可以读取messagesAdded事件上的电子邮件。

它的完美工作正常与下面的代码在单个服务器环境，但当我部署到生产，我们有2个服务器，我结束了处理每个电子邮件两次，因为相同的代码部署在两个服务器上，都试图读取电子邮件，一旦它在邮箱中收到。

下面是我用来连接到邮箱和阅读电子邮件的代码片段：

 try {
    Properties props = System.getProperties();
    // Get a Session object
    Session session = Session.getInstance(props, null);
    // session.setDebug(true);

    // Get a Store object
    Store store = session.getStore("imap");

    // Connect
    store.connect(argv[0], argv[1], argv[2]);

    // Open a Folder
    Folder folder = store.getFolder(argv[3]);
    if (folder == null || !folder.exists()) {
    System.out.println("Invalid folder");
    System.exit(1);
    }

    folder.open(Folder.READ_WRITE);

    // Add messageCountListener to listen for new messages
    folder.addMessageCountListener(new MessageCountAdapter() {
    public void messagesAdded(MessageCountEvent ev) {
        Message[] msgs = ev.getMessages();
        System.out.println("Got " + msgs.length + " new messages");
        // Process incoming mail.

} catch (Exception ex) {
    ex.printStackTrace();
}

我应该如何限制电子邮件在多服务器环境中只处理一次？

Answer 1

也许解决这个问题最简单的方法就是使用分布式锁；有很多很好的图书馆。但是如果你想在javamail中找到答案，那么有两种方法。

首先，您可以使用标志并调用message.isSet（）来检查其他服务器是否设置了标志，然后message.set标志（）来锁定。不幸的是，这会导致冲突。竞争可以通过一些不漂亮的黑客行为来修复，这些黑客行为涉及另外两个标志或一个名为condstore的IMAP扩展，而javamail显然不支持-setFlags（）需要一个新的long参数来设置标志，只有当标志自客户端上次注意到以来没有改变时。

其次，您可以使用一系列邮箱，并在其中移动邮件。你需要四个邮箱，即收件箱和其他三个邮箱，可能称为“processing-a”、“processing-b”和“processing”。服务器A处理“processing-A”中的所有消息，然后将每个消息移动到“processing-B”，B负责“processing-B”。当每台服务器完成其“处理foo”时，它会在收件箱中查找新邮件，并调用moveMessages（）将一条或几条邮件自动移动到自己的邮箱中。moveMessages（）使用名为move的IMAP扩展以原子方式移动消息，大多数服务器都支持它，但并非所有服务器都支持它。