微服务——Nacos配置管理模型

1.如何在IDEA中启动Nacos？

2.Nacos配置中心宕机了，我们的服务还可以读取到配置信息吗？

可以从内存,客户端获取了配置中心的配置信息以后,会将配置信息在本地内存中存储一份
在本地中靠Map对象存储

2.1长轮询

客户端每隔30s向Nacos配置中心发起一次请求，拉取一次配置信息 wait29.5s
没有配置更新时，客户端会在Nacos服务端的队列中等待
每隔XX秒发送一次请求定时任务调度

2.2如何在Java中实现定时任务调度？ 2.2.1单线程执行定时任务调度

Timer对象（import java.util.Timer;）
创建对象时，会创建一个线程，并且为线程分配一个任务队列，顺序执行
TimerTask 任务执行对象

package com.jt.common.util;

import java.util.Timer;
import java.util.TimerTask;


public class TimerUtils {
    public static void main(String[] args) {
        //1.构建执行任务对象
        Timer timer=new Timer();
        //2.构建任务对象
        TimerTask task1=new TimerTask() {
            @Override
            public void run() {
                System.out.println(System.currentTimeMillis());
            }
        };
        //3.定时执行任务
        timer.schedule(task1, 1000, 1000);
    }
}

实现效果

结束任务

timer.cancle();

缺陷：不能并发执行，因为只有一个线程执行多次任务，谁先来谁先执行

2.2.2多线程执行定时任务

Timer ScheduledExecutorService 多线程的任务调度
实现代码

package com.jt.common.util;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;


public class ScheduledExecutorServiceUtils {

    public static void main(String[] args) {
        
        ScheduledExecutorService scheduledExecutorService =
                Executors.newScheduledThreadPool(5);
        
        Runnable runnable=new Runnable() {
            @Override
            public void run() {
                String tName=Thread.currentThread().getName();
                System.out.println(tName+"->"+System.currentTimeMillis());
            }
        };
        
        scheduledExecutorService.
                scheduleAtFixedRate(runnable,1000,//1s以后开始执行
                                                 1000,//每隔1s开始执行 与任务是否执行完毕无关
                                      TimeUnit.MILLISECONDS);//时间单位
    }
}

实现效果

3.Nacos的配置管理模型——命名空间

配置管理模型作用：区分配置、管理配置，通过Namespace、group、Data ID能够定位到一个配置集

3.1新建命名空间

3.2克隆配置中心

3.3修改dev的配置信息

3.4配置后端yml文件

server:
  port: 8082
spring:
  application:
    name: sca-provider
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 #假如nacos和你的服务在一台电脑上，默认服务本机，是可以省略的
      config:
        server-addr: localhost:8848 #配置中心的地址
        file-extension: yml #添加配置中心配置格式
        namespace: 1ec9fffa-c171-458d-815d-502a52daf446 #指定命名空间
logging:
  level:
    com.jt: debug #配置com.jt包以及子包中的日志级别 默认是info

public配置信息

dev配置信息

测试结果

说明读取的是指定命名空间的配置中心信息，也就是dev中的sca-provider名字的配置信息
若不指定命名空间，则默认为pubilic空间

4.Nacos的配置管理模型——分组设计 4.1新建分组配置

4.2配置分组id

4.3新建Controller层

package com.jt.provider.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RefreshScope
@RestController
public class ProviderCacheController {
    @Value("${useLocalCache:false}")
    private boolean useLocalCache;

    @RequestMapping("/provider/cache")
    public String doUseLocalCache(){
        return "useLocalCache'value is   "+useLocalCache;
    }
}

实现效果

ArrayList线程不安全
Vector线程安全但性能差悲观锁
CopyOnWriteArrayList（JDK1.5）保证集合的线程安全乐观锁
mysql 使用的是悲观锁

4.4双重校验锁机制

package com.jt.common.thread;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;

public class SyncTests {

    //private static List cache=new Vector<>();
    //CopyOnWriteArrayList是一个线程安全的List集合,允许多个线程执行并发更新,但是只能有一个更新成功.
    private static List cache=new CopyOnWriteArrayList<>();//CAS(比较和交换)

    //    public synchronized static List selectAll(){
//        if (cache.isEmpty()) {
//              System.out.println("Get Data From Database");
//              List data = Arrays.asList("A", "B", "C");
//              cache.addAll(data);
//        }
//        return cache;
//    }
    public static List selectAll(){
        if(cache.isEmpty()) {//A,B,C,D
            synchronized (cache) {
                if (cache.isEmpty()) {
                    System.out.println("Get Data From Database");
                    List data = Arrays.asList("A", "B", "C");
                    cache.addAll(data);
                }
            }
        }
        return cache;
    }

    public static void main(String[] args) {
        //System.out.println(Thread.currentThread().getName());
        Thread t1=new Thread(){
            @Override
            public void run() {
                System.out.println(selectAll());
            }
        };
        Thread t2=new Thread(){
            @Override
            public void run() {
                System.out.println(selectAll());
            }
        };
        Thread t3=new Thread(){
            @Override
            public void run() {
                System.out.println(selectAll());
            }
        };
        Thread t4=new Thread(){
            @Override
            public void run() {
                System.out.println(selectAll());
            }
        };
        Thread t5=new Thread(){
            @Override
            public void run() {
                System.out.println(selectAll());
            }
        };
        t1.start();
        t2.start();
        t3.start();
        t4.start();
        t5.start();
    }
}

package com.jt.provider.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;

@RefreshScope
@RestController
public class ProviderCacheController {

    @Value("${useLocalCache:false}")
    private boolean useLocalCache;

    @RequestMapping("/provider/cache")
    public String doUseLocalCache(){
        return "useLocalCache'value is   "+useLocalCache;
    }

    //构建一个本地(Local)缓存对象(基于jvm中的一个对象存储从数据库获取的数据).
    private List cache=new CopyOnWriteArrayList<>();
    @RequestMapping("/provider/cache02")
    public  List doUseLocalCache02(){
        if(!useLocalCache){
            System.out.println("==Get data from database==");
            List cates = Arrays.asList("Category-A", "Category-B", "Category-C");
        }
        if(cache.isEmpty()){
            synchronized (cache) {
                if (cache.isEmpty()) {//Thread-A,Thread-B,...
                    System.out.println("==Get data from database==");
                    //假设这部分分类信息是从数据库获取的,但是,我不希望每次获取分类信息都要从数据库查
                    List cates = Arrays.asList("Category-A", "Category-B", "Category-C");
                    cache.addAll(cates);
                }
            }
        }
        return cache;
    }//生产层面
}

配置中新为false

实现效果

redis分布式缓存
lruCache 本地缓存+分布式缓存

5.Nacos的配置管理模型——共享配置的读取 5.1新建配置

5.2修改配置文件

5.3新建Conreoller层

package com.jt.provider.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RefreshScope
public class ProviderSecretController {
    @Value("${app.secret:123456}")
    private String secret;
    @GetMapping("/provider/doGetSecret")
    public String doGetSecret(){
        return "the secret is"+secret;
    }
}

实现效果

总结

配置管理模型三要素：namespace（ group（ dataId
为什么会有共享配置？？？很多配置中有一些共性
如何理解命名空间？？？定义一些配置的作用域，做配置的分类管理
为什么进行分组？？？同一环境下不同活动会有不同配置
如何引用共享配置？？？使用shared-configs
线程安全问题前提：多个线程+有共享数据集+是否是原子操作
如何理解线程并发中的双重校验锁？？？性能+安全
CopyonWriteArrayList 线程安全

微服务——Nacos配置管理模型

Java相关栏目本月热门文章