手动新建配置用于测试

首先,将待测试的配置内容填写到Nacos控制台中:
k1=v1 spring.datasource.username=ken spring.datasource.password=123456
点击“发布”按钮即可完成配置的创建与保存:

接着,切换到【示例代码】标签页,查看Java SDK如何获取与监听Nacos配置的示例代码:


通过curl命令访问Nacos配置
curl -X GET "https://223.2.35.53:8848/nacos/v1/cs/configs?dataId=test&group=DEFAULT_GROUP"
执行上述命令后,即可获取之前在Nacos中配置的内容。这表明服务端接口运行正常,能够正确响应配置查询请求。

工程示例:使用Java SDK获取Nacos配置
首先,创建一个Maven工程作为基础项目。
添加Nacos客户端依赖
在项目的pom.xml文件中引入以下依赖:
com.alibaba.nacos nacos-client 2.1.1
编写获取配置的Java代码
将官方示例代码简化后,得到如下实现:
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.PropertyKeyConst;
import ja va.util.Properties;
public class Main {
public static void main(String[] args) throws Exception {
String serverAddr = "localhost:8848";
String dataId = "test";
String group = "DEFAULT_GROUP";
Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
ConfigService configService = NacosFactory.createConfigService(properties);
String content = configService.getConfig(dataId, group, 2000);
System.out.println("SDK result: 'n" + content + "'");
}
}
直接运行该代码,会出现错误:缺少org.slf4j.LoggerFactory。此时无需担心,只需添加对应的日志依赖即可解决。
修改pom.xml引入SLF4J日志依赖
通过引入Spring Boot相关依赖,可以间接将日志框架带入项目:
4.0.0 org.example test-ja va 1.0-SNAPSHOT spring-boot-parent org.springframework.boot 2.6.5 8 8 org.springframework.boot spring-boot-starter-web com.alibaba.nacos nacos-client 2.1.1
获取到的Nacos配置信息为null的解决方法
方案一:降低Nacos客户端版本
使用nacos-client 2.1.1运行时,获取到的配置内容为null。这通常是版本兼容性问题导致的。一个简单的解决方案是将nacos-client版本降级到1.4.4。
方案二:Docker部署Nacos时暴露gRPC端口
如果采用Docker方式启动Nacos服务,需要额外映射两个端口:
-p 9848:9848 # 关键:暴露 gRPC 客户端端口 -p 9849:9849 # 关键:暴露 gRPC 服务端端口

完成端口映射后,即可正常使用Nacos 2.x的新特性,例如配置监听、长连接等。
成功获取配置信息
任选上述方案之一进行修复,重新运行Java代码,即可成功获取到Nacos中的配置内容:

工程示例:监听Nacos配置的变化
在上一工程的基础上,修改Java代码,增加配置监听器功能:
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.listener.Listener;
import ja va.util.Properties;
import ja va.util.concurrent.Executor;
public class Main {
public static void main(String[] args) throws Exception {
String serverAddr = "localhost:8848";
String dataId = "test";
String group = "DEFAULT_GROUP";
Properties properties = new Properties();
properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
ConfigService configService = NacosFactory.createConfigService(properties);
String content = configService.getConfig(dataId, group, 2000);
System.out.println("SDK result: 'n" + content + "'");
// 注册配置变化监听器
configService.addListener(dataId, group, new Listener() {
@Override
public Executor getExecutor() {
return null;
}
@Override
public void receiveConfigInfo(String s) {
System.out.println("receiveConfigInfo");
System.out.println(s);
}
});
System.in.read(); // 防止程序退出,保持监听状态
}
}
随后,在Nacos服务端修改配置并重新发布。客户端将自动感知到配置变化,并打印出最新的配置内容。
