MetricTimerListener在统计的时候数据丢失、控制台看到数据误差较大的问题

在进行入com.alibaba.csp.sentinel.slots.clusterbuilder.ClusterBuilderSlot#entry方法的时候

public void entry(Context context, ResourceWrapper resourceWrapper, DefaultNode node, int count, Object... args) throws Throwable { if (clusterNode == null) { synchronized (lock) { if (clusterNode == null) { // Create the cluster node. clusterNode = Env.nodeBuilder.buildClusterNode(); HashMap<ResourceWrapper, ClusterNode> newMap = new HashMap<ResourceWrapper, ClusterNode>(16); newMap.putAll(clusterNodeMap); newMap.put(node.getId(), clusterNode); clusterNodeMap = newMap; } } } node.setClusterNode(clusterNode);

/*
 * if context origin is set, we should get or create a new {@link Node} of
 * the specific origin.
 */
if (!"".equals(context.getOrigin())) {
    Node originNode = node.getClusterNode().getOriginNode(context.getOrigin());
    context.getCurEntry().setOriginNode(originNode);
}

fireEntry(context, resourceWrapper, node, count, args);

}

clusterNode并没有根据resourceWrapper从全局clusterNodeMap中get出来而是直接判断是否为null。为null就new一个新的clusterNode,然后put进clusterNodeMap中，这样可能覆盖了clusterNodeMap原本resourceWrapper对应的统计信息，任意时刻一个resourceWrapper在clusterNodeMap只保留了一个线程的统计信息。这样会不会导致MetricTimerListener在统计的时候数据丢失？控制台看到数据误差较大？

public void run() { Map<Long, List> maps = new TreeMap<Long, List>();

    for (Entry<ResourceWrapper, ClusterNode> e : ClusterBuilderSlot.getClusterNodeMap().entrySet()) {
        String name = e.getKey().getName();
        ClusterNode node = e.getValue();
        Map<Long, MetricNode> metrics = node.metrics();

        for (Entry<Long, MetricNode> entry : metrics.entrySet()) {
            long time = entry.getKey();
            MetricNode metricNode = entry.getValue();
            metricNode.setResource(name);
            if (maps.get(time) == null) {
                maps.put(time, new ArrayList<MetricNode>());
            }
            List<MetricNode> nodes = maps.get(time);
            nodes.add(entry.getValue());
        }
    }
    if (!maps.isEmpty()) {
        for (Entry<Long, List<MetricNode>> entry : maps.entrySet()) {
            try {
                metricWriter.write(entry.getKey(), entry.getValue());
            } catch (Exception e) {
                RecordLog.info("write metric error: ", e);
            }
        }
    }

}

原提问者GitHub用户linlinisme