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内容的：

然后响应。

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

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