嵌套循环到 Java 流拼图

Question

我是 Java 8 中的流的新手。我正在努力弄清楚如何使用流在列表上实现嵌套的 for 循环。一个列表包含消息，消息中的一个字段是作者的 id（遗憾的是，不是 obj 引用）。另一个列表是作者，作者中的一个字段是作者 ID。代码需要为消息列表中的每条消息在作者列表中找到匹配的作者。我拥有的工作 Java 代码（不使用流或 lambdas）如下，我的问题是如何使用流重写它？我已经尝试了几件事，我认为需要一个 flatMap 和一个过滤器，但我似乎无法做到。

public void showAuthors(List<Message> messages, List<Authors> authors) {
    String authorName=null;
    for (Message message : messages) {
        int authorId = message.getAuthorId();
        for (Authors author : authors) {
            if (author.getId() == authorId)
                authorName = author.getFullName();
                break;
        }
        System.out.println("Message id is " + message.getId() + 
                           " author is " + authorName);
    }
}

我在这里查看了一些类似的问题，但我似乎无法正确回答。

感谢任何帮助！

==============================================

更新：作者列表中有一些 Id 字段的空数据。这要求我使用带有流操作的过滤器来创建 AuthorId,Name 的映射。

Answer 1

由于您正在进行mxn 比较，因此最好在authorId -> author 之间创建一个映射以避免O(n) 查找作者：

Map<Integer, Author> authorMaps = authors.stream().collect(toMap(Author::getId, Function.identity()));

现在您可以像这样获取每条消息的作者：

messages.stream().filter(m -> authorMaps.containsKey(m.getAuthorId()))
        .forEach(m -> 
            System.out.println("Message id is " + m.getId() + 
                           " author is " + authorMaps.get(m.getAuthorId()). getFullName());
        );

Answer 2

首先对我来说，您当前的逻辑是错误的。如果第一次不满足条件并且对于所有消息你得到以前的作者或像这样的一些无效结果，它会中断内部循环。

Message id is 1 author is AuthOne
Message id is 2 author is AuthOne
Message id is 4 author is AuthOne

这是更正后的。

public static void showAuthors(List<Message> messages, List<Author> authors) {
    String authorName = null;
    for (Message message : messages) {
        int authorId = message.getAuthorId();
        for (Author author : authors) {
            if (author.getId() == authorId) {
                authorName = author.getFullName();
                break;
            }
        }
        System.out.println("Message id is " + message.getId() + " author is " + authorName);
    }
}

只有在找到第一个 Author 后，您才需要中断循环。这是具有线性时间复杂度的等效 stream 对应项。

Map<Integer, String> authorsById = authors.stream()
        .collect(Collectors.toMap(Author::getId, Author::getFullName));
Map<Integer, String> authorNameAgainstId = messages.stream()
        .collect(Collectors.toMap(Message::getId, m -> authorsById.get(m.getAuthorId())));

Answer 3

在尝试了上面的一些建议之后，我很快意识到作者数据中有一些没有 ID 的对象，只有名称（显然它们有双重目的......这不是我的设计！）。

所以，我根据上述答案的帮助/提示写了以下内容：

public void showAuthors(List<Message> messages, List<Reference> authors) {
Map<Integer, String> authorsById = authors.stream()
    .filter(author -> !(author.getId() == null))
    .filter(name -> !(name.getFullName() == null))
    .collect(Collectors.toMap(Reference::getId, Reference::getFullName));

messages.forEach(
    message -> System.out.println("Message id is " + message.getId() + 
              " Author is " + authorsById.get(message.getSenderId())));

这个解决方案有什么问题吗？

另外，我是 stackoverflow 的新手（我相信您会说出来）...有没有办法可以为所有 3 位响应者提供帮助？这就是点赞的目的吗？

梅格

Answer 4

消息处理不需要流，这里 forEach 更合适。不过，流对于作者列表到地图的转换很有用。

您可以使用带有 3 个参数的 toMap 来避免作者列表中可能的作者重复（原始代码避免了这种情况）。

您可以使用 Optional 来避免可能缺少 authos、null id 等 - 每次 .map 返回 null 时，Optional 都会变为 Optional::Empty，因此对其的进一步处理会跳到终端操作，而 ifPresence 只是跳过 empty选项。

Map<Integer, String> authorNames=authors.stream()
    .collect(Collectors.toMap(
        Author::getId,
        Author::getFullName,
        (oldValue, newValue) -> oldValue));

messages.forEach(
    m -> Optional.of(m)
        .map(Message::getAuthorId)
        .map(authorNames::get)
        .map(name -> "Message id is " + m.getId() + " author is " + name)
        .ifPresent(System.out::println)
);