ClientLongPolling的run

然后你会发现，又是一个调度任务，延迟时间29.5秒，就是最少挂起时间。然后会将对象放进监听集合里。

当挂起时间过后，开始处理，因为不是固定轮询的，所以直接响应：

把轮询任务给取消了，然后生成响应。

如果不是固定轮询的，就直接返回了，因为在这个任务之前已经判断过没有改变，才会挂起，为了有改变的时候直接响应。如果是固定的，生成响应的时候会去比对MD5，然后把写回：

监听后台配置修改

LongPollingService是个监听器，他会监听配置数据改动事件。

一旦有数据变动会开启一个DataChangeTask任务，里面就是做立即响应的：

DataChangeTask的run

遍历所有有订阅的ClientLongPolling，然后封装好有变化的配置，直接响应。

    class DataChangeTask implements Runnable {
            @Override
            public void run() {
                try {
                    ConfigService.getContentBetaMd5(groupKey);
                    //遍历所有的订阅ClientLongPolling
                    for (Iterator<ClientLongPolling> iter = allSubs.iterator(); iter.hasNext(); ) {
                        ClientLongPolling clientSub = iter.next();
                        if (clientSub.clientMd5Map.containsKey(groupKey)) {
                            // 如果beta发布且不在beta列表直接跳过
                            if (isBeta && !betaIps.contains(clientSub.ip)) {
                                continue;
                            }
    
                            // 如果tag发布且不在tag列表直接跳过
                            if (StringUtils.isNotBlank(tag) && !tag.equals(clientSub.tag)) {
                                continue;
                            }
    
                            getRetainIps().put(clientSub.ip, System.currentTimeMillis());
                            iter.remove(); // 删除订阅关系
                            LogUtil.clientLog.info("{}|{}|{}|{}|{}|{}|{}",
                                (System.currentTimeMillis() - changeTime),
                                "in-advance",
                                RequestUtil.getRemoteIp((HttpServletRequest)clientSub.asyncContext.getRequest()),
                                "polling",
                                clientSub.clientMd5Map.size(), clientSub.probeRequestSize, groupKey);
                             //立即返回
                            clientSub.sendResponse(Arrays.asList(groupKey));
                        }
                    }
                } catch (Throwable t) {
                    LogUtil.defaultLog.error("data change error:" + t.getMessage(), t.getCause());
                }
            }

又到这里，取消轮询任务，这回是有changedGroups内容的：

然后响应。

这样终于知道为什么监听的长轮询有时候挂起好久，有时候直接返回，为什么改了后台配置后挂起的会立即返回，这种设计方式避免了无效的轮询，节省了网络开销，而且如果有改变也可以立即结束挂起，返回改变的配置。

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

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] ，回复【面试题】即可免费领取。

阅读全文

Spring Cloud 2.2.2 源码之旅

Spring Cloud 2.2.2 源码之五十二nacos服务端处理监听配置请求二

ClientLongPolling的run

监听后台配置修改

DataChangeTask的run