【Nacos】微服务注册在不同的group上，支持跨group服务发现，二次开发

        Nacos具备微服务注册和发现，以及配置管理的功能，本文详情描述【注册和发现】的原理，以及基本使用，包括如何进行跨group注册和发现。

一、Nacos配置

spring:cloud:nacos:discovery:server-addr: nacosIP地址:8849namespace: devgroup: Productconfig:server-addr: nacosIP地址:8849namespace: devgroup: Productfile-extension: yamlrefresh-enabled: trueenable-remote-sync-config: truename: product.yaml
spring:cloud:nacos:discovery:server-addr: nacosIP地址:8849namespace: devgroup: Orderconfig:server-addr: nacosIP地址:8849namespace: devgroup: Orderfile-extension: yamlrefresh-enabled: trueenable-remote-sync-config: truename: order.yamlextension-configs:- data-id: config-global.yamlgroup: Orderrefresh: true
一、NacosServiceDiscovery 中 getInstances 获取注册在nacos上的服务实例清单

public List<ServiceInstance> getInstances(String serviceId) throws NacosException {String group = this.discoveryProperties.getGroup();List<Instance> instances = this.namingService().selectInstances(serviceId, group, true);return hostToServiceInstanceList(instances, serviceId);
}

  但是原始功能不支持跨group服务发现，所以我们需要重写 getInstances方法。

二、NacosServiceDiscoveryV2 继承 NacosServiceDiscovery，并重写 getInstances

import com.alibaba.cloud.nacos.NacosServiceInstance;
import com.alibaba.cloud.nacos.NacosServiceManager;
import com.alibaba.cloud.nacos.discovery.NacosServiceDiscovery;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.api.naming.pojo.ListView;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import org.springframework.cloud.client.ServiceInstance;import java.util.*;import static com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty;
import static java.util.Objects.isNull;/*** @description: naocs服务发现重写*/
public class NacosServiceDiscoveryV2 extends NacosServiceDiscovery {private final NacosDiscoveryPropertiesV2 discoveryProperties;private final NacosShareProperties nacosShareProperties;private final NacosServiceManager nacosServiceManager;public NacosServiceDiscoveryV2(NacosDiscoveryPropertiesV2 discoveryProperties, NacosShareProperties nacosShareProperties, NacosServiceManager nacosServiceManager) {super(discoveryProperties, nacosServiceManager);this.discoveryProperties = discoveryProperties;this.nacosShareProperties = nacosShareProperties;this.nacosServiceManager = nacosServiceManager;}/*** Return all instances for the given service.* @param serviceId id of service* @return list of instances* @throws NacosException nacosException*/@Overridepublic List<ServiceInstance> getInstances(String serviceId) throws NacosException {String group = discoveryProperties.getGroup();List<Instance> instances = discoveryProperties.namingServiceInstance().selectInstances(serviceId, group, true);if (isEmpty(instances)) {Map<String, Set<String>> namespaceGroupMap = nacosShareProperties.getNamespaceGroupMap();Map<String, NamingService> namespace2NamingServiceMap = discoveryProperties.shareNamingServiceInstances();for (Map.Entry<String, NamingService> entry : namespace2NamingServiceMap.entrySet()) {String namespace;NamingService namingService;if (isNull(namespace = entry.getKey()) || isNull(namingService = entry.getValue()))continue;Set<String> groupNames = namespaceGroupMap.get(namespace);List<Instance> shareInstances;if (isEmpty(groupNames)) {shareInstances = namingService.selectInstances(serviceId, group, true);if (CollectionUtils.isNotEmpty(shareInstances))break;} else {shareInstances = new ArrayList<>();for (String groupName : groupNames) {List<Instance> subShareInstances = namingService.selectInstances(serviceId, groupName, true);if (CollectionUtils.isNotEmpty(subShareInstances)) {shareInstances.addAll(subShareInstances);}}}if (CollectionUtils.isNotEmpty(shareInstances)) {instances = shareInstances;break;}}}return hostToServiceInstanceList(instances, serviceId);}/*** Return the names of all services.* @return list of service names* @throws NacosException nacosException*/public List<String> getServices() throws NacosException {String group = discoveryProperties.getGroup();ListView<String> services = discoveryProperties.namingServiceInstance().getServicesOfServer(1, Integer.MAX_VALUE, group);return services.getData();}public static List<ServiceInstance> hostToServiceInstanceList(List<Instance> instances, String serviceId) {List<ServiceInstance> result = new ArrayList<>(instances.size());for (Instance instance : instances) {ServiceInstance serviceInstance = hostToServiceInstance(instance, serviceId);if (serviceInstance != null) {result.add(serviceInstance);}}return result;}public static ServiceInstance hostToServiceInstance(Instance instance,String serviceId) {if (instance == null || !instance.isEnabled() || !instance.isHealthy()) {return null;}NacosServiceInstance nacosServiceInstance = new NacosServiceInstance();nacosServiceInstance.setHost(instance.getIp());nacosServiceInstance.setPort(instance.getPort());nacosServiceInstance.setServiceId(serviceId);Map<String, String> metadata = new HashMap<>();metadata.put("nacos.instanceId", instance.getInstanceId());metadata.put("nacos.weight", instance.getWeight() + "");metadata.put("nacos.healthy", instance.isHealthy() + "");metadata.put("nacos.cluster", instance.getClusterName() + "");metadata.putAll(instance.getMetadata());nacosServiceInstance.setMetadata(metadata);if (metadata.containsKey("secure")) {boolean secure = Boolean.parseBoolean(metadata.get("secure"));nacosServiceInstance.setSecure(secure);}return nacosServiceInstance;}private NamingService namingService() {return nacosServiceManager.getNamingService(discoveryProperties.getNacosProperties());}
}

原理：

1、根据 serviceId 和 group 获取当前实例

2、获取所有group清单，并根据group找到group下所有实例

3、将group清单，加入到自己的实例清单中。

三、NacosDiscoveryPropertiesV2 继承 NacosDiscoveryProperties，服务发现属性重写 shareNamingServiceInstances、getNacosProperties方法

import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.client.naming.utils.UtilAndComs;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import java.util.function.Predicate;import static com.alibaba.nacos.api.PropertyKeyConst.*;
import static java.util.Objects.nonNull;/*** @description: naocs服务发现属性重写*/
public class NacosDiscoveryPropertiesV2 extends NacosDiscoveryProperties {private static final Logger log = LoggerFactory.getLogger(NacosDiscoveryPropertiesV2.class);private final NacosShareProperties nacosShareProperties;private static final Map<String, NamingService> NAMESPACE_TO_NAMING_SERVICE_MAP = new ConcurrentHashMap<>();public NacosDiscoveryPropertiesV2(NacosShareProperties nacosShareProperties) {super();this.nacosShareProperties = nacosShareProperties;}public Map<String, NamingService> shareNamingServiceInstances() {if (!NAMESPACE_TO_NAMING_SERVICE_MAP.isEmpty()) {return new HashMap<>(NAMESPACE_TO_NAMING_SERVICE_MAP);}List<NacosShareProperties.NacosShareEntity> entities = Optional.ofNullable(nacosShareProperties).map(NacosShareProperties::getEntities).orElse(Collections.emptyList());entities.stream().filter(entity -> nonNull(entity) && nonNull(entity.getNamespace())).filter(distinctByKey(NacosShareProperties.NacosShareEntity::getNamespace)).forEach(entity -> {try {NamingService namingService = NacosFactory.createNamingService(getNacosProperties(entity.getNamespace()));if (namingService != null) {NAMESPACE_TO_NAMING_SERVICE_MAP.put(entity.getNamespace(), namingService);}} catch (Exception e) {log.error("create naming service error! properties={}, e=", this, e);}});return new HashMap<>(NAMESPACE_TO_NAMING_SERVICE_MAP);}private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {Map<Object, Boolean> seen = new ConcurrentHashMap<>();return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;}private Properties getNacosProperties(String namespace) {Properties properties = new Properties();properties.put(SERVER_ADDR, getServerAddr());properties.put(USERNAME, Objects.toString(getUsername(), ""));properties.put(PASSWORD, Objects.toString(getPassword(), ""));properties.put(NAMESPACE, namespace);properties.put(UtilAndComs.NACOS_NAMING_LOG_NAME, getLogName());String endpoint = getEndpoint();if (endpoint.contains(":")) {int index = endpoint.indexOf(":");properties.put(ENDPOINT, endpoint.substring(0, index));properties.put(ENDPOINT_PORT, endpoint.substring(index + 1));}else {properties.put(ENDPOINT, endpoint);}properties.put(ACCESS_KEY, getAccessKey());properties.put(SECRET_KEY, getSecretKey());properties.put(CLUSTER_NAME, getClusterName());properties.put(NAMING_LOAD_CACHE_AT_START, getNamingLoadCacheAtStart());//        enrichNacosDiscoveryProperties(properties);return properties;}
}

四、共享share属性类 NacosShareProperties

import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;import java.util.*;
import java.util.concurrent.ConcurrentHashMap;import static java.util.Objects.nonNull;/*** <pre>*  @description: 共享nacos属性*  </pre>*/
@Configuration
@ConfigurationProperties(prefix = "nacos.share")
public class NacosShareProperties {private final Map<String, Set<String>> NAMESPACE_TO_GROUP_NAME_MAP = new ConcurrentHashMap<>();/*** 共享nacos实体列表*/private List<NacosShareEntity> entities;public List<NacosShareEntity> getEntities() {return entities;}public void setEntities(List<NacosShareEntity> entities) {this.entities = entities;}public Map<String, Set<String>> getNamespaceGroupMap() {if (CollectionUtils.isEmpty(entities)) {return new HashMap<>();}entities.stream().filter(entity -> nonNull(entity) && nonNull(entity.getNamespace())).forEach(entity -> {Set<String> groupNames = NAMESPACE_TO_GROUP_NAME_MAP.computeIfAbsent(entity.getNamespace(), k -> new HashSet<>());if (nonNull(entity.getGroupNames()))groupNames.addAll(entity.getGroupNames());});return new HashMap<>(NAMESPACE_TO_GROUP_NAME_MAP);}@Overridepublic String toString() {return "NacosShareProperties{" +"entities=" + entities +'}';}/*** 共享nacos实体*/public static final class NacosShareEntity {/*** 命名空间*/private String namespace;/*** 分组*/private List<String> groupNames;public String getNamespace() {return namespace;}public void setNamespace(String namespace) {this.namespace = namespace;}public List<String> getGroupNames() {return groupNames;}public void setGroupNames(List<String> groupNames) {this.groupNames = groupNames;}@Overridepublic String toString() {return "NacosShareEntity{" +"namespace='" + namespace + '\'' +", groupNames=" + groupNames +'}';}}
}

五、整合配置类 NacosDiscoveryAutoConfigurationV2

import com.alibaba.cloud.nacos.ConditionalOnNacosDiscoveryEnabled;
import com.alibaba.cloud.nacos.NacosServiceManager;
import com.alibaba.cloud.nacos.discovery.NacosDiscoveryAutoConfiguration;
import com.alibaba.cloud.nacos.discovery.NacosServiceDiscovery;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.cloud.client.ConditionalOnDiscoveryEnabled;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @Auther: yangjian*/
@Configuration(proxyBeanMethods = false)
@ConditionalOnDiscoveryEnabled
@ConditionalOnNacosDiscoveryEnabled
@AutoConfigureBefore({NacosDiscoveryAutoConfiguration.class})
public class NacosDiscoveryAutoConfigurationV2 {@Bean@ConditionalOnMissingBeanpublic NacosDiscoveryPropertiesV2 nacosProperties(NacosShareProperties nacosShareProperties) {return new NacosDiscoveryPropertiesV2(nacosShareProperties);}@Bean@ConditionalOnMissingBeanpublic NacosServiceDiscovery nacosServiceDiscovery(NacosDiscoveryPropertiesV2 discoveryPropertiesV2, NacosShareProperties nacosShareProperties, NacosServiceManager nacosServiceManager) {return new NacosServiceDiscoveryV2(discoveryPropertiesV2, nacosShareProperties, nacosServiceManager);}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/50218.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

无人机飞行姿态俯仰、横滚、偏航、油门详解

无人机飞行姿态俯仰、横滚、偏航、油门详解

无人机飞行姿态涉及其在空中的空间位置和方向。飞行姿态控制的精确性和稳定性是无人机实现自主飞行和完成任务的关键。无人机的飞行姿态主要通过控制其横滚、俯仰和偏航来实现。以下是对无人机飞行姿态的详细解释&#xff1a; 1. 横滚&#xff08;Roll&#xff09; 定义&…
阅读更多...
vue中的nexttrick

vue中的nexttrick

Vue.js 是一个用于构建用户界面的渐进式框架&#xff0c;它允许开发者通过声明式的数据绑定来构建网页应用。在 Vue 中&#xff0c;nextTick 是一个非常重要的 API&#xff0c;它用于延迟回调的执行&#xff0c;直到下次 DOM 更新循环之后。 为什么使用 nextTick&#xff1f; …
阅读更多...
自定义维度映射：Kylin Cube设计的高级玩法

自定义维度映射：Kylin Cube设计的高级玩法

自定义维度映射&#xff1a;Kylin Cube设计的高级玩法 在数据仓库领域&#xff0c;Apache Kylin以其高性能的分析能力而闻名。Kylin通过构建多维数据立方体&#xff08;Cube&#xff09;来实现对大数据集的快速查询。Cube设计中的维度映射是优化查询性能的关键环节。本文将探讨…
阅读更多...
vue3前端开发-小兔鲜项目-登录组件的开发表单验证

vue3前端开发-小兔鲜项目-登录组件的开发表单验证

vue3前端开发-小兔鲜项目-登录组件的开发表单验证&#xff01;现在开始写登录页面的内容。首先这一次完成基础的首页按钮点击跳转&#xff0c;以及初始化一些简单的表单的输入验证。后期还会继续完善内容。 1&#xff1a;首先还是准备好login页面的组件代码内容。 <script …
阅读更多...
企业风险管理的智能监控：Kompas.ai如何预警潜在风险

企业风险管理的智能监控：Kompas.ai如何预警潜在风险

在企业运营中&#xff0c;风险管理是确保业务连续性和稳健发展的关键环节。随着技术的进步&#xff0c;智能风险管理成为预防损失和识别潜在风险的重要手段。Kompas.ai&#xff0c;作为一款先进的智能监控工具&#xff0c;正通过数据分析和模式识别技术&#xff0c;帮助企业实现…
阅读更多...
《华为数据之道》读书笔记六---面向自助消费的数据服务建设

《华为数据之道》读书笔记六---面向自助消费的数据服务建设

七、从结果管理到过程管理&#xff0c; 从能“看”到能“管” 1、数据赋能业务运营 数字化运营旨在利用数字化技术获取、管理和分析数据&#xff0c;从而为企业的战略决策与业务运营提供可量化的、科学的支撑。 数字化运营归根结底是运营&#xff0c;旨在推动运营效率与能力的…
阅读更多...
【第三天】计算机网络 HTTP请求中常见的状态码 什么是强缓存和协商缓存

【第三天】计算机网络 HTTP请求中常见的状态码 什么是强缓存和协商缓存

HTTP请求中常见的状态码 前面不是说过了HTTP的请求报文和响应报文吗&#xff1f; 状态码不就是响应报文里才有的吗。 同时响应报文的第一行包含了协议版本&#xff0c;状态码以及描述。 状态码有以下这几个类别&#xff1a; 状态码类别含义1XXinformation(信息性状态码&#…
阅读更多...
基站光伏直流叠光能效管理方案

基站光伏直流叠光能效管理方案

安科瑞 华楠 基站现状和趋势 5G基站是专门提供5G网络服务的公用移动通信基站。5G基站主要用于提供5G空口协议功能&#xff0c;支持与用户设备、核心网之间的通信。按照逻辑功能划分&#xff0c;5G基站可分为5G基带单元与5G射频单元&#xff0c;二者之间可通过CPRI或eCPRI接口…
阅读更多...
AFSim仿真系统-架构概览

AFSim仿真系统-架构概览

引言 本文档从最终用户的角度描述了AFSIM架构&#xff0c;旨在帮助最终用户深入了解AFSIM的操作概念。 核心架构 AFSIM基于面向对象的C架构&#xff0c;提供了一种可扩展和模块化的架构&#xff0c;使得许多附加功能能够轻松集成。AFSIM允许新的组件模型&#xff08;如传感器、…
阅读更多...
vue3.0学习笔记（二）——生命周期与响应式数据（ref,reactive,toRef,toRefs函数）

vue3.0学习笔记（二）——生命周期与响应式数据（ref,reactive,toRef,toRefs函数）

1. 组合API-setup函数 使用细节&#xff1a; setup 是一个新的组件选项&#xff0c;作为组件中使用组合API的起点。从组件生命周期来看&#xff0c;它的执行在组件实例创建之前vue2.x的beforeCreate执行。这就意味着在setup函数中 this 还不是组件实例&#xff0c;this 此时是…
阅读更多...
SpringBoot 实现图形验证码

SpringBoot 实现图形验证码

一、最终结果展示 二、前端代码 2.1 index.html <!DOCTYPE html> <html lang"en"><head><meta charset"utf-8"><title>验证码</title><style>#inputCaptcha {height: 30px;vertical-align: middle;}#verifica…
阅读更多...
交易积累-BR

交易积累-BR

BR指标&#xff0c;全称是“买卖意愿比率”&#xff08;Bull/Bear Ratio&#xff09;&#xff0c;是一个衡量市场买卖力量对比的技术分析工具。BR指标是由中国的技术分析师发展起来的&#xff0c;它通过比较股票或市场在一定时间内的上涨能量与下跌能量来评估市场情绪和潜在的趋…
阅读更多...
【AI大模型】使用AI大模型进行企业数据分析与决策支持

【AI大模型】使用AI大模型进行企业数据分析与决策支持

前言 ChatGPT4相比于ChatGPT3.5,有着诸多不可比拟的优势&#xff0c;比如图片生成、图片内容解析、GPTS开发、更智能的语言理解能力等&#xff0c;但是在国内使用GPT4存在网络及充值障碍等问题&#xff0c;如果您对ChatGPT4.0感兴趣&#xff0c;可以私信博主为您解决账号和环境…
阅读更多...
自动驾驶（八十八）---------通讯之SOMEIP

自动驾驶（八十八）---------通讯之SOMEIP

1. 什么是SOME/IP 服务导向架构&#xff08;SOA&#xff0c;Service-Oriented Architecture&#xff09;是一种设计软件系统的方法&#xff0c;强调通过可重用的服务来实现系统的松散耦合。每个服务是独立的功能单元&#xff0c;可以被不同的应用程序使用。这些服务通过标准化的…
阅读更多...
【Vue】vue两个核心功能声明式渲染_响应式

【Vue】vue两个核心功能声明式渲染_响应式

1、简介 Vue.js 是一个渐进式JavaScript框架&#xff0c;用于构建用户界面。它以其易用性、灵活性和高效性而闻名。Vue 的两个核心功能是声明式渲染和响应式系统&#xff0c;这两个功能共同为开发者提供了强大的工具来构建动态且响应式的Web应用。 2、声明式渲染 2.1简介 声…
阅读更多...
【教程】Node.js+Apache 部署网页全过程（非常详细！）

【教程】Node.js+Apache 部署网页全过程（非常详细！）

文章目录 背景0. 前置假设1. 更新系统和安装必要软件2. 打包并上传项目到服务器2.1 识别需要上传的文件2.2 文件归档和压缩2.3 压缩文件上传到服务器2.4 解压文件 3. 配置Node.js应用3.1 启动 PM23.2 确认 PM2 进程 4. 配置Apache反向代理5. 启用必要的Apache模块6. 检查 Apach…
阅读更多...
linux如何卸载python3.5

linux如何卸载python3.5

卸载&#xff1a; 1、卸载python3.5 sudo apt-get remove python3.5 2、卸载python3.5及其依赖 sudo apt-get remove --auto-remove python3.5 3、清除python3.5 sudo apt-get purge python3.5 或者 sudo apt-get purge --auto-remove python3.5
阅读更多...
异步爬虫基础

异步爬虫基础

我们知道爬虫是 IO 密集型任务&#xff0c; 例如使用 requests 库来爬取某个站点&#xff0c;当发出一个请求后&#xff0c; 程序必须等待网站返回响应&#xff0c; 才能接着运行&#xff0c; 而在等待过程中&#xff0c;整个爬虫程序是一直在等待的。 协程的基本原理 案例的…
阅读更多...
AI发展下的伦理挑战：构建未来科技的道德框架

AI发展下的伦理挑战：构建未来科技的道德框架

一、引言 随着人工智能&#xff08;AI&#xff09;技术的飞速发展&#xff0c;我们正处在一个前所未有的科技变革时代。AI不仅在医疗、教育、金融、交通等领域展现出巨大的应用潜力&#xff0c;也在日常生活中扮演着越来越重要的角色。然而&#xff0c;这一技术的迅猛进步也带来…
阅读更多...
【OpenCV C++20 学习笔记】操作图片

【OpenCV C++20 学习笔记】操作图片

操作图片 概述图片的导入和保存对导入的图片的操作获取像素值Point类型和图片像素 内存管理和引用计数一些简便操作图片可视化更精确的类型转换 概述 在本专栏的第一篇文章中就介绍了一个用OpenCV处理图片的实例&#xff08;《图片处理基础》&#xff09;&#xff0c;这篇文章…
阅读更多...
最新文章

Copyright @ 2022~2023