Krawler is a web crawling framework written in Kotlin. It is heavily inspired by crawler4j by Yasser Ganjisaffar. The project is still very new, and those looking for a mature, well tested crawler framework should likely still use crawler4j. For those who can tolerate a bit of turbulence, Krawler should serve as a replacement for crawler4j with minimal modifications to exisiting applications.
Some neat features and benefits of Krawler include:
- Kotlin project!
- Krawler differentiates between a "check" and a "visit".
Checks are used to verify the status code of a resource by issuing an HTTP HEAD request rather than a GET request.
Each policy (get or check) can have it's own logic associated with it by implementing
either
shouldCheck
orshouldVisit
andcheck
andvisit
. - Krawler's politeness delay is per-host rather than global. This way servers aren't overwhelmed, but crawls visiting many hosts in parallel are not effectively serialized by the politeness delay.
- Krawler uses Jsoup for parsing HTML files while harvesting links, making it more tolerant of malformed or poorly written websites, and thus less likely to error out during a crawl. The original HTML of the page is still available to facilitate validation and checking though.
- Krawler collects full anchor tags including all attributes and anchor text.
- Krawler currently has no proxy support, but it is on the roadmap. :(
Krawler is published through jitpack.io at: https://jitpack.io/#brianmadden/krawler/ .
Add jitpack.io as a repository, and krawler as a compile time dependency to your build.gradle
to use Krawler in your project:
repositories {
jcenter()
maven { url "https://jitpack.io" }
}
dependencies {
compile 'com.github.brianmadden:krawler:0.4.1'
}
Using the Krawler framework is fairly simple. Minimally, there are two methods that must be overridden
in order to use the framework. Overriding the shouldVisit
method dictates what should be visited by
the crawler, and the visit
method dictates what happens once the page is visited. Overriding these
two methods is sufficient for creating your own crawler, however there are additional methods that
can be overridden to privde more robust behavior.
The full code for this simple example can also be found in the example project:
class SimpleExample(config: KrawlConfig = KrawlConfig()) : Krawler(config) {
private val FILTERS: Regex = Regex(".*(\\.(css|js|bmp|gif|jpe?g|png|tiff?|mid|mp2|mp3|mp4|wav|avi|" +
"mov|mpeg|ram|m4v|pdf|rm|smil|wmv|swf|wma|zip|rar|gz|tar|ico))$", RegexOption.IGNORE_CASE)
/**
* Threadsafe whitelist of acceptable hosts to visit
*/
val whitelist: MutableSet<String> = ConcurrentSkipListSet()
override fun shouldVisit(url: KrawlUrl): Boolean {
val withoutGetParams: String = url.canonicalForm.split("?").first()
return (!FILTERS.matches(withoutGetParams) && url.host in whitelist)
}
private val counter: AtomicInteger = AtomicInteger(0)
override fun visit(url: KrawlUrl, doc: KrawlDocument) {
println("${counter.incrementAndGet()}. Crawling ${url.canonicalForm}")
}
override fun onContentFetchError(url: KrawlUrl, reason: String) {
println("${counter.incrementAndGet()}. Tried to crawl ${url.canonicalForm} but failed to read the content.")
}
private var startTimestamp: Long = 0
private var endTimestamp: Long = 0
override fun onCrawlStart() {
startTimestamp = LocalTime.now().toNanoOfDay()
}
override fun onCrawlEnd() {
endTimestamp = LocalTime.now().toNanoOfDay()
println("Crawled $counter pages in ${(endTimestamp - startTimestamp) / 1000000000.0} seconds.")
}
}
- Proxy support
- Headless Chrome support for crawling Javascript driven sites
0.4.1 (2017-8-15)
- Removed logging implementation from dependencies to prevent logging conflicts when used as a library.
- Updated Kotlin version to 1.1.4
- Updated
kotlinx.coroutines
to .17
0.4.0 (2017-5-17)
-
Rewrote core crawl loop to use Kotlin 1.1 coroutines. This has effectively turned the crawl process into a multi-stage pipeline. This architecture change has removed the necessity for some locking by removing resource contention by multiple threads.
-
Updated the build file to build the simple example as a runnable jar
-
Minor bug fixes in the KrawlUrl class.
0.3.2 (2017-3-3)
-
Fixed a number of bugs that would result in a crashed thread, and subsequently an incorrect number of crawled pages as well as cause slowdowns due to a reduced number of worker threads.
-
Added a new utility function to wrap
doCrawl
and log any uncaught exceptions during crawling.
0.3.1 (2017-2-2)
-
Created 1:1 mapping between threads and the number of queues used to serve URLs to visit. URLs have an affinity for a particular queue based on their domain. All URLs from that domain will end up in the same queue. This improves parallel crawl performance by reducing the frequency that the politeness delay effects requests. For crawls bound to fewer domains than queues, the excess queues are not used.
-
Many bug fixes including fix that eliminates accidental over-crawling.
0.2.2 (2017-1-21)
- Added additional configuration option for redirect handling in KrawlConfig. Setting
useFastRedirectHandling = true
(when redirects are enabled) will cause Krawler to automatically follow redirects, keeping a history of the transitions and status codes. This history is present in theKrawlDocument#redirectHistory
property.
0.2.1 (2017-1-20)
-
Redirect handling has been changed. Redirects can be followed or not via configuration option in
KrawlConfig
. When redirects are enabled the redirected to URL will be added to the queue as a part of the link harvesting phase of Krawler. -
If an anchor tag specifies
rel='canonical'
thecanonicalForm
will not be subject to further processing. -
KrawlUrl.new
's implementation has been changed to preventnull
from being returned in certain circumstances.
0.2.0 (2017-1-18)
- Krawler now respects robots.txt. This feature can be configured by passing a custom
RobotsConfig
to yourKrawler
instance. By default Krawler will respect robots.txt without any additional configuration. - Krawler now collects outgoing links from
src
attributes of tags in addition to thehref
of anchor tags. - Minor bug fixes and refactorings.