服务发现任务图

NacosWatch

这个就不多说了，SmartLifecycle这个已经很熟悉了吧，调用start，里面开启任务，30秒一次，发送HeartbeatEvent，不过貌似现在没有监听器监听。

BeatTask心跳任务

服务注册默认是临时结点，所以要有心跳。

其实就是发送心跳到/nacos/v1/ns/instance/beat，然后根据返回的信息设置属性，如果是没找到就注册服务。默认第一次是非轻量级的心跳，会发body的，body就是一堆服务信息的url编码的字符串，后面就不需要了，默认间隔5秒。

            @Override
            public void run() {
                if (beatInfo.isStopped()) {
                    return;
                }
                long nextTime = beatInfo.getPeriod();
                try {
                	//直接http调用，如果是轻量级的心跳没有body，否则会带body
                    JSONObject result = serverProxy.sendBeat(beatInfo, BeatReactor.this.lightBeatEnabled);
                    long interval = result.getIntValue("clientBeatInterval");//心跳间隔
                    boolean lightBeatEnabled = false;
                    //根据服务端发开的是否要进行轻量级心跳进行改变
                    if (result.containsKey(CommonParams.LIGHT_BEAT_ENABLED)) {
                        lightBeatEnabled = result.getBooleanValue(CommonParams.LIGHT_BEAT_ENABLED);
                    }
                    BeatReactor.this.lightBeatEnabled = lightBeatEnabled;
                    if (interval > 0) {
                        nextTime = interval;
                    }
                    int code = NamingResponseCode.OK;
                    if (result.containsKey(CommonParams.CODE)) {
                        code = result.getIntValue(CommonParams.CODE);
                    }
                    //如果不存在，就注册
                    if (code == NamingResponseCode.RESOURCE_NOT_FOUND) {
                        Instance instance = new Instance();
                        instance.setPort(beatInfo.getPort());
                        instance.setIp(beatInfo.getIp());
                        instance.setWeight(beatInfo.getWeight());
                        instance.setMetadata(beatInfo.getMetadata());
                        instance.setClusterName(beatInfo.getCluster());
                        instance.setServiceName(beatInfo.getServiceName());
                        instance.setInstanceId(instance.getInstanceId());
                        instance.setEphemeral(true);
                        try {
                            serverProxy.registerService(beatInfo.getServiceName(),
                                NamingUtils.getGroupName(beatInfo.getServiceName()), instance);
                        } catch (Exception ignore) {
                        }
                    }
                } catch (NacosException ne) {
                    NAMING_LOGGER.error("[CLIENT-BEAT] failed to send beat: {}, code: {}, msg: {}",
                        JSON.toJSONString(beatInfo), ne.getErrCode(), ne.getErrMsg());
    
                }
                //根据间隔进行下一次调用
                executorService.schedule(new BeatTask(beatInfo), nextTime, TimeUnit.MILLISECONDS);
            }

securityProxy.login(getServerList());安全验证

这个以前说过，就是安全验证的，没用户名密码就直接返回了。

        public boolean login(List<String> servers) {
    
            try {//没超时直接返回
                if ((System.currentTimeMillis() - lastRefreshTime) < TimeUnit.SECONDS.toMillis(tokenTtl - tokenRefreshWindow)) {
                    return true;
                }
    
                for (String server : servers) {
                    if (login(server)) {//登录和计时
                        lastRefreshTime = System.currentTimeMillis();
                        return true;
                    }
                }
            } catch (Throwable ignore) {
            }
    
            return false;
        }

还有其他任务下次讲。

好了，今天就到这里了，希望对学习理解有帮助，大神看见勿喷，仅为自己的学习理解，能力有限，请多包涵。

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

• 大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
• 原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
• 持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
• 覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
• 不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
• 宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
• 宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
• 宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】 即可免费领取。