- class Program
- {
- static bool finishIsCompleted=true;
- static ConcurrentDictionary<string, int> failStatis;// 保存请求失败的 ip 地址: key 失败次数: value
- static string refreshLink = "https://blog.csdn.net/baijifeilong/article/details/80734388";
- static string requestSuccessKey,requestFailKey;
- static async Task Main(string[] args)
- {
- ThreadPool.SetMinThreads(500, 100);
- failStatis = new ConcurrentDictionary<string, int>();
- requestSuccessKey = "list_request_success"+DateTime.Now.ToString("hhmm");
- requestFailKey = "list_request_fail" + DateTime.Now.ToString("hhmm");
- Timer timer = new Timer(async (state) =>
- {
- if (finishIsCompleted)
- {
- finishIsCompleted = false;
- // 获取代理
- var proxyIps = RedisHelper.GetProxy();
- int threadCount = 1;
- if (proxyIps.Count> 10)
- {
- threadCount = proxyIps.Count / 10;
- }
- // 平均分配给每个 thread 执行 15 个请求
- int requestCount = proxyIps.Count / threadCount;
- for (var i = 0; i <threadCount; i++)
- {
- var tempList = proxyIps.GetRange(i * requestCount, requestCount);
- if (i == threadCount - 1)
- {
- tempList.AddRange(proxyIps.GetRange(threadCount * requestCount, proxyIps.Count - threadCount * requestCount));
- }
- Thread thread = new Thread(async () =>
- {
- // 执行发起请求
- await Finish(tempList);
- });
- thread.Start();
- }
- }
- }, "processing timer event", 0, 1000*30);
- Console.ReadLine();
- }
- public static async Task Finish(List<string> proxyIps)
- {
- for (int i = 0; i <proxyIps.Count; i++)
- {
- string ip = proxyIps[i];
- int index = ip.IndexOf(":");
- string ipAddress = ip.Substring(0, index);
- int ipPort = int.Parse(ip.Substring(index + 1));
- // 随机休眠
- Thread.Sleep(new Random().Next(1,4)*1000);
- await Get(ipAddress, ipPort, 10000, randomUseragent(), refreshLink, () =>
- {
- RedisHelper.AddRequestOk(requestSuccessKey,ip+" "+DateTime.Now.ToShortTimeString(),true);
- Console.ForegroundColor = ConsoleColor.White;
- Console.WriteLine(ip+"success");
- },
- (error) =>
- {
- RedisHelper.AddRequestOk(requestFailKey, ip + " " + DateTime.Now.ToShortTimeString(),false);
- Console.ForegroundColor = ConsoleColor.Red;
- Console.WriteLine(ipAddress+error+"失败"+(failStatis.ContainsKey(ip)?failStatis[ip] :1)+"次");
- if (failStatis.ContainsKey(ip))
- {
- if (failStatis[ip] == 6)
- {
- RedisHelper.RemoveSetValue(ip);
- }
- else
- failStatis[ip]++;
- }
- else
- {
- failStatis.AddOrUpdate(ip, 1,(key,oldValue)=>oldValue+1);
- }
- }
- );
- }
- finishIsCompleted = true;
- }
- private static string randomUseragent()
- {
- string[] usersagents = new string[] {
- "Mozilla/5.0 (Linux; U; Android 2.3.7; en-us; Nexus One Build/FRF91) ApplewebKit/533.1 (Khtml, like Gecko) Version/4.0 Mobile Safari/533.1",
- "MQQBrowser/26 Mozilla/5.0 (Linux; U; Android 2.3.7; zh-cn; MB200 Build/GRJ22; CyanogenMod-7) AppleWebKit/533.1 (KHTML, like Gecko) Version/4.0 Mobile Safari/533.1",
- "JUC (Linux; U; 2.3.7; zh-cn; MB200; 320*480) UCWEB7.9.3.103/139/999",
- "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:7.0a1) Gecko/20110623 Firefox/7.0a1 Fennec/7.0a1",
- "Opera/9.80 (Android 2.3.4; Linux; Opera Mobi/build-1107180945; U; en-GB) Presto/2.8.149 Version/11.10",
- "Mozilla/5.0 (Linux; U; Android 3.0; en-us; Xoom Build/HRI39) AppleWebKit/534.13 (KHTML, like Gecko) Version/4.0 Safari/534.13",
- "Mozilla/5.0 (iPhone; U; CPU iPhone OS 3_0 like Mac OS X; en-us) AppleWebKit/420.1 (KHTML, like Gecko) Version/3.0 Mobile/1A542a Safari/419.3",
- "Mozilla/5.0 (iPhone; U; CPU iPhone OS 4_0 like Mac OS X; en-us) AppleWebKit/532.9 (KHTML, like Gecko) Version/4.0.5 Mobile/8A293 Safari/6531.22.7",
- "Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X; en-us) AppleWebKit/531.21.10 (KHTML, like Gecko) Version/4.0.4 Mobile/7B334b Safari/531.21.10",
- "Mozilla/5.0 (BlackBerry; U; BlackBerry 9800; en) AppleWebKit/534.1+ (KHTML, like Gecko) Version/6.0.0.337 Mobile Safari/534.1+",
- "Mozilla/5.0 (hp-tablet; Linux; hpwOS/3.0.0; U; en-US) AppleWebKit/534.6 (KHTML, like Gecko) wOSBrowser/233.70 Safari/534.6 TouchPad/1.0",
- "Mozilla/5.0 (SymbianOS/9.4; Series60/5.0 NokiaN97-1/20.0.019; Profile/MIDP-2.1 Configuration/CLDC-1.1) AppleWebKit/525 (KHTML, like Gecko) BrowserNG/7.1.18124",
- "Mozilla/5.0 (compatible; MSIE 9.0; Windows Phone OS 7.5; Trident/5.0; IEMobile/9.0; HTC; Titan)",
- "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2228.0 Safari/537.36",
- "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2227.1 Safari/537.36",
- "Mozilla/5.0 (X11; U; Linux x86_64; zh-CN; rv:1.9.2.10) Gecko/20100922 Ubuntu/10.10 (maverick) Firefox/3.6.10",
- "Mozilla/5.0 (Windows NT 5.1; U; en; rv:1.8.1) Gecko/20061208 Firefox/2.0.0 Opera 9.50",
- "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/534.57.2 (KHTML, like Gecko) Version/5.1.7 Safari/534.57.2",
- "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/30.0.1599.101 Safari/537.36",
- "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; LBBROWSER)",
- "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; QQBrowser/7.0.3698.400)",
- "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/38.0.2125.122 UBrowser/4.0.3214.0 Safari/537.36",
- "Mozilla/5.0 (Linux; U; Android 2.2.1; zh-cn; HTC_Wildfire_A3333 Build/FRG83D) AppleWebKit/533.1 (KHTML, like Gecko) Version/4.0 Mobile Safari/533.1",
- "Mozilla/5.0 (BlackBerry; U; BlackBerry 9800; en) AppleWebKit/534.1+ (KHTML, like Gecko) Version/6.0.0.337 Mobile Safari/534.1+",
- "Mozilla/5.0 (compatible; MSIE 9.0; Windows Phone OS 7.5; Trident/5.0; IEMobile/9.0; HTC; Titan)",
- "Mozilla/4.0 (compatible; MSIE 6.0; ) Opera/UCWEB7.0.2.37/28/999",
- "Openwave/ UCWEB7.0.2.37/28/999",
- "NOKIA5700/ UCWEB7.0.2.37/28/999",
- "UCWEB7.0.2.37/28/999",
- "Mozilla/5.0 (hp-tablet; Linux; hpwOS/3.0.0; U; en-US) AppleWebKit/534.6 (KHTML, like Gecko) wOSBrowser/233.70 Safari/534.6 TouchPad/1.0",
- "Mozilla/5.0 (Linux; U; Android 3.0; en-us; Xoom Build/HRI39) AppleWebKit/534.13 (KHTML, like Gecko) Version/4.0 Safari/534.13",
- "Opera/9.80 (Android 2.3.4; Linux; Opera Mobi/build-1107180945; U; en-GB) Presto/2.8.149 Version/11.10",
- "Mozilla/5.0 (iPad; U; CPU OS 4_3_3 like Mac OS X; en-us) AppleWebKit/533.17.9 (KHTML, like Gecko) Version/5.0.2 Mobile/8J2 Safari/6533.18.5",
- };
- Random random = new Random();
- var randomNumber = random.Next(0, usersagents.Length);
- return usersagents[randomNumber];
- }
- public static async Task Get(string proxyIp, int proxyPort,int timeout, string randomUseragent, string url, Action success, Action<string> fail)
- {
- HttpWebRequest request = null;
- HttpWebResponse response = null;
- try
- {
- request = (HttpWebRequest)WebRequest.Create(url);
- request.Timeout = timeout;
- request.UserAgent = randomUseragent;
- request.Proxy = new WebProxy(proxyIp,proxyPort);
- response = await request.GetResponseAsync() as HttpWebResponse;
- if (response.StatusCode == HttpStatusCode.OK)
- {
- success();
- }
- else
- {
- fail(response+":"+response.StatusDescription);
- }
- }
- catch (Exception ex)
- {
- fail(ex.Message.ToString());
- }
- finally
- {
- if (request != null)
- {
- request.Abort();
- request = null;
- }
- if (response != null)
- {
- response.Close();
- response = null;
- }
- }
- }
- }
来源: https://www.cnblogs.com/zhangmumu/p/9275383.html