您好,登錄后才能下訂單哦!
本篇內(nèi)容主要講解“nacos address中deleteCluster的原理及用法”,感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷,實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“nacos address中deleteCluster的原理及用法”吧!
本文主要研究一下nacos address的deleteCluster
nacos-1.1.3/address/src/main/java/com/alibaba/nacos/address/controller/AddressServerClusterController.java
@RestController @RequestMapping({AddressServerConstants.ADDRESS_SERVER_REQUEST_URL + "/nodes"}) public class AddressServerClusterController { @Autowired private ServiceManager serviceManager; @Autowired private AddressServerManager addressServerManager; @Autowired private AddressServerGeneratorManager addressServerGeneratorManager; //...... @RequestMapping(value = "", method = RequestMethod.DELETE) public ResponseEntity deleteCluster(@RequestParam(required = false) String product, @RequestParam(required = false) String cluster, @RequestParam String ips) { //1. prepare the storage name for product and cluster String productName = addressServerGeneratorManager.generateProductName(product); String clusterName = addressServerManager.getDefaultClusterNameIfEmpty(cluster); //2. prepare the response name for product and cluster to client String rawProductName = addressServerManager.getRawProductName(product); String rawClusterName = addressServerManager.getRawClusterName(cluster); ResponseEntity responseEntity = ResponseEntity.status(HttpStatus.OK).body("product=" + rawProductName + ", cluster=" + rawClusterName + " delete success."); try { String serviceName = addressServerGeneratorManager.generateNacosServiceName(productName); Service service = serviceManager.getService(Constants.DEFAULT_NAMESPACE_ID, serviceName); if (service == null) { responseEntity = ResponseEntity.status(HttpStatus.NOT_FOUND).body("product=" + rawProductName + " not found."); } else { if (StringUtils.isBlank(ips)) { // delete all ips from the cluster responseEntity = ResponseEntity.status(HttpStatus.BAD_REQUEST).body("ips must not be empty."); } else { // delete specified ip list String[] ipArray = addressServerManager.splitIps(ips); String checkResult = AddressServerParamCheckUtil.checkIps(ipArray); if (AddressServerParamCheckUtil.CHECK_OK.equals(checkResult)) { List<Instance> instanceList = addressServerGeneratorManager.generateInstancesByIps(serviceName, rawProductName, clusterName, ipArray); serviceManager.removeInstance(Constants.DEFAULT_NAMESPACE_ID, serviceName, false, instanceList.toArray(new Instance[instanceList.size()])); } else { responseEntity = ResponseEntity.status(HttpStatus.BAD_REQUEST).body(checkResult); } } } } catch (Exception e) { responseEntity = ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(e.getCause()); } return responseEntity; } //...... }
deleteCluster接收product、cluster、ips參數(shù);其中productName通過(guò)addressServerGeneratorManager.generateProductName(product)生成;clusterName通過(guò)addressServerManager.getDefaultClusterNameIfEmpty(cluster)生成
它首先通過(guò)serviceManager.getService獲取service,獲取不到則返回404;若ips為空,返回400;之后通過(guò)addressServerGeneratorManager.generateInstancesByIps(serviceName, rawProductName, clusterName, ipArray)獲取instanceList
最后通過(guò)serviceManager.removeInstance(Constants.DEFAULT_NAMESPACE_ID, serviceName, false, instanceList.toArray(new Instance[instanceList.size()]))移除instance;注意這里的ephemeral參數(shù)為false
nacos-1.1.3/naming/src/main/java/com/alibaba/nacos/naming/core/ServiceManager.java
@Component @DependsOn("nacosApplicationContext") public class ServiceManager implements RecordListener<Service> { /** * Map<namespace, Map<group::serviceName, Service>> */ private Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>(); private LinkedBlockingDeque<ServiceKey> toBeUpdatedServicesQueue = new LinkedBlockingDeque<>(1024 * 1024); private Synchronizer synchronizer = new ServiceStatusSynchronizer(); private final Lock lock = new ReentrantLock(); @Resource(name = "consistencyDelegate") private ConsistencyService consistencyService; @Autowired private SwitchDomain switchDomain; @Autowired private DistroMapper distroMapper; @Autowired private ServerListManager serverListManager; @Autowired private PushService pushService; private final Object putServiceLock = new Object(); //...... public Service getService(String namespaceId, String serviceName) { if (serviceMap.get(namespaceId) == null) { return null; } return chooseServiceMap(namespaceId).get(serviceName); } public Map<String, Service> chooseServiceMap(String namespaceId) { return serviceMap.get(namespaceId); } public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); removeInstance(namespaceId, serviceName, ephemeral, service, ips); } public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Service service, Instance... ips) throws NacosException { String key = KeyBuilder.buildInstanceListKey(namespaceId, serviceName, ephemeral); List<Instance> instanceList = substractIpAddresses(service, ephemeral, ips); Instances instances = new Instances(); instances.setInstanceList(instanceList); consistencyService.put(key, instances); } //...... }
getService方法直接從serviceMap中根據(jù)namespaceId獲取map,然后再根據(jù)serviceName獲取Service;removeInstance方法先獲取service,然后再移除指定的instance,最后更新到consistencyService
deleteCluster接收product、cluster、ips參數(shù);其中productName通過(guò)addressServerGeneratorManager.generateProductName(product)生成;clusterName通過(guò)addressServerManager.getDefaultClusterNameIfEmpty(cluster)生成
它首先通過(guò)serviceManager.getService獲取service,獲取不到則返回404;若ips為空,返回400;之后通過(guò)addressServerGeneratorManager.generateInstancesByIps(serviceName, rawProductName, clusterName, ipArray)獲取instanceList
最后通過(guò)serviceManager.removeInstance(Constants.DEFAULT_NAMESPACE_ID, serviceName, false, instanceList.toArray(new Instance[instanceList.size()]))移除instance;注意這里的ephemeral參數(shù)為false
到此,相信大家對(duì)“nacos address中deleteCluster的原理及用法”有了更深的了解,不妨來(lái)實(shí)際操作一番吧!這里是億速云網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。