13518219792
这篇文章主要介绍“nacos address中getCluster的原理和作用是什么”，在日常操作中，相信很多人在nacos address中getCluster的原理和作用是什么问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”nacos address中getCluster的原理和作用是什么”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
成都创新互联公司-专业网站定制、快速模板网站建设、高性价比王屋网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式王屋网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖王屋地区。费用合理售后完善，10多年实体公司更值得信赖。
本文主要研究一下nacos address的getCluster
nacos-1.1.3/address/src/main/java/com/alibaba/nacos/address/controller/ServerListController.java
@RestController
public class ServerListController {
@Autowired
private ServiceManager serviceManager;
@Autowired
private AddressServerGeneratorManager addressServerBuilderManager;
/**
* @param product will get Ip list of that products to be associated
* @param cluster will get Ip list of that product cluster to be associated
* @return
*/
@RequestMapping(value = "/{product}/{cluster}", method = RequestMethod.GET)
public ResponseEntity getCluster(@PathVariable String product,
@PathVariable String cluster) {
String productName = addressServerBuilderManager.generateProductName(product);
String serviceName = addressServerBuilderManager.generateNacosServiceName(productName);
Service service = serviceManager.getService(Constants.DEFAULT_NAMESPACE_ID, serviceName);
if (service == null) {
return ResponseEntity.status(HttpStatus.NOT_FOUND).body("product=" + product + " not found.");
}
if (!service.getClusterMap().containsKey(cluster)) {
return ResponseEntity.status(HttpStatus.NOT_FOUND).body("product=" + product + ",cluster=" + cluster + " not found.");
}
Cluster clusterObj = service.getClusterMap().get(cluster);
return ResponseEntity.status(HttpStatus.OK).body(addressServerBuilderManager.generateResponseIps(clusterObj.allIPs(false)));
}
}getCluster方法首先通过addressServerBuilderManager.generateProductName(product)获取productName，通过addressServerBuilderManager.generateNacosServiceName(productName)获取serviceName
然后通过serviceManager.getService(Constants.DEFAULT_NAMESPACE_ID, serviceName)获取service，之后判断service.getClusterMap()是否包含cluster，不包含返回404
最后通过service.getClusterMap().get(cluster)获取cluster，然后通过addressServerBuilderManager.generateResponseIps(clusterObj.allIPs(false))返回结果
nacos-1.1.3/address/src/main/java/com/alibaba/nacos/address/component/AddressServerGeneratorManager.java
@Component
public class AddressServerGeneratorManager {
public String generateProductName(String name) {
if (StringUtils.isBlank(name) || AddressServerConstants.DEFAULT_PRODUCT.equals(name)) {
return AddressServerConstants.ALIWARE_NACOS_DEFAULT_PRODUCT_NAME;
}
return String.format(AddressServerConstants.ALIWARE_NACOS_PRODUCT_DOM_TEMPLATE, name);
}
public String generateNacosServiceName(String rawServiceName) {
if (rawServiceName.indexOf(Constants.DEFAULT_GROUP) != -1) {
return rawServiceName;
}
return Constants.DEFAULT_GROUP + AddressServerConstants.GROUP_SERVICE_NAME_SEP + rawServiceName;
}
public String generateResponseIps(List instanceList) {
StringBuilder ips = new StringBuilder();
instanceList.forEach(instance -> {
ips.append(instance.getIp() + ":" + instance.getPort());
ips.append("\n");
});
return ips.toString();
}
//......
} generateProductName方法对于name为空或者是nacos的，返回nacos.as.default，否则返回nacos.as.前缀加name；generateNacosServiceName会返回DEFAULT_GROUP@@加rawServiceName，默认rawServiceName是不包含DEFAULT_GROUP的；generateResponseIps方法将instanceList转为ip及port并用换行拼接的string
getCluster方法首先通过addressServerBuilderManager.generateProductName(product)获取productName，通过addressServerBuilderManager.generateNacosServiceName(productName)获取serviceName
然后通过serviceManager.getService(Constants.DEFAULT_NAMESPACE_ID, serviceName)获取service，之后判断service.getClusterMap()是否包含cluster，不包含返回404
最后通过service.getClusterMap().get(cluster)获取cluster，然后通过addressServerBuilderManager.generateResponseIps(clusterObj.allIPs(false))返回结果
到此，关于“nacos address中getCluster的原理和作用是什么”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！
