Java Stream实现复杂字符串数据分组与映射

String data = "010$$fengtai,010$$chaoyang,010$$haidain,027$$wuchang,027$$hongshan,027$$caidan,021$$changnin,021$$xuhui,020$$tianhe";

{
  027=[wuchang, hongshan, caidan],
  020=[tianhe],
  010=[fengtai, chaoyang, haidain],
  021=[changnin, xuhui]
}

import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class TraditionalParser {

    public Map<String, List<String>> parseDataTraditional(String inputData) {
        // 第一步：按逗号分隔，并进一步按$$分隔
        List<String[]> splitDataList = Arrays.stream(inputData.split(","))
            .map(s -> s.split("\$\$"))
            .collect(Collectors.toList()); // 这里仍使用了Stream，但后续是传统迭代

        // 第二步：迭代处理，构建Map
        Map<String, List<String>> resultMap = new HashMap<>();
        for (String[] entry : splitDataList) {
            String key = entry[0];
            String value = entry[1];

            // 检查Map中是否已存在该Key对应的列表
            List<String> list = resultMap.get(key);
            if (list == null) {
                // 如果不存在，则创建新列表并添加元素
                list = new ArrayList<>();
                list.add(value);
                resultMap.put(key, list);
            } else {
                // 如果存在，则直接向现有列表中添加元素
                list.add(value);
            }
        }
        return resultMap;
    }
}

// 初始尝试
Map<String, List<String>> result =  Arrays.stream(data.split(","))
    .collect(Collectors.groupingBy(s -> s.split("\$\$")[0]));

import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class StreamParser {

    public Map<String, List<String>> parseDataStream(String inputData) {
        return Arrays.stream(inputData.split(",")) // 1. 按逗号分隔原始字符串，得到Stream<String>
            .collect(Collectors.groupingBy(
                s -> s.split("\$\$")[0], // 2. 定义分组键：使用"$$"前缀作为Key
                Collectors.mapping(
                    s -> s.split("\$\$")[1], // 3. 定义值映射：使用"$$"后缀作为Value
                    Collectors.toList()       // 4. 定义下游收集器：将映射后的值收集到List中
                )
            ));
    }
}

import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class OptimizedStreamParser {

    public Map<String, List<String>> parseDataOptimizedStream(String inputData) {
        return Arrays.stream(inputData.split(",")) // 1. 按逗号分隔原始字符串，得到Stream<String>
            .map(s -> s.split("\$\$"))        // 2. 预处理：将每个String元素分割成String[]数组
            .collect(Collectors.groupingBy(
                sArray -> sArray[0],             // 3. 定义分组键：使用数组的第一个元素作为Key
                Collectors.mapping(
                    sArray -> sArray[1],         // 4. 定义值映射：使用数组的第二个元素作为Value
                    Collectors.toList()          // 5. 定义下游收集器：将映射后的值收集到List中
                )
            ));
    }

    public static void main(String[] args) {
        String data = "010$$fengtai,010$$chaoyang,010$$haidain,027$$wuchang,027$$hongshan,027$$caidan,021$$changnin,021$$xuhui,020$$tianhe";
        OptimizedStreamParser parser = new OptimizedStreamParser();
        Map<String, List<String>> result = parser.parseDataOptimizedStream(data);
        System.out.println(result);
        // 预期输出: {027=[wuchang, hongshan, caidan], 020=[tianhe], 021=[changnin, xuhui], 010=[fengtai, chaoyang, haidain]}
    }
}