如何检查重复项是否未添加到 LinkedBlockingQueue 中？

Question

我使用 Java 邮件 API 接收来自多个 Gmail 帐户的消息。不同的帐户由不同的线程处理，我使用 aLinkedBlockingQueue来存储电子邮件。但是，我不希望将同一电子邮件重复添加到Queue. 这是我到目前为止的代码：

public synchronized void readMail(){
    try {
        boolean alreadyAdded = false;
        Folder inbox = store.getFolder("Inbox");
        inbox.open(Folder.READ_ONLY);
        Message [] received = inbox.getMessages();

        if(messages.isEmpty()){
            for(Message newMessage:received){
                System.out.println("Queue empty, adding messages");
                messages.put(newMessage);
            }
        }

        else{
            for(Message existingMessage:messages){
                for(Message newMessage:received){
                    if (alreadyAdded == true)
                        break;

                    else{
                        if(existingMessage.getSubject().equals(newMessage.getSubject())){
                            alreadyAdded = true;
                            System.out.println("boolean changed to true, message "+newMessage.getSubject()+"won't be added");
                        }

                        else{
                            alreadyAdded = false;
                            System.out.println("Non-duplicate message "+newMessage.getSubject());
                            messages.put(newMessage);
                        }
                    }
                }
            }
        }
    } 
    catch (MessagingException e) {
        e.printStackTrace();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

我遇到的问题是在检查队列是否为空else之后的块中。if我希望它检查刚刚读入的消息集并将其与Queue. 如果该消息已存在，Queue请勿再次添加。我不能简单地使用.contains()，因为每次下载消息时，它们都会被赋予不同的内存位置，因此尽管对象Message实际上可能是相同的（例如具有相同的主题、内容等），但它不会具有相同的签名（例如第一次下载时可能会这样Messagehgshsh676767，但下次下载时可能会这样Messageyyetwt8965）。

我遇到了困难，任何人都可以建议一种方法来确保不添加重复项吗？

Answer 1

if(!queue.contains(element)) {
    queue.add(element);
}

如果您想要一个 Set，您可以扩展 LinkedBlockingQueue 并覆盖添加：

public boolean add(E e)
    if(!this.contains(e)) {
        return super.add(e);
    } else {
        return false;
    }
}

但是您应该在本地创建并使用它，或者正确地重写它 - 所有可以向其中添加元素的方法和构造函数。

关于包含问题，请为接收到的消息创建一个包装器并正确实现该public boolean equals(Object o)方法。当您收到消息时，将其放入此包装器中，并将此包装器放入集合中。