本文目錄一覽:
- 1、北大青鳥java培訓:Java多線程爬蟲實現?
- 2、java適合寫爬蟲嗎?
- 3、如何用Java寫一個爬蟲
- 4、java爬蟲 長時間無返回
- 5、Java網路爬蟲怎麼實現?
- 6、java爬蟲抓取指定數據
北大青鳥java培訓:Java多線程爬蟲實現?
一、需求 1.定時抓取固定網站新聞標題、內容、發表時間和來源。
2.程序需要支持分散式、多線程 二、設計 1.網站是固定,但是未來也可能添加新的網站去抓取,每個網站內容節點設計都不一樣,這樣就需要支持動態可配置來新增網站以方便未來的擴展,這樣就需要每次都需要開發介入。
2.網站html節點的結構可能發生變化,所以也要支持提取節點可配置。
3.怎樣支持分散式?暫時最簡單的想法就是:多機器部署程序,還有新搞一台或者部署程序其中一台製作一個定時任務,定時開啟每台機器應該抓取哪個網站,暫時不能支持同一個網站同時可以支持被多台機器同時抓取,這樣會比較麻煩,要用到分散式隊列。
所以暫時一個網站同時只會被單台機器抓取。
4.多線程,怎樣多線程?多線程抓取我這邊有兩個實現: (1)一個線程抓取一個網站,維護一個自己的url隊列做廣度抓取,同時抓取多個網站。
如圖: (2)多個線程同時抓取不同的網站。
如圖: 以上兩張辦法其實各有優點,也給有缺點,看我們怎麼取捨了。
方法1:每個線程創建一個自己的隊列,圖中的queue可以不用concurrentQueue,優點:不涉及到控制並發,每個網站一個線程抓取一個網站,抓取完畢即自動回收銷毀線程。
控制方便。
缺點:線程數不可以擴展,例如當只有3個網站,你最多只能開3個線程來抓取,不能開更多,有一定的局限性。
方法2:N個線程同時抓取N個網站,線程數和網站數目不掛鉤,優點:線程數可以調整並且和和抓取網站數量無關。
3個網站我們可以開4個5個或者10個這個可以根據您的硬體資源進行調整。
缺點:需要控制並發,並且要控制什麼時候銷毀線程(thread1空閑,並且queue為空不代表任務可以結束,可能thread2結果還沒返回),當被抓取的網站響應較慢時,會拖慢整個爬蟲進度。
三、實現 抓取方式最終還是選擇了方法二,因為線程數可配置! 使用技術: jfinal用了之後才發現這東西不適合,但是由於項目進度問題,還是使用了。
maven項目管理 jettyserver mysql eclipse開發 項目需要重點攻破的難點: (1)合理的控制N個線程正常的抓取網站,並且當所有線程工作都完成了並且需要抓取的隊列為空時,N個線程同時退出銷毀。
(2)不同網站設計節點不一樣,需要通過配置解決各個網站需要抓取的URL和抓取節點內容在html節點的位置。
(3)個性化內容處理,由於html結構設計問題,北大青鳥認為抓取的內容可能有些多餘的html標籤,或者多餘的內容該怎麼處理。
java適合寫爬蟲嗎?
JAVA也可以實現爬蟲,比如jsoup包,一個非常方便解析html的工具呢。
不過相對來說,java語言笨重,稍微有些麻煩。
如何用Java寫一個爬蟲
import java.io.File;
import java.net.URL;
import java.net.URLConnection;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Scanner;
import java.util.UUID;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class DownMM {
public static void main(String[] args) throws Exception {
//out為輸出的路徑,注意要以\\結尾
String out = “D:\\JSP\\pic\\java\\”;
try{
File f = new File(out);
if(! f.exists()) {
f.mkdirs();
}
}catch(Exception e){
System.out.println(“no”);
}
String url = “-“;
Pattern reg = Pattern.compile(“img src=\”(.*?)\””);
for(int j=0, i=1; i=10; i++){
URL uu = new URL(url+i);
URLConnection conn = uu.openConnection();
conn.setRequestProperty(“User-Agent”, “Mozilla/5.0 (Windows NT 6.3; WOW64; Trident/7.0; rv:11.0) like Gecko”);
Scanner sc = new Scanner(conn.getInputStream());
Matcher m = reg.matcher(sc.useDelimiter(“\\A”).next());
while(m.find()){
Files.copy(new URL(m.group(1)).openStream(), Paths.get(out + UUID.randomUUID() + “.jpg”));
System.out.println(“已下載:”+j++);
}
}
}
}
java爬蟲 長時間無返回
可能是代碼異常。
寫代碼總是會出異常的,尤其是爬蟲這類程序,無法確保每次請求都能穩定地返回統一的結果,比如反爬蟲策略提升代理IP超時程序異常等等,處理好這些問題,才能保證爬蟲程序持續地運行下去,反爬蟲策略,超時設置網路總是不會一如既往的穩定如一,可能代理IP某個時間不穩定,也可能目標伺服器某個時間不穩定,還有自身機器的網路也可能不穩定,如果不設置好超時,程序也不好跑下去。
Java網路爬蟲怎麼實現?
網路爬蟲是一個自動提取網頁的程序,它為搜索引擎從萬維網上下載網頁,是搜索引擎的重要組成。
傳統爬蟲從一個或若干初始網頁的URL開始,獲得初始網頁上的URL,在抓取網頁的過程中,不斷從當前頁面上抽取新的URL放入隊列,直到滿足系統的一定停止條件。對於垂直搜索來說,聚焦爬蟲,即有針對性地爬取特定主題網頁的爬蟲,更為適合。
以下是一個使用java實現的簡單爬蟲核心代碼:
public void crawl() throws Throwable {
while (continueCrawling()) {
CrawlerUrl url = getNextUrl(); //獲取待爬取隊列中的下一個URL
if (url != null) {
printCrawlInfo();
String content = getContent(url); //獲取URL的文本信息
//聚焦爬蟲只爬取與主題內容相關的網頁,這裡採用正則匹配簡單處理
if (isContentRelevant(content, this.regexpSearchPattern)) {
saveContent(url, content); //保存網頁至本地
//獲取網頁內容中的鏈接,並放入待爬取隊列中
Collection urlStrings = extractUrls(content, url);
addUrlsToUrlQueue(url, urlStrings);
} else {
System.out.println(url + ” is not relevant ignoring …”);
}
//延時防止被對方屏蔽
Thread.sleep(this.delayBetweenUrls);
}
}
closeOutputStream();
}
private CrawlerUrl getNextUrl() throws Throwable {
CrawlerUrl nextUrl = null;
while ((nextUrl == null) (!urlQueue.isEmpty())) {
CrawlerUrl crawlerUrl = this.urlQueue.remove();
//doWeHavePermissionToVisit:是否有許可權訪問該URL,友好的爬蟲會根據網站提供的”Robot.txt”中配置的規則進行爬取
//isUrlAlreadyVisited:URL是否訪問過,大型的搜索引擎往往採用BloomFilter進行排重,這裡簡單使用HashMap
//isDepthAcceptable:是否達到指定的深度上限。爬蟲一般採取廣度優先的方式。一些網站會構建爬蟲陷阱(自動生成一些無效鏈接使爬蟲陷入死循環),採用深度限制加以避免
if (doWeHavePermissionToVisit(crawlerUrl)
(!isUrlAlreadyVisited(crawlerUrl))
isDepthAcceptable(crawlerUrl)) {
nextUrl = crawlerUrl;
// System.out.println(“Next url to be visited is ” + nextUrl);
}
}
return nextUrl;
}
private String getContent(CrawlerUrl url) throws Throwable {
//HttpClient4.1的調用與之前的方式不同
HttpClient client = new DefaultHttpClient();
HttpGet httpGet = new HttpGet(url.getUrlString());
StringBuffer strBuf = new StringBuffer();
HttpResponse response = client.execute(httpGet);
if (HttpStatus.SC_OK == response.getStatusLine().getStatusCode()) {
HttpEntity entity = response.getEntity();
if (entity != null) {
BufferedReader reader = new BufferedReader(
new InputStreamReader(entity.getContent(), “UTF-8”));
String line = null;
if (entity.getContentLength() 0) {
strBuf = new StringBuffer((int) entity.getContentLength());
while ((line = reader.readLine()) != null) {
strBuf.append(line);
}
}
}
if (entity != null) {
nsumeContent();
}
}
//將url標記為已訪問
markUrlAsVisited(url);
return strBuf.toString();
}
public static boolean isContentRelevant(String content,
Pattern regexpPattern) {
boolean retValue = false;
if (content != null) {
//是否符合正則表達式的條件
Matcher m = regexpPattern.matcher(content.toLowerCase());
retValue = m.find();
}
return retValue;
}
public List extractUrls(String text, CrawlerUrl crawlerUrl) {
Map urlMap = new HashMap();
extractHttpUrls(urlMap, text);
extractRelativeUrls(urlMap, text, crawlerUrl);
return new ArrayList(urlMap.keySet());
}
private void extractHttpUrls(Map urlMap, String text) {
Matcher m = (text);
while (m.find()) {
String url = m.group();
String[] terms = url.split(“a href=\””);
for (String term : terms) {
// System.out.println(“Term = ” + term);
if (term.startsWith(“http”)) {
int index = term.indexOf(“\””);
if (index 0) {
term = term.substring(0, index);
}
urlMap.put(term, term);
System.out.println(“Hyperlink: ” + term);
}
}
}
}
private void extractRelativeUrls(Map urlMap, String text,
CrawlerUrl crawlerUrl) {
Matcher m = relativeRegexp.matcher(text);
URL textURL = crawlerUrl.getURL();
String host = textURL.getHost();
while (m.find()) {
String url = m.group();
String[] terms = url.split(“a href=\””);
for (String term : terms) {
if (term.startsWith(“/”)) {
int index = term.indexOf(“\””);
if (index 0) {
term = term.substring(0, index);
}
String s = //” + host + term;
urlMap.put(s, s);
System.out.println(“Relative url: ” + s);
}
}
}
}
public static void main(String[] args) {
try {
String url = “”;
Queue urlQueue = new LinkedList();
String regexp = “java”;
urlQueue.add(new CrawlerUrl(url, 0));
NaiveCrawler crawler = new NaiveCrawler(urlQueue, 100, 5, 1000L,
regexp);
// boolean allowCrawl = crawler.areWeAllowedToVisit(url);
// System.out.println(“Allowed to crawl: ” + url + ” ” +
// allowCrawl);
crawler.crawl();
} catch (Throwable t) {
System.out.println(t.toString());
t.printStackTrace();
}
}
java爬蟲抓取指定數據
根據java網路編程相關的內容,使用jdk提供的相關類可以得到url對應網頁的html頁面代碼。
針對得到的html代碼,通過使用正則表達式即可得到我們想要的內容。
比如,我們如果想得到一個網頁上所有包括「java」關鍵字的文本內容,就可以逐行對網頁代碼進行正則表達式的匹配。最後達到去除html標籤和不相關的內容,只得到包括「java」這個關鍵字的內容的效果。
從網頁上爬取圖片的流程和爬取內容的流程基本相同,但是爬取圖片的步驟會多一步。
需要先用img標籤的正則表達式匹配獲取到img標籤,再用src屬性的正則表達式獲取這個img標籤中的src屬性的圖片url,然後再通過緩衝輸入流對象讀取到這個圖片url的圖片信息,配合文件輸出流將讀到的圖片信息寫入到本地即可。
原創文章,作者:TVKE,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/144260.html