使用Collectors.toMap处理重复key时需传入mergeFunction，其接收旧值u1和新值u2，按业务规则（如status级别、timestamp先后）决定返回哪个值以实现优先级覆盖。
当使用 Collectors.toMap 处理流中可能含重复 key 的数据时，Java 默认会抛出 IllegalStateException。若需按某种优先级（如时间最新、数值最大、状态更高级等）决定哪个 value 覆盖重复 key，关键在于正确传入第三个参数——mergeFunction。
明确 mergeFunction 的作用逻辑
该函数接收两个同 key 的 value：第一个是「已存在的旧值」，第二个是「当前新出现的值」。你需要在此函数中定义「谁胜出」的规则，并返回最终保留的 value。
- 返回旧值 → 保留先出现的（“先到先得”）
- 返回新值 → 保留后出现的（“后到覆盖”，常见于更新场景）
- 根据字段比较后返回 → 实现业务优先级（如 status 级别更高、timestamp 更晚、score 更大）
按业务字段实现优先级覆盖（示例）
假设有一个 User 类，需按 id 去重，但多个 User 同 id 时，优先保留 status 级别更高的（比如 ACTIVE > PENDING > INACTIVE），且状态相同时保留 updatedAt 更新的那个：
Map<long user> userMap = users.stream()
.collect(Collectors.toMap(
User::getId,
Function.identity(),
(u1, u2) -> {
int cmp = Integer.compare(u2.getStatus().getLevel(), u1.getStatus().getLevel());
if (cmp != 0) return cmp > 0 ? u2 : u1;
return u2.getUpdatedAt().isAfter(u1.getUpdatedAt()) ? u2 : u1;
}
));</long>
注意：这里 u1 是已存入的旧值，u2 是当前待加入的新值；逻辑上我们倾向选「更优」的那个，所以比较后显式返回。
简化写法：复用 Comparator 或静态方法
为提升可读性和复用性，可将优先级逻辑抽成独立方法或 Comparator：
- 定义比较器：
ComparatorpriorityCmp = Comparator.comparing((User u) -> u.getStatus().getLevel()).thenComparing(u -> u.getUpdatedAt()).reversed(); - 在 mergeFunction 中调用：
(u1, u2) -> priorityCmp.compare(u1, u2) （即：若 u2 更优或相等，则留 u2）
这样把排序逻辑和合并逻辑解耦，后续调整优先级只需改 Comparator，不碰收集逻辑。
注意事项与避坑点
使用过程中容易忽略的关键细节：
-
key mapper 和 value mapper 不应返回 null，否则抛
NullPointerException；建议提前 filter 或用 Optional 处理 - mergeFunction 内部不要修改原对象（尤其涉及集合、map 等可变结构），避免副作用
- 若原始数据顺序本身隐含优先级（如数据库查询结果按 update_time DESC 排序），直接用
(u1, u2) -> u1可保最早一条（因 u1 是先插入的），而(u1, u2) -> u2则保最后一条 - 需要默认值兜底？可在 collect 后用
map.computeIfAbsent(key, fallbackSupplier)补充缺失项，而非塞进 toMap
