在ChanenlManager中更新ChannelsResource的目的是什么

问题描述

updateChannelsResource方法希望添加资源id与RM_CHANNELS中的资源id不同的RpcContext

private static void updateChannelsResource(String resourceId, String clientIp, String applicationId) { ConcurrentMap<Integer, RpcContext> sourcePortMap = RM_CHANNELS.get(resourceId).get(applicationId).get(clientIp); for (ConcurrentMap.Entry<String, ConcurrentMap<String, ConcurrentMap<String, ConcurrentMap<Integer, RpcContext>>>> rmChannelEntry : RM_CHANNELS.entrySet()) { if (rmChannelEntry.getKey().equals(resourceId)) { continue; } ConcurrentMap<String, ConcurrentMap<String, ConcurrentMap<Integer, RpcContext>>> applicationIdMap = rmChannelEntry.getValue(); if (!applicationIdMap.containsKey(applicationId)) { continue; } ConcurrentMap<String, ConcurrentMap<Integer, RpcContext>> clientIpMap = applicationIdMap.get(applicationId); if (!clientIpMap.containsKey(clientIp)) { continue; } ConcurrentMap<Integer, RpcContext> portMap = clientIpMap.get(clientIp); for (ConcurrentMap.Entry<Integer, RpcContext> portMapEntry : portMap.entrySet()) { Integer port = portMapEntry.getKey(); if (!sourcePortMap.containsKey(port)) { RpcContext rpcContext = portMapEntry.getValue(); sourcePortMap.put(port, rpcContext); rpcContext.holdInResourceManagerChannels(resourceId, port); } } } }

行的用途是什么sourcePortMap.put（port，rpcContext）；，该rpcContext的资源id与sourcePortMap相关的资源id不同。我想这种方法是错误的，没有必要

原提问者GitHub用户liujianhuiouc