Skip to content

W
webmagic
Commit 1f21d9cc authored by yihua.huang's avatar yihua.huang
Browse files
Options

spell mistake fix #128

parent e310139d
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 27 deletions
webmagic-core/src/main/java/us/codecraft/webmagic/proxy/ProxyPool.java
View file @ 1f21d9cc
package us.codecraft.webmagic.proxy; package us.codecraft.webmagic.proxy;
import java.io.BufferedReader; import org.apache.http.HttpHost;
import java.io.File; import org.slf4j.Logger;
import java.io.FileInputStream; import org.slf4j.LoggerFactory;
import java.io.FileNotFoundException;
import java.io.FileOutputStream; import java.io.*;
import java.io.FileReader;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.ArrayList; import java.util.*;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.Timer;
import java.util.TimerTask;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.DelayQueue; import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
import org.apache.http.HttpHost;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/** /**
* ClassName:ProxyPool * ClassName:ProxyPool
...@@ -59,7 +42,7 @@ public class ProxyPool { ...@@ -59,7 +42,7 @@ public class ProxyPool {
@Override @Override
public void run() { public void run() {
saveProxyList(); saveProxyList();
logger.info(allProxyStutus()); logger.info(allProxyStatus());
} }
}; };
...@@ -230,7 +213,7 @@ public class ProxyPool { ...@@ -230,7 +213,7 @@ public class ProxyPool {
} }
} }
public String allProxyStutus() { public String allProxyStatus() {
String re = "all proxy info >>>> \n"; String re = "all proxy info >>>> \n";
for (Entry<String, Proxy> entry : allProxy.entrySet()) { for (Entry<String, Proxy> entry : allProxy.entrySet()) {
re += entry.getValue().toString() + "\n"; re += entry.getValue().toString() + "\n";
...@@ -285,13 +268,13 @@ public class ProxyPool { ...@@ -285,13 +268,13 @@ public class ProxyPool {
proxyPool.logger.info("borrow object>>>>" + i + ">>>>" + httphostList.get(i).toString()); proxyPool.logger.info("borrow object>>>>" + i + ">>>>" + httphostList.get(i).toString());
i++; i++;
} }
System.out.println(proxyPool.allProxyStutus()); System.out.println(proxyPool.allProxyStatus());
System.in.read(); System.in.read();
for (i = 0; i < httphostList.size(); i++) { for (i = 0; i < httphostList.size(); i++) {
proxyPool.returnProxy(httphostList.get(i), 200); proxyPool.returnProxy(httphostList.get(i), 200);
proxyPool.logger.info("return object>>>>" + i + ">>>>" + httphostList.get(i).toString()); proxyPool.logger.info("return object>>>>" + i + ">>>>" + httphostList.get(i).toString());
} }
System.out.println(proxyPool.allProxyStutus()); System.out.println(proxyPool.allProxyStatus());
System.in.read(); System.in.read();
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment