软件简介

一个简约灵活强大的Java爬虫框架。

Features:

1、代码简单易懂，可定制性强
2、简单且易于使用的api
3、支持文件下载、分块抓取
4、请求和相应支持的内容和选项比较丰富、每个请求可定制性强
5、支持网络请求前后执行自定义操作
6、Selenium+PhantomJS支持
7、Redis支持

Future:

1、Complete the code comment and test(完善代码注释和完善测试代码)

demo:

import com.github.xbynet.crawler.http.DefaultDownloader;
import com.github.xbynet.crawler.http.FileDownloader;
import com.github.xbynet.crawler.http.HttpClientFactory;
import com.github.xbynet.crawler.parser.JsoupParser;
import com.github.xbynet.crawler.scheduler.DefaultScheduler;

public class GithubCrawler extends Processor {
    @Override
    public void process(Response resp) {
        String currentUrl = resp.getRequest().getUrl();
        System.out.println("CurrentUrl:" + currentUrl);
        int respCode = resp.getCode();
        System.out.println("ResponseCode:" + respCode);
        System.out.println("type:" + resp.getRespType().name());
        String contentType = resp.getContentType();
        System.out.println("ContentType:" + contentType);
        Map> headers = resp.getHeaders();
        System.out.println("ResonseHeaders:");
        for (String key : headers.keySet()) {
            List values=headers.get(key);
            for(String str:values){
                System.out.println(key + ":" +str);
            }
        }
        JsoupParser parser = resp.html();
        // suppport parted ,分块抓取是会有个parent response来关联所有分块response
        // System.out.println("isParted:"+resp.isPartResponse());
        // Response parent=resp.getParentResponse();
        // resp.addPartRequest(null);
        //Map extras=resp.getRequest().getExtras();

        if (currentUrl.equals("https://github.com/xbynet")) {
            String avatar = parser.single("img.avatar", "src");
            String dir = System.getProperty("java.io.tmpdir");
            String savePath = Paths.get(dir, UUID.randomUUID().toString())
                    .toString();
            boolean avatarDownloaded = download(avatar, savePath);
            System.out.println("avatar:" + avatar + ", saved:" + savePath);
            // System.out.println("avtar downloaded status:"+avatarDownloaded);
            String name = parser.single(".vcard-names > .vcard-fullname",
                    "text");
            System.out.println("name:" + name);
            List reponames = parser.list(
                    ".pinned-repos-list .repo.js-repo", "text");
            List repoUrls = parser.list(
                    ".pinned-repo-item .d-block >a", "href");
            System.out.println("reponame:url");
            if (reponames != null) {
                for (int i = 0; i < reponames.size(); i++) {
                    String tmpUrl="https://github.com"+repoUrls.get(i);
                    System.out.println(reponames.get(i) + ":"+tmpUrl);
                    Request req=new Request(tmpUrl).putExtra("name", reponames.get(i));
                    resp.addRequest(req);
                }
            }
        }else{
            Map extras=resp.getRequest().getExtras();
            String name=extras.get("name").toString();
            System.out.println("repoName:"+name);
            String shortDesc=parser.single(".repository-meta-content","allText");
            System.out.println("shortDesc:"+shortDesc);
        }
    }

    public void start() {
        Site site = new Site();
        Spider spider = Spider.builder(this).threadNum(5).site(site)
                .urls("https://github.com/xbynet").build();
        spider.run();
    }

    public static void main(String[] args) {
        new GithubCrawler().start();
    }


    public void startCompleteConfig() {
        String pcUA = "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36";
        String androidUA = "Mozilla/5.0 (Linux; Android 5.1.1; Nexus 6 Build/LYZ28E) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/48.0.2564.23 Mobile Safari/537.36";

        Site site = new Site();
        site.setEncoding("UTF-8").setHeader("Referer", "https://github.com/")
                .setRetry(3).setRetrySleep(3000).setSleep(50).setTimeout(30000)
                .setUa(pcUA);

        Request request = new Request("https://github.com/xbynet");
        HttpClientContext ctx = new HttpClientContext();
        BasicCookieStore cookieStore = new BasicCookieStore();
        ctx.setCookieStore(cookieStore);
        request.setAction(new RequestAction() {
            @Override
            public void before(CloseableHttpClient client, HttpUriRequest req) {
                System.out.println("before-haha");
            }

            @Override
            public void after(CloseableHttpClient client,
                    CloseableHttpResponse resp) {
                System.out.println("after-haha");
            }
        }).setCtx(ctx).setEncoding("UTF-8")
                .putExtra("somekey", "I can use in the response by your own")
                .setHeader("User-Agent", pcUA).setMethod(Const.HttpMethod.GET)
                .setPartRequest(null).setEntity(null)
                .setParams("appkeyqqqqqq", "1213131232141").setRetryCount(5)
                .setRetrySleepTime(10000);

        Spider spider = Spider.builder(this).threadNum(5)
                .name("Spider-github-xbynet")
                .defaultDownloader(new DefaultDownloader())
                .fileDownloader(new FileDownloader())
                .httpClientFactory(new HttpClientFactory()).ipProvider(null)
                .listener(null).pool(null).scheduler(new DefaultScheduler())
                .shutdownOnComplete(true).site(site).build();
        spider.run();
    }


}

Examples:

• Github(github个人项目信息)
• OSChinaTweets(开源中国动弹)
• Qiushibaike(醜事百科)
• Neihanshequ(内涵段子)
• ZihuRecommend(知乎推荐)

More Examples: Please see
here

Thinks:

webmagic:本项目借鉴了webmagic多处代码，设计上也作了较多参考，非常感谢。
xsoup：本项目使用xsoup作为底层xpath处理器
JsonPath：本项目使用JsonPath作为底层jsonpath处理器
Jsoup 本项目使用Jsoup作为底层HTML/XML处理器
HttpClient 本项目使用HttpClient作为底层网络请求工具