【Nacos系列第三篇】- Nacos之Spring Boot Config

作者:毕来生

微信:878799579

前言

​ 个人比较看好Spring Cloud Alibaba家族。此系列以Nacos为主题,从Spring、Spring boot、Spring Cloud多个方面逐步进行演示,源码解读。目前来看官方文档还有待完善。网络上除了官网外缺少Nacos系列文章。都是零零散散的知识点。如此系列文章哪里写的有不周全,错误之处。欢迎大家指正。谢谢。

​ 因公众号排版问题,可能会有代码显示不完整,请使用电脑版微信内置浏览器/复制链接到浏览器中。

​ 第一篇 : 【Nacos系列第一篇】-Nacos之Spring Discovery 以及Config

​ 第二篇 : 【Nacos系列第二篇】-Nacos之Spring Boot Discovery。

​ 因大家在工作中逐步以Spring boot、Spring Cloud为主进行开发。我们接下来会以这两个为核心演示详解。


Nacos架构图

【Nacos系列第三篇】- Nacos之Spring Boot Config

工程结构

上面说了那么多,现在先来看一下我们的Spring boot Nacos config工程结构(Windows下演示)

Spring Boot版本:2.1.2.RELEASE

【Nacos系列第三篇】- Nacos之Spring Boot Config

准备工作

1、启动Nacos(Demo演示环境为Windows下)

2、访问http://127.0.0.1:8848/nacos/index.html#/configurationManagement?dataId=&group=&appName=&namespace= 进入Nacos配置管理页面

3、点击左侧配置管理->配置列表(右侧有一个加号。添加对应信息),如下图

【Nacos系列第三篇】- Nacos之Spring Boot Config

【Nacos系列第三篇】- Nacos之Spring Boot Config

以上就是我们要做的准备工作啦。


代码演示

附上与普通创建的Spring boot工程不同点

ConfigController(新增)

package org.nacos.springboot.controller;

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.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.Executor;

/**
 * @author bilaisheng
 * @wechat: 878799579
 * @date 2019/01/15 19:34
 * @description  Test Nacos Config
 */
@Controller
@RequestMapping("config")
public class ConfigController {

	/**
	 * @author : bilaisheng
	 * @wechat: 878799579
	 * @date : 2019/01/15 19:45
	 * @return Map
	 * @throws NacosException
	 * @throws InterruptedException
	 */
	@ResponseBody
	@RequestMapping("/get")
	public Map getConfig() throws NacosException, InterruptedException {
		// 用以演示用,页面返回数据展示
		Map map = new HashMap();
		//  服务地址。本机演示故写localhost。请根据实际情况替换对应IP
		String serverAddr = "localhost";
		String dataId = "nacos-spring";
		String group = "bilaisheng";
		Properties properties = new Properties();
		properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
		// 创建ConfigService,此处通过Properties方式进行创建,另一种演示serviceaddr获取configService.
		// 原理上都是通过 ConfigFactory.createConfigService()去进行创建
		ConfigService configService = NacosFactory.createConfigService(properties);
		// ConfigService configService = NacosFactory.createConfigService(serverAddr);

		String content = configService.getConfig(dataId, group, 5000);
		System.out.println("config : " + content);
		map.put("content", content);
		// 添加Listener,用以演示receive获取数据结果
		configService.addListener(dataId, group, new Listener() {
			@Override
			public void receiveConfigInfo(String configInfo) {
				System.out.println("recieve : " + configInfo);
			}
			@Override
			public Executor getExecutor() {
				return null;
			}
		});

		// 推送config。将原有dataid中信息替换。
		boolean isPublishOk = configService.publishConfig(dataId, group, "publish config content");
		System.out.println("isPublishOk : " + isPublishOk);
		map.put("isPublishOk", isPublishOk);

		Thread.sleep(3000);
		content = configService.getConfig(dataId, group, 5000);
		System.out.println("Thread sleep 3000ms : " + content);
		map.put("Thread sleep 3000ms : ", content);

		// 删除指定dataid , group 配置
		boolean isRemoveOk = configService.removeConfig(dataId, group);
		System.out.println("remove " + dataId + "config is " + isRemoveOk);
		Thread.sleep(3000);

		content = configService.getConfig(dataId, group, 5000);
		System.out.println("content after 5000ms "+content);
		Thread.sleep(3000);
		return map;
	}
}

application.properties

nacos.config.server-addr=127.0.0.1:8848

pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>com.alibaba.boot</groupId>
    <artifactId>nacos-config-spring-boot-starter</artifactId>
    <version>0.2.1</version>
</dependency>

上述内容就是我们在创建好Spring Boot工程结构后增加/调整内容。

演示步骤

1、启动 BilaishengNacosSpringbootConfigApplication

2、调用 http://localhost:8080/config/get,此时控制台出现

【Nacos系列第三篇】- Nacos之Spring Boot Config

页面出现

【Nacos系列第三篇】- Nacos之Spring Boot Config

以上就是我们Spring Boot Config的一个Demo例子


喜欢就关注我吧

【Nacos系列第三篇】- Nacos之Spring Boot Config