1. Feign 调用注意事项 - ★★★

1. 【原则】: 禁止遍历 - 多次跨服务调用接口 ( 提需求 : idList )

1. 单一数据查询 , 可直接用 Feign单一查询接口

2. List数据查询 , 需进行 Feign 数据转换 , 禁止遍历 Feign

3. stream() : 从List<对象> , 取出 id 和 name 组成 map 集合

4. for 循环 : 从List<对象> , 取出 id 和 Oject 组成 map 集合

2. 【原则】: 避免跨服务调用阻塞流程

1. 减少跨服务校验 ( 删除 - 资源占用 )

2. List 结果集数据转换

1. 单查 feign API , 获取某模块数据 : map 容器化

2. 单查 feign API , 获取某模块数据 : cache 缓存 + map 容器化 ( 推荐 )

1. 对 feign API 数据源作缓存 ( 主业务逻辑不做 )

2. 对全业务作缓存

3. 单查 feign API , 获取某模块数据 : 预热 + cache 缓存 + map 容器化

3. Feign 调用业务情景

1. CMP 配额模块

2. Iot 资产结构模块 - ( 单查 )

3. Iot 锚点数据转换 machineName / productType ( 业务内处理 × )

4. Iot 锚点转换 machine | camera ( 容器构建 map )

4. Feign 提示 / 异常

1. GET 请求以 @Requestbody 传参导致的异常 ( @R~body 用 POST )

1. Feign 调用注意事项 - ★★★

1. 【原则】: 禁止遍历 - 多次跨服务调用接口 ( 提需求 : idList )

路由 filter 过滤

限制 1 s 执行多少次 feign 调用

[
    {
        "args": {
            "key-resolver": "#{@remoteAddrKeyResolver}" , 
            "redis-rate-limiter.burstCapacity": "20" , 
            "redis-rate-limiter.replenishRate": "10"
        } , 
        "name": "RequestRateLimiter"
    } , 
    {
        "args": {
            "name": "default" , 
            "fallbackUri": "forward:/fallback"
        } , 
        "name": "Hystrix"
    }
]

1. 单一数据查询 , 可直接用 Feign单一查询接口

2. List`<Object>` 数据查询 , 需进行 Feign 数据转换 , 禁止遍历 Feign

但HashMap占内存比较大 , 不少人都更关注于HashMap所占的内存怎么计算。

运行了一下 , 没找到HashMap的极限容量 , 但就发现HashMap很耗内存 , 一下子就OutOfMemoryError了。

        Integer a = 1;
        long start = 0;
        long end = 0;
        // 先垃圾回收
        System.gc();
        start = Runtime.getRuntime().freeMemory();
        HashMap map = new HashMap();
        for (int i = 0; i < 1000000; i++) {
            map.put(i ,  a);
        }
        // 快要计算的时 , 再清理一次
        System.gc();
        end = Runtime.getRuntime().freeMemory();
        System.out.println("一个HashMap对象占内存:" + (end - start));

当添加2000000个item的时候 , 就内存溢出了。

1000000个item的HashMap就占内存接近60M了~~夸张

map - key 上限: 2^30 = 1 073 741 824 (10.7 亿)

3. stream() : 从`List<对象>` , 取出 id 和 name 组成 map 集合

     Map<String ,  String> collect = list
         .stream()
         .collect(Collectors.toMap(p -> p.getId() ,  p -> p.getName()));

Iot-emergency 应急管理

原始:

    /**
     * 资产结构数据处理
     * @return Map<Integer ,  String>
     */
    private Map<Integer ,  String> iotStructureMap(){
        IotStructureDTO iotStructureDTO = new IotStructureDTO();
        IotUser user = SecurityUtils.getUser();
        if (user != null) {
            iotStructureDTO.setTenantId(user.getTenantId());
        }
        HashMap<Integer ,  String> structureMap = new HashMap<>(128);
        R<List<IotStructureVO>> listR = remoteIotStructureService.queryIotStructureList(iotStructureDTO);
        if( 0 == listR.getCode() && !listR.getData().isEmpty()){
            for (IotStructureVO iotStructureVO : listR.getData()) {
                structureMap.put(iotStructureVO.getId() , iotStructureVO.getAddressPath());
            }
        }
        return structureMap;
    }

stream() 流处理:

    /**
     * 设备数据处理
     * @return Map<Integer ,  String>
     */
    private Map<Integer ,  String> machineDataMap(){
        MachineData machineData = new MachineData();
        machineData.setDelFlag(1);
        R<List<MachineData>> listR = remoteMachineDataService.feginList(machineData);
        if(0 == listR.getCode() && null != listR.getData() && !listR.getData().isEmpty()){
            return listR.getData()
                    .stream()
                    .collect(Collectors.toMap(MachineData::getMachineId ,  MachineData::getMachineName));
        }
        return new HashMap<>();
    }

4. for 循环 : 从`List<对象>` , 取出 id 和 Oject 组成 map 集合