使用阻塞队列爬取代理ip实现爬虫

妖狐艹你老母 2022-06-05 07:21 272阅读 0赞

package com.yanshu.service;  
/\*import org.apache.commons.io.IOUtils;\*/  
import org.jsoup.Jsoup;  
import org.jsoup.nodes.Document;  
import org.jsoup.nodes.Element;  
import org.jsoup.select.Elements;  
  
  
import javax.net.ssl.HttpsURLConnection;  
import java.io.BufferedReader;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.InputStreamReader;  
import java.net.\*;  
import java.util.HashMap;  
import java.util.Map;  
import java.util.PriorityQueue;  
import java.util.Queue;  
import java.util.concurrent.BlockingQueue;  
import java.util.concurrent.LinkedBlockingDeque;  
public class Test \{  
public static void getIpAddress(BlockingQueue<Ip> queue) \{  
       Map<String, String> maps = new HashMap<String, String>();  
     //  for(int i = 1 ; i < 20; ++i) \{  
           try \{  
               Document doc = Jsoup.connect("http://www.xicidaili.com/nn/" )  
                       .data("query", "Java")  
                       .userAgent("Netscape/5")  
                       .cookie("auth", "token")  
                     //  .timeout(3000)  
                       .get();  
               String regex =  
                       "((?:(?:25\[0-5\]|2\[0-4\]\\\\d|((1\\\\d\{2\})|(\[1-9\]?\\\\d)))\\\\.)\{3\}(?:25\[0-5\]|2\[0-4\]\\\\d|((1\\\\d\{2\})|(\[1-9\]?\\\\d))))";  
               Elements elements =  
                       doc.select("td:matches(" + regex + ")");  
               System.out.println(doc.text());  
               for(int j = 0; j < elements.size(); ++j) \{  
                   Element e = (Element) elements.get(j);  
                   Element e1 = e.nextElementSibling();  
                   String ip = e.text();  
                   String prot = e1.text();  
                   if(isPing(ip)) \{  
                       System.out.println(ip + " " + prot);  
                       try \{  
                           queue.put(new Ip(ip, prot));  
                       \} catch (InterruptedException e2) \{  
                           e2.printStackTrace();  
                       \}  
                   \}  
               \}  
           \} catch (IOException e) \{  
               e.printStackTrace();  
           \}  
       //\}  
   \}  
   public static boolean isPing(String ip) \{  
       boolean status = false;  
       if(ip != null) \{  
           try \{  
               status = InetAddress.getByName(ip).isReachable(500);  
           \} catch(UnknownHostException e) \{  
           \}  
           catch(IOException e) \{  
           \}  
       \}  
       return status;  
   \}  
  
  
   public static void main(String\[\] args) \{  
       final BlockingQueue<Ip> queue = new LinkedBlockingDeque<>();  
       Thread thread = new Thread(new Runnable() \{  
           @Override  
           public void run() \{  
               getIpAddress(queue);  
           \}  
       \});  
       Thread thread1 = new Thread(new Runnable() \{  
           @Override  
           public void run() \{  
               parse(queue);  
           \}  
       \});  
  
  
       thread.start();  
       thread1.start();  
   \}  
  
  
   public static void parse(BlockingQueue<Ip> queue) \{  
  
  
       while (true) \{  
           Ip ip = null;  
           try \{  
               ip = queue.take();  
           \} catch (InterruptedException e) \{  
               e.printStackTrace();  
           \}  
           while (true) \{  
                   System.out.println(ip.ip + " " + ip.port);  
                   SocketAddress addr = new InetSocketAddress(ip.ip, Integer.parseInt(ip.port));  
                   Proxy proxy = new Proxy(Proxy.Type.HTTP, addr);  
                   try\{  
                       URL url = new URL("https://api.douban.com/v2/book/isbn/7505715666");  
                       HttpsURLConnection conn = (HttpsURLConnection)url.openConnection(proxy);  
                       conn.setConnectTimeout(5000);  
                       conn.setRequestProperty("User-Agent","Mozilla/4.0 (compatible; MSIE 7.0; NT 5.1; GTB5; .NET CLR 2.0.50727; CIBA)");  
                       conn.connect();  
                       String result = "";  
                       BufferedReader in = null;  
                       in = new BufferedReader(new InputStreamReader(  
                                   conn.getInputStream(),"UTF-8"));  
                           String line;  
                           while ((line = in.readLine()) != null) \{  
                               result += line;  
                           \}  
                       System.out.println(result);  
                   \}catch (Exception e) \{  
                      // e.printStackTrace();  
                       break;  
                   \}  
           \}  
       \}  
   \}  
\}  
class Ip\{  
   String ip;  
   String port;  
  
  
   public Ip(String ip, String port) \{  
       this.ip = ip;  
       this.port = port;  
   \}  
  
  
\}