简单读取nacos配置,服务注册,订阅的代码

2024-08-29 00:28

本文主要是介绍简单读取nacos配置,服务注册,订阅的代码,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

以下配置文件具体可以看nacos 动态读取nacos配置中心项目配置这篇博客中的配置文件(配置文件是统一用的)
简单读取nacos配置中心配置:

package com.richfit.richfit.controller.nacos;import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.annotation.NacosValue;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.Properties;
import java.util.concurrent.Executor;@RestController
@RequestMapping("/nacos")
public class nacosController {//使用@nacosValue注解获取值,并开启自动更新@NacosValue(value = "${spring.datasource.password}", autoRefreshed = true)private String urlheadAutoRefresh;/*** @NacosValue注解,这种的不能实时读取更新nacos中修改的配置,除非重启项目或者重启nacos。下面这个方法就可以实时更新返回* @return*/@GetMapping("getNacosValue1")public String getValue1(){return "getNacosValue1:"+urlheadAutoRefresh;//输出:getNacosValue1:hlr2261226HLR}@Value("${spring.application.name}")private String name;@Value("${spring.cloud.nacos.config.file-extension}")private String extension;@Value("${spring.cloud.nacos.config.group}")private String group;@Value("${spring.cloud.nacos.config.namespace}")private String namespace;@Value("${spring.cloud.nacos.config.username}")private String username;@Value("${spring.cloud.nacos.config.password}")private String password;/**** @return* @throws NacosException* @throws InterruptedException*/@GetMapping("getNacosValue")public String getValue() throws NacosException, InterruptedException {String dataId = name + "."+extension;Properties properties = new Properties();properties.put(PropertyKeyConst.SERVER_ADDR, "localhost");//这一定是命名空间id不能是名称properties.put(PropertyKeyConst.NAMESPACE, namespace);properties.put(PropertyKeyConst.USERNAME, username);properties.put(PropertyKeyConst.PASSWORD, password);properties.put(PropertyKeyConst.SERVER_NAME,name);ConfigService configService = NacosFactory.createConfigService(properties);System.out.println("是否已经连接服务:"+configService.getServerStatus());//是否已经连接服务:UP 代表已连接if ("UP".equalsIgnoreCase(configService.getServerStatus())) {System.out.println("Nacos服务状态正常,服务可用。");// 进行其他业务逻辑处理} else {System.out.println("Nacos服务状态异常,服务不可用。");// 进行错误处理或重试逻辑}String content = configService.getConfig(dataId, group, 5000);System.out.println(content);//下面为监听器,只要客户端中配置改了,下面的addListener就会触发configService.addListener(dataId, group, new Listener() {@Overridepublic void receiveConfigInfo(String configInfo) {System.out.println("receive:" + configInfo);}@Overridepublic Executor getExecutor() {return null;}});//content 是 配置的内容,配置后在发布
//        boolean isPublishOk = configService.publishConfig(dataId, group, "脸脸真可爱,悦悦很可爱,妞妞太可爱");
//        System.out.println(isPublishOk);
//
//        Thread.sleep(3000);
//        //配置完后在获取
//        content = configService.getConfig(dataId, group, 5000);
//        System.out.println(content);return content;}
}

@NacosValue 读取客户端配置的关键注解

简单读取nacos服务注册和订阅:

package com.richfit.richfit.controller.nacos;import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.listener.Event;
import com.alibaba.nacos.api.naming.listener.EventListener;
import com.alibaba.nacos.api.naming.listener.NamingEvent;
import com.alibaba.nacos.api.naming.pojo.Instance;
import com.alibaba.nacos.api.naming.pojo.ServiceInfo;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Properties;/*** 获取nacos上的服务列表** Nacos为服务注册与发现提供了一个SDK类 NamingService,* 通过该类,可以实现服务的注册与发现、订阅服务的动态变化、* 获取服务实例、获取注册中心的健康状态等等** <dependency>*     <groupId>com.alibaba.nacos</groupId>*     <artifactId>nacos-client</artifactId>*     <version>1.4.2</version>* </dependency>** namingService.registerInstance():注册实例* namingService.deregisterInstance():取消注册* namingService.getAllInstances(String serviceName):获取服务的所有实例* namingService.getServicesOfServer(int pageNo, int pageSize):分页查询,从服务器获取所有服务名称* namingService.getSubscribeServices():获取当前客户端所有订阅的服务* namingService.selectInstances():根据条件获取服务实例* namingService.selectOneHealthyInstance():根据条件选择一个健康的实例* namingService.subscribe():订阅服务以接收实例更改事件* namingService.unsubscribe():取消订阅* namingService.getServerStatus():获取服务器健康状态*/
@RestController
@RequestMapping("/nacosClient")
public class NacosClient {@Value("${spring.application.name}")private String name;@Value("${spring.cloud.nacos.config.file-extension}")private String extension;@Value("${spring.cloud.nacos.config.group}")private String group;@Value("${spring.cloud.nacos.config.namespace}")private String namespace;@Value("${spring.cloud.nacos.config.username}")private String username;@Value("${spring.cloud.nacos.config.password}")private String password;/**** @return* @throws NacosException* @throws InterruptedException*/@GetMapping("getNacosFuwu")public String getNacosFuwu(){try {Properties properties = new Properties();properties.put(PropertyKeyConst.SERVER_ADDR, "localhost:8848");//这一定是命名空间id不能是名称properties.put(PropertyKeyConst.NAMESPACE, namespace);properties.put(PropertyKeyConst.USERNAME, username);properties.put(PropertyKeyConst.PASSWORD, password);// 服务名String serviceName = "richfit.properties";//properties.put(PropertyKeyConst.SERVER_NAME, serviceName);NamingService namingService = NacosFactory.createNamingService(properties);//获取服务器健康状态String serverStatus = namingService.getServerStatus();System.out.println("服务器健康状态:"+serverStatus);//服务注册namingService.registerInstance(serviceName, "192.168.1.101:", 8888, "richfit-TEST");//使用namingService获取服务列表List<Instance> instances = namingService.getAllInstances(serviceName);// 输出服务列表for (Instance instance : instances) {System.out.println("IP: " + instance.getIp());System.out.println("Port: " + instance.getPort());//是否健康System.out.println("Healthy: " + instance.isHealthy());//Healthy: true//节点是否存在System.out.println("Enabled: " + instance.isEnabled());System.out.println("Weight: " + instance.getWeight());//Weight: 1.0System.out.println("ClusterName: " + instance.getClusterName());//ClusterName: richfit-TESTSystem.out.println("InstanceId: " + instance.getInstanceId());//InstanceId: 192.168.1.101:#8888#richfit-TEST#DEFAULT_GROUP@@richfit.propertiesSystem.out.println("------------------------");}//订阅服务以接收实例更改事件namingService.subscribe("richfit.properties", new EventListener() {@Overridepublic void onEvent(Event event) {
//                    int removeSize = ((NamingChangeEvent) event).instancesDiff.removedInstances.size();
//                    int addSize = ((NamingChangeEvent) event).instancesDiff.addedInstances.size();
//                    if (removeSize > 0){
//                        System.out.println("已取消订阅的服务名:"+((NamingEvent)event).getServiceName());
//                    }
//                    if (addSize > 0){
//                        System.out.println("已新增订阅的服务名:"+((NamingEvent)event).getServiceName());
//                    }System.out.println("已订阅的实例:"+((NamingEvent)event).getInstances()+"个服务");}});//获取当前客户端所有订阅的服务。服务订阅之后,当客户端服务列表没有显示节点了,但是一段时间内订阅者列表节点不会消失List<ServiceInfo> subscribeServices = namingService.getSubscribeServices();//如果订阅的个数大于0if (subscribeServices.size() > 0){try {//取消服务注册namingService.deregisterInstance(serviceName, "192.168.1.101:", 8888, "richfit-TEST");} catch (NacosException e) {throw new RuntimeException(e);}}System.out.println("获取当前客户端所有订阅的服务个数:"+namingService.getSubscribeServices().size());} catch (Exception e) {e.printStackTrace();}return null;}}

这篇关于简单读取nacos配置,服务注册,订阅的代码的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1116314

相关文章

SpringBoot中四种AOP实战应用场景及代码实现

《SpringBoot中四种AOP实战应用场景及代码实现》面向切面编程(AOP)是Spring框架的核心功能之一,它通过预编译和运行期动态代理实现程序功能的统一维护,在SpringBoot应用中,AO... 目录引言场景一:日志记录与性能监控业务需求实现方案使用示例扩展:MDC实现请求跟踪场景二:权限控制与

Android开发环境配置避坑指南

《Android开发环境配置避坑指南》本文主要介绍了Android开发环境配置过程中遇到的问题及解决方案,包括VPN注意事项、工具版本统一、Gerrit邮箱配置、Git拉取和提交代码、MergevsR... 目录网络环境:VPN 注意事项工具版本统一:android Studio & JDKGerrit的邮

SpringBoot3.4配置校验新特性的用法详解

《SpringBoot3.4配置校验新特性的用法详解》SpringBoot3.4对配置校验支持进行了全面升级,这篇文章为大家详细介绍了一下它们的具体使用,文中的示例代码讲解详细,感兴趣的小伙伴可以参考... 目录基本用法示例定义配置类配置 application.yml注入使用嵌套对象与集合元素深度校验开发

IntelliJ IDEA 中配置 Spring MVC 环境的详细步骤及问题解决

《IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决》:本文主要介绍IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决,本文分步骤结合实例给大... 目录步骤 1:创建 Maven Web 项目步骤 2:添加 Spring MVC 依赖1、保存后执行2、将新的依赖

如何使用 Python 读取 Excel 数据

《如何使用Python读取Excel数据》:本文主要介绍使用Python读取Excel数据的详细教程,通过pandas和openpyxl,你可以轻松读取Excel文件,并进行各种数据处理操... 目录使用 python 读取 Excel 数据的详细教程1. 安装必要的依赖2. 读取 Excel 文件3. 读

利用Python调试串口的示例代码

《利用Python调试串口的示例代码》在嵌入式开发、物联网设备调试过程中,串口通信是最基础的调试手段本文将带你用Python+ttkbootstrap打造一款高颜值、多功能的串口调试助手,需要的可以了... 目录概述:为什么需要专业的串口调试工具项目架构设计1.1 技术栈选型1.2 关键类说明1.3 线程模

SpringBoot基于配置实现短信服务策略的动态切换

《SpringBoot基于配置实现短信服务策略的动态切换》这篇文章主要为大家详细介绍了SpringBoot在接入多个短信服务商(如阿里云、腾讯云、华为云)后,如何根据配置或环境切换使用不同的服务商,需... 目录目标功能示例配置(application.yml)配置类绑定短信发送策略接口示例:阿里云 & 腾

Python Transformers库(NLP处理库)案例代码讲解

《PythonTransformers库(NLP处理库)案例代码讲解》本文介绍transformers库的全面讲解,包含基础知识、高级用法、案例代码及学习路径,内容经过组织,适合不同阶段的学习者,对... 目录一、基础知识1. Transformers 库简介2. 安装与环境配置3. 快速上手示例二、核心模

Spring Boot读取配置文件的五种方式小结

《SpringBoot读取配置文件的五种方式小结》SpringBoot提供了灵活多样的方式来读取配置文件,这篇文章为大家介绍了5种常见的读取方式,文中的示例代码简洁易懂,大家可以根据自己的需要进... 目录1. 配置文件位置与加载顺序2. 读取配置文件的方式汇总方式一:使用 @Value 注解读取配置方式二

如何为Yarn配置国内源的详细教程

《如何为Yarn配置国内源的详细教程》在使用Yarn进行项目开发时,由于网络原因,直接使用官方源可能会导致下载速度慢或连接失败,配置国内源可以显著提高包的下载速度和稳定性,本文将详细介绍如何为Yarn... 目录一、查询当前使用的镜像源二、设置国内源1. 设置为淘宝镜像源2. 设置为其他国内源三、还原为官方