Sentinel源码解析之ClusterBuilderSlot

- 日理万妓 2022-10-15 00:47 212阅读 0赞

> 原创不易，转载请注明出处

### 文章目录 ###

*   *   *  前言
         *  源码解析
         *   *  entry方法
             *  exit方法
         *  总结

--------------------

### 前言 ###

在《Sentinel源码解析之NodeSelectorSlot》一文中我们分析了第一个slot NodeSelectorSlot的源码，这个slot主要是为相同资源不同的线程创建node，缓存没有创建，然后塞到当前线程中。今天我们要分析的ClusterBuilderSlot 从名字上看也能知道是与集群有关的，它主要是为某个资源创建集群node的，也就是每个资源就一个集群node，代码也很简单，我们看下。

### 源码解析 ###

首先看下ClusterBuilderSlot的成员

private static volatile Map<ResourceWrapper, ClusterNode> clusterNodeMap = new HashMap<>();//资源 ---》clusterNode
    
    private static final Object lock = new Object();
    
    private volatile ClusterNode clusterNode = null;// clusterNode

可以看到这个clusterNodeMap 其实就是个缓存 资源与 ClusterNode 对应关系的，一个资源对应着一个ClusterNode 对象。  
lock就是个锁，这个下面会用到，一个资源一把锁。  
clusterNode这个是对象成员，一个资源对应一个clusterNode。

#### entry方法 ####

@Override
        public void entry(Context context, ResourceWrapper resourceWrapper, DefaultNode node, int count,
                          boolean prioritized, Object... args)
            throws Throwable { 
            if (clusterNode == null) { 
                synchronized (lock) { 
                    if (clusterNode == null) { 
                        // Create the cluster node.
    
                        // 创建 cluster node
                        clusterNode = new ClusterNode();
                        HashMap<ResourceWrapper, ClusterNode> newMap = new HashMap<>(Math.max(clusterNodeMap.size(), 16));
                        newMap.putAll(clusterNodeMap);
    
                        ///node.getId() 这个其实是resource
                        newMap.put(node.getId(), clusterNode);
    
                        clusterNodeMap = newMap;
                    }
                }
            }
    
            /// 设置clusterNode
            node.setClusterNode(clusterNode);
    
            /* * if context origin is set, we should get or create a new {@link Node} of * the specific origin. * 此上下文的起源(通常表示不同的调用者，例如服务使用者名称或起源IP)。 */
            if (!"".equals(context.getOrigin())) { 
    
                //创建originNode 然后在当前entry 甚至originNode
                Node originNode = node.getClusterNode().getOrCreateOriginNode(context.getOrigin());
                context.getCurEntry().setOriginNode(originNode);
            }
    
            fireEntry(context, resourceWrapper, node, count, prioritized, args);
        }

代码很简单，就是这个资源对应的clusterNode不存在的话，就创建一个ClusterNode实例，然后放到map中缓存  
再就是设置到往当前node中，这个node是上个NodeSelectorSlot 创建的那个。  
再就是从context取出origin，这个origin得解释下，其实就是上层资源，比如说微服务中，上层服务调用下层服务，sentinel会通过一些手段将上层服务资源传到下层服务，然后就能获取到这个origin，如果我们这个服务不是上层服务的话，这个origin一般会有的，这里就是获取origin的node，他也有个map专门缓存的，如果没有就创建。最后将这个origin node塞到当前调用entry中。  
最后就是调用下一个slot。

#### exit方法 ####

这个与NodeSelectorSlot 一样，啥事没干

@Override
    public void exit(Context context, ResourceWrapper resourceWrapper, int count, Object... args) { 
        /// 也没干啥子操作
        fireExit(context, resourceWrapper, count, args);
    }

### 总结 ###

这个ClusterBuilderSlot 还是很简单，就是为资源创建一个clusternode ，然后塞到当前调用node中，同时将origin node 塞到当前调用entry中。其实从ClusterBuilderSlot 与NodeSelectorSlot 中我们会发现，开始它就是准备各个维度统计使用的node，这些维度还是需要我们自己品的。