类 RAMRecorder
- java.lang.Object
-
- xin.jiangqiang.core.recoder.AbstractRecorder
-
- xin.jiangqiang.core.recoder.RAMRecorder
-
- 所有已实现的接口:
Recorder
public class RAMRecorder extends AbstractRecorder
内存记录器,存储统计各个阶段的爬虫 此类所有方法同步,是限制并发的主要因素
-
-
字段概要
-
从类继承的字段 xin.jiangqiang.core.recoder.AbstractRecorder
config
-
-
构造器概要
构造器 构造器 说明 RAMRecorder()
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 voidadd(Crawler crawler)写集合crawlersSet 不能添加重复的爬虫voidaddAll(List<Crawler> crawlers)写集合crawlersSet 不能添加重复的爬虫voidaddErr(Crawler crawler)写集合errCrawlers tmpCrawlersSet 成功或失败后移除正在爬取列表中的对应爬虫voidaddSucc(Crawler crawler)写集合succCrawlers tmpCrawlersSet 成功或失败后移除正在爬取列表中的对应爬虫Integercount()IntegercountErr()IntegercountSucc()Booleanexist(Crawler crawler)是否已经存在此爬虫URLList<Crawler>getAll()查询所有未爬取的爬虫List<Crawler>getErr()查询爬取失败的CrawlergetOne()读集合crawlersSet 写集合tmpCrawlersSet 获取的同时需要删除存储的该爬虫实例(保证下一个线程不会取到同一个)List<Crawler>getSucc()查询爬取成功的voidinitBeforeStart()写集合crawlersListvoidsaveBeforeEnd()读集合crawlersList
-
-
-
方法详细资料
-
add
public void add(Crawler crawler)
写集合crawlersSet 不能添加重复的爬虫- 指定者:
add在接口中Recorder- 覆盖:
add在类中AbstractRecorder- 参数:
crawler- 需要存储的爬虫
-
addAll
public void addAll(List<Crawler> crawlers)
写集合crawlersSet 不能添加重复的爬虫- 指定者:
addAll在接口中Recorder- 覆盖:
addAll在类中AbstractRecorder- 参数:
crawlers- 需要存储的爬虫列表
-
getOne
public Crawler getOne()
读集合crawlersSet 写集合tmpCrawlersSet 获取的同时需要删除存储的该爬虫实例(保证下一个线程不会取到同一个)- 指定者:
getOne在接口中Recorder- 覆盖:
getOne在类中AbstractRecorder- 返回:
- 获取一个爬虫实例
-
addSucc
public void addSucc(Crawler crawler)
写集合succCrawlers tmpCrawlersSet 成功或失败后移除正在爬取列表中的对应爬虫- 指定者:
addSucc在接口中Recorder- 覆盖:
addSucc在类中AbstractRecorder- 参数:
crawler- 成功爬取的爬虫
-
addErr
public void addErr(Crawler crawler)
写集合errCrawlers tmpCrawlersSet 成功或失败后移除正在爬取列表中的对应爬虫- 指定者:
addErr在接口中Recorder- 覆盖:
addErr在类中AbstractRecorder- 参数:
crawler- 爬取失败的爬虫
-
count
public Integer count()
- 指定者:
count在接口中Recorder- 覆盖:
count在类中AbstractRecorder- 返回:
- 查询未爬取的种子条数
-
countSucc
public Integer countSucc()
- 指定者:
countSucc在接口中Recorder- 覆盖:
countSucc在类中AbstractRecorder- 返回:
- 查询成功条数
-
countErr
public Integer countErr()
- 指定者:
countErr在接口中Recorder- 覆盖:
countErr在类中AbstractRecorder- 返回:
- 查询失败条数
-
saveBeforeEnd
public void saveBeforeEnd()
读集合crawlersList- 指定者:
saveBeforeEnd在接口中Recorder- 覆盖:
saveBeforeEnd在类中AbstractRecorder
-
initBeforeStart
public void initBeforeStart()
写集合crawlersList- 指定者:
initBeforeStart在接口中Recorder- 覆盖:
initBeforeStart在类中AbstractRecorder
-
getAll
public List<Crawler> getAll()
从接口复制的说明:Recorder查询所有未爬取的爬虫- 指定者:
getAll在接口中Recorder- 覆盖:
getAll在类中AbstractRecorder
-
getSucc
public List<Crawler> getSucc()
从接口复制的说明:Recorder查询爬取成功的- 指定者:
getSucc在接口中Recorder- 覆盖:
getSucc在类中AbstractRecorder- 返回:
- 爬取成功的爬虫列表
-
getErr
public List<Crawler> getErr()
从接口复制的说明:Recorder查询爬取失败的- 指定者:
getErr在接口中Recorder- 覆盖:
getErr在类中AbstractRecorder- 返回:
- 爬取失败的爬虫列表
-
-