它的逻辑如下: –
>获取网址
>在我们获得速率限制/非500响应之前,通过本地/默认IP进行请求
>出错
>调用SelectNewProxy()迭代代理列表并随机返回一个尝试(避免IP请求限制的好方法)
>从列表中删除不良代理以避免再次选择它
>启动一个每秒递增一次的计时器
>当计时器== 600(10分钟)
>创建新的WebProxy并再次尝试本地/默认IP后面的请求
>重置计时器
冲洗并重复
代码如下:
public string Request(string action){ httpWebRequest req; OnStatusChange(new MyArgs() { Message = "Status: Requesting..." }); string response = string.Empty; while (response.Equals(string.Empty) && proxy != null) { try { req = (httpWebRequest)WebRequest.Create(action); req.Proxy = proxy; HandleUIMessages(action,proxy); response = new StreamReader(req.GetResponse().GetResponseStream()).ReadToEnd(); } catch { //OnProxyChange(new MyArgs() { ProxyMessage = string.Format("Proxy: {0}",proxy.Address.ToString()) }); RemoveProxy(proxy); if (!timer.Enabled) { timer.Interval = (int)TimeInterval.Onesecond; timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed); timer.Enabled = true; timer.Start(); } WebProxy reset = new SelectNewProxy(); proxy = counter >= 600 ? reset : proxy = SelectNewProxy(); } } return response;}
值得一提的是我正在使用ThreadPool并且每个请求都在它自己的线程中运行.看起来它会工作,但我没有得到预期的效果,计数器达到’600’并设置proxy = reset但它似乎只是非常简短,可能只有第一个线程击中它?然后调用timer_Elapsed并重置计数器.可能是一个线程正在命中它,分配proxy = reset然后因为计数器现在已经被重置(不再是> = 600),所有后续排队的线程调用SelectNewProxy()?感觉我在漫无目的,但希望有人可以理解我想说的话,如果我猜对了,我怎么能确保所有线程都得到代理=重置并重试我们的初始IP?
任何帮助深表感谢!
谢谢
解决方法 你是如何宣布代理的?如果要在多个线程上读取/写入其值,则应确保使用volatile关键字声明它,否则其他人可能无法在一个线程上写入代理.例如.:
volatile WebProxy proxy;总结
以上是内存溢出为你收集整理的c# – 请求方法和线程问题?全部内容,希望文章能够帮你解决c# – 请求方法和线程问题?所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)