Java for Beginner

[Совет по Java #053]

Тема: Collectors.toMap при дублирующихся ключах выбрасывает IllegalStateException.

Проблема: Статический метод Collectors.toMap(Function keyMapper, Function valueMapper) создает коллектор, который собирает элементы стрима в HashMap.

Если два элемента стрима отображаются на один и тот же ключ, коллектор выбрасывает IllegalStateException с сообщением "duplicate key". Это поведение часто оказывается неожиданным для разработчиков, которые полагаются на уникальность ключей в данных, но из-за ошибок в данных или бизнес-логике дубликаты возникают. В результате приложение падает в рантайме, и диагностика может быть затруднена, особенно в больших стримах. Даже если вероятность дубликатов мала, надежность кода требует явного определения стратегии разрешения конфликтов.

Решение: Используйте перегруженную версию Collectors.toMap(keyMapper, valueMapper, mergeFunction), где mergeFunction — это BinaryOperator, определяющий, какое значение сохранить при конфликте.
Наиболее частые стратегии: оставить первое значение ((oldValue, newValue) -> oldValue), взять последнее ((old, new) -> new), объединить значения (например, конкатенировать строки или суммировать числа). Для сложной агрегации используйте Collectors.groupingBy в связке с downstream-коллектором.

Также существует Collectors.toConcurrentMap для потокобезопасных карт.

import java.util.*;
import java.util.stream.*;

public class ToMapDuplicate {
    
    public static void main(String[] args) {
        List<String> items = Arrays.asList("apple", "banana", "apple", "cherry");
        
        //Антипаттерн: выбросит IllegalStateException
        try {
            Map<String, Integer> bad = items.stream()
                .collect(Collectors.toMap(s -> s, String::length));
        } catch (IllegalStateException e) {
            System.err.println("Duplicate key: " + e.getMessage());
        }
        
        //Решение 1: оставить первое значение
        Map<String, Integer> first = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                String::length,
                (oldVal, newVal) -> oldVal
            ));
        System.out.println("First: " + first); // {banana=6, apple=5, cherry=6}
        
        //Решение 2: взять последнее значение (часто для перезаписи)
        Map<String, Integer> last = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                String::length,
                (old, newVal) -> newVal
            ));
        System.out.println("Last: " + last);
        
        //Решение 3: объединить значения (например, список длин)
        Map<String, List<Integer>> grouped = items.stream()
            .collect(Collectors.toMap(
                s -> s,
                s -> new ArrayList<>(List.of(s.length())),
                (list1, list2) -> { list1.addAll(list2); return list1; }
            ));
        System.out.println("Grouped: " + grouped);
        
        //Альтернатива: groupingBy для агрегации
        Map<String, Long> countByKey = items.stream()
            .collect(Collectors.groupingBy(
                s -> s,
                Collectors.counting()
            ));
        System.out.println("Counts: " + countByKey);
    }
}

Объяснение: Базовая версия toMap вызывает Map.merge(key, value, throwingMerger()), где throwingMerger просто бросает IllegalStateException. Это сделано для того, чтобы предотвратить случайную потерю данных без явного указания стратегии.

Указывая mergeFunction, вы берете на себя ответственность за разрешение конфликтов. Выбор стратегии зависит от бизнес-правил: для уникальных идентификаторов лучше перезаписывать последним значением; для агрегации — использовать groupingBy с downstream; для подсчета частоты — groupingBy с counting().

#Java #советы

👍5

85 views08:59