1 class Program
2 {
3 static bool finishIsCompleted=true;
4 static ConcurrentDictionary<string, int> failStatis;//保存请求失败的ip地址:key 失败次数:value
5 static string refreshLink = "https://blog.csdn.net/baijifeilong/article/details/80734388";
6 static string requestSuccessKey,requestFailKey;
7 static async Task Main(string[] args)
8 {
9
10 ThreadPool.SetMinThreads(500, 100);
11 failStatis = new ConcurrentDictionary<string, int>();
12 requestSuccessKey = "list_request_success"+DateTime.Now.ToString("hhmm");
13 requestFailKey = "list_request_fail" + DateTime.Now.ToString("hhmm");
14 Timer timer = new Timer(async (state) =>
15 {
16 if (finishIsCompleted)
17 {
18 finishIsCompleted = false;
19 //获取代理
20 var proxyIps = RedisHelper.GetProxy();
21 int threadCount = 1;
22 if (proxyIps.Count > 10)
23 {
24 threadCount = proxyIps.Count / 10;
25 }
26 //平均分配给每个thread执行15个请求
27 int requestCount = proxyIps.Count / threadCount;
28 for (var i = 0; i < threadCount; i++)
29 {
30 var tempList = proxyIps.GetRange(i * requestCount, requestCount);
31 if (i == threadCount - 1)
32 {
33 tempList.AddRange(proxyIps.GetRange(threadCount * requestCount, proxyIps.Count - threadCount * requestCount));
34 }
35 Thread thread = new Thread(async () =>
36 {
37 //执行发起请求
38 await Finish(tempList);
39 });
40 thread.Start();
41 }
42 }
43 }, "processing timer event", 0, 1000*30);
44 Console.ReadLine();
45 }
46
47 public static async Task Finish(List<string> proxyIps)
48 {
49 for (int i = 0; i < proxyIps.Count; i++)
50 {
51 string ip = proxyIps[i];
52 int index = ip.IndexOf(":");
53 string ipAddress = ip.Substring(0, index);
54 int ipPort = int.Parse(ip.Substring(index + 1));
55 //随机休眠
56 Thread.Sleep(new Random().Next(1,4)*1000);
57 await Get(ipAddress, ipPort, 10000, randomUseragent(), refreshLink, () =>
58 {
59 RedisHelper.AddRequestOk(requestSuccessKey,ip+" "+DateTime.Now.ToShortTimeString(),true);
60 Console.ForegroundColor = ConsoleColor.White;
61 Console.WriteLine(ip+" success");
62 },
63 (error) =>
64 {
65 RedisHelper.AddRequestOk(requestFailKey, ip + " " + DateTime.Now.ToShortTimeString(),false);
66 Console.ForegroundColor = ConsoleColor.Red;
67 Console.WriteLine(ipAddress+error+"失败"+(failStatis.ContainsKey(ip)?failStatis[ip] :1)+"次");
68 if (failStatis.ContainsKey(ip))
69 {
70 if (failStatis[ip] == 6)
71 {
72 RedisHelper.RemoveSetValue(ip);
73 }
74 else
75 failStatis[ip]++;
76 }
77 else
78 {
79 failStatis.AddOrUpdate(ip, 1,(key,oldValue)=>oldValue+1);
80 }
81 }
82 );
83 }
84 finishIsCompleted = true;
85 }
86
87 private static string randomUseragent()
88 {
89 string[] usersagents = new string[] {
90 "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",
91 "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",
92 "JUC (Linux; U; 2.3.7; zh-cn; MB200; 320*480) UCWEB7.9.3.103/139/999",
93 "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:7.0a1) Gecko/20110623 Firefox/7.0a1 Fennec/7.0a1",
94 "Opera/9.80 (Android 2.3.4; Linux; Opera Mobi/build-1107180945; U; en-GB) Presto/2.8.149 Version/11.10",
95 "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",
96 "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",
97 "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",
98 "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",
99 "Mozilla/5.0 (BlackBerry; U; BlackBerry 9800; en) AppleWebKit/534.1+ (KHTML, like Gecko) Version/6.0.0.337 Mobile Safari/534.1+",
100 "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",
101 "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",
102 "Mozilla/5.0 (compatible; MSIE 9.0; Windows Phone OS 7.5; Trident/5.0; IEMobile/9.0; HTC; Titan)",
103 "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2228.0 Safari/537.36",
104 "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",
105 "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",
106 "Mozilla/5.0 (Windows NT 5.1; U; en; rv:1.8.1) Gecko/20061208 Firefox/2.0.0 Opera 9.50",
107 "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/534.57.2 (KHTML, like Gecko) Version/5.1.7 Safari/534.57.2",
108 "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/30.0.1599.101 Safari/537.36",
109 "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) ",
110 "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)",
111 "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",
112 "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",
113 "Mozilla/5.0 (BlackBerry; U; BlackBerry 9800; en) AppleWebKit/534.1+ (KHTML, like Gecko) Version/6.0.0.337 Mobile Safari/534.1+",
114 "Mozilla/5.0 (compatible; MSIE 9.0; Windows Phone OS 7.5; Trident/5.0; IEMobile/9.0; HTC; Titan)",
115 "Mozilla/4.0 (compatible; MSIE 6.0; ) Opera/UCWEB7.0.2.37/28/999",
116 "Openwave/ UCWEB7.0.2.37/28/999",
117 "NOKIA5700/ UCWEB7.0.2.37/28/999",
118 "UCWEB7.0.2.37/28/999",
119 "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",
120 "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",
121 "Opera/9.80 (Android 2.3.4; Linux; Opera Mobi/build-1107180945; U; en-GB) Presto/2.8.149 Version/11.10",
122 "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",
123 };
124 Random random = new Random();
125 var randomNumber = random.Next(0, usersagents.Length);
126 return usersagents[randomNumber];
127 }
128 public static async Task Get(string proxyIp, int proxyPort,int timeout, string randomUseragent, string url, Action success, Action<string> fail)
129 {
130 HttpWebRequest request = null;
131 HttpWebResponse response = null;
132 try
133 {
134 request = (HttpWebRequest)WebRequest.Create(url);
135 request.Timeout = timeout;
136 request.UserAgent = randomUseragent;
137 request.Proxy = new WebProxy(proxyIp,proxyPort);
138
139 response = await request.GetResponseAsync() as HttpWebResponse;
140
141 if (response.StatusCode == HttpStatusCode.OK)
142 {
143 success();
144 }
145 else
146 {
147 fail(response+":"+response.StatusDescription);
148 }
149 }
150 catch (Exception ex)
151 {
152 fail(ex.Message.ToString());
153 }
154 finally
155 {
156 if (request != null)
157 {
158 request.Abort();
159 request = null;
160 }
161 if (response != null)
162 {
163 response.Close();
164 response = null;
165 }
166 }
167 }
168 }