使用Java自制一个一个Nacos

public class ClientBody
{
    private static final long serialVersionUID=1L;

    /** 自增id */
    private Long id;

    /** 项目名 */
    private String projectName;
    
    /** 端口 */
    private String port;
    
    /** 健康检测回调接口 */
    private String CallbackInterface;

    /** 内网ip */
    private String inNetIp;

    /** 外网ip */
    private String outNetIp;

    /** 注册时间 */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date regSerTime;

    /** 0-健康 1-异常 2-死亡 */
    private String serType;

    /** 异常时间 */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date exceptTime;

    /** 死亡时间 */
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date deathTime;

    /** 检测次数 */
    private Long checkNum;

    /** 异常次数 */
    private Long exceNum;
}

/**
 * 令牌自定义标识
 */
@Value("${token.header}")
private String header;

/**
 * 服务注册
 */
@PostMapping("/serviceRegistration")
public Boolean add(HttpServletRequest request, @RequestBody ClientBody clientBody){
    /**
     * 获取token
     */
    String token = request.getHeader("header");
    /**
     * 验证请求合法性
     */
    Boolean isLegal = SecurityUtils.verLegal(token);
    if(isLegal){
        /**
         * 检测 serType!=2 端口+内网地址
         */
        ClientBody client = clientBodyService.checkClient(clientBody);
        if(ObjectUtils.isNotEmpty(client)){
            /**
             * 说明是在心跳检测期间重新启动。
             * 注销这台实例.
             *
             * Mysql client 这条数据
             * deathTime 改为现在时间
             * serType 改为 2
             *
             * Redis 直接删除这个数据id 为 Key的数据
             * 直接删除这台实例
             */
            clientBodyService.logoutCient(client);
            /**
             * redis 和 Mysql 中新增一台实例
             * regSerTime 现在时间
             * serType 为 0
             */
            clientBodyService.insert(clientBody);
        }else{
            /**
             * 启动了一台实例
             */
            clientBodyService.insert(clientBody);
        }

        return true;

    }else{
        return false;
    }
}

/**
 * 60秒定时健康检测
 */
@Scheduled(cron = "0/60 * * * * ?")
public void heartbeatCheck(){
    /**
     * 查询 serType = 0 健康的 实例List
     */
    List<ClientBody> clientBodyList = clientBodyService.selectOnlineServer();
    for (ClientBody clientBody : clientBodyList) {
        //回调接口
        String CallbackInterface = clientBody.getCallbackInterface();
        //内网地址
        String inNetIp = clientBody.getInNetIp();
        //拿到端口号
        String port = clientBody.getPort();
        
        //发送http请求 true为正常 false为异常
        Boolean state = HttpUtils.sendHead(CallbackInterface,inNetIp,port);

        if(state){
            //检测次数 + 1(checkNum + 1)
            clientBodyService.updateCientNormal(clientBody);
        }else{
            /**
             * 检测ping不通原因可能时网络波动
             * 检测十次 都是异常 才判定死亡
             */
            if(clientBody.getCheckNum() > 10){
                //修改这条数据为死亡 (serType = 2)
                clientBodyService.updateCientDeath(clientBody);
            }else{
                //修改这条数据为异常,然后检测次数 + 1,异常次数 + 1,异常时间[现在时间字符串拼接在原有数据之后](serType = 1;checkNum + 1;exceNum + 1;)
                clientBodyService.updateCientException(clientBody);
            }
        }
    }
}

/**
 * 注册
 * @PostConstruct 解释：在项目启动时加载数据
 */
@PostConstruct
public void registerService(){
    HashMap<String, Object> map = new HashMap<String,Object>(){{
        //项目名
        put("projectName",MyConfig.getName());
        //我注册选择内网地址，这个可以根据自己项目的实际情况选用。
        put("inNetIp", MyConfig.getUrl());
        //回调接口，这个接口就是下边的健康检测接口
        put("CallbackInterface", "/checkHealthy");
        //项目端口号
        put("port", MyConfig.getPort());
    }};

    AjaxResult ajaxResult = HttpUtils.sendPostRequest('注册与配置中心url', "/serviceRegistration", map);
}

/**
 * 健康检测接口
 */
@RequestMapping(value = "/CallbackInterface",method = RequestMethod.HEAD)
public void healthyByHead(HttpServletResponse response) {
    response.setHeader("data","200");
}

public class ConfigData
{
    private static final long serialVersionUID=1L;

    /** id */
    private Long id;

    /** key */
    private String key;

    /** value */
    private String value;

    /** tag */
    private String tag;

    /** remark */
    private String remark;
}

@GetMapping("/getConfigDataByTag")
public List<Map<String, String>> getConfig(@RequestParam String tag) throws JsonProcessingException {
    Map<String, String> configData = configDataService.selectconfigDataList(new configData(tag));
    return list;
}

public class ServerConfigProcessor implements EnvironmentPostProcessor {
    
    private static final String PROPERTY_SOURCE_NAME = "databaseProperties";

    @Override
    public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) {
        log.info("ServerConfig loading start");
        Map<String, Object> propertySource = new HashMap<>();

        try {
            /**
             * 拉取配置
             * MyConfig.ServerConfigHttpUrl 服务端url
             * MyConfig.ServerConfigInterface 服务端接口
             * MyConfig.MyServerTag 本服务标识（用来判断拉取的配置条件）
             */
            Map<String, Object> configSource = HttpUtils.sendGet(MyConfig.ServerConfigHttpUrl,MyConfig.ServerConfigInterface,MyConfig.MyServerTag);

            propertySource.putAll(configSource);

            environment.getPropertySources().addFirst(new MapPropertySource(PROPERTY_SOURCE_NAME, propertySource));

            log.info("ServerConfig loading Success");

        } catch (Throwable e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
}