commit
689e89a9b2
|
@ -145,6 +145,8 @@ public class FileCacheQueueScheduler extends DuplicateRemovedScheduler implement
|
||||||
if (!inited.get()) {
|
if (!inited.get()) {
|
||||||
init(task);
|
init(task);
|
||||||
}
|
}
|
||||||
|
if(urls.contains(request.getUrl())) //已存在此URL 表示已抓取过 跳过
|
||||||
|
return;
|
||||||
queue.add(request);
|
queue.add(request);
|
||||||
fileUrlWriter.println(request.getUrl());
|
fileUrlWriter.println(request.getUrl());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue