[Помогите!] реализовать прокси в потоках

[[Na`Vi]DendI]

Возможно ли сделать так что бы программа брала из списка прокси,если 1 прокси будет не валид то брала следующий ? Спасибо.

[the-boxi]

Конечно можно, дай код там где у тебя реализован много-поток и переменную в которой хранятся прокси!

[[Na`Vi]DendI]

Цитата: Сообщение от the-boxi Конечно можно, дай код там где у тебя реализован много-поток и переменную в которой хранятся прокси!

s = Convert.ToInt32(numericUpDown1.Text);

                    threads = new Thread[s];
                    for (i = 0; i < threads.Length; i++)
                    {
                        threads[i] = new Thread(new ThreadStart(main_ss));
                        threads[i].Start();

                                                   прокси
public ArrayList proxyArray; //для прокси 
proxyArray.AddRange(File.ReadAllLines("proxy.txt")); //ну и загрузка proxy...

Ну думаю достаточно,спасибо.

[TeedI]

Цитата: Сообщение от [Na`Vi]DendI s = Convert.ToInt32(numericUpDown1.Text); threads = new Thread[s]; for (i = 0; i < threads.Length; i++) { threads[i] = new Thread(new ThreadStart(main_ss)); threads[i].Start(); прокси public ArrayList proxyArray; //для прокси proxyArray.AddRange(File.ReadAllLines("proxy.txt")); //ну и загрузка proxy... Ну думаю достаточно,спасибо.

private Queue<string> proxyList = new Queue<string>();
private WebProxy pr = null;

/* Функция отправки запроса */
private void Request ( ) {
    
    try {
      WebRequest req = WebRequest.Create ( "http://google.ru");
      req.proxy = ( pr == null ) ? null : pr;
      req.Timeout = 4000;
      req.GetResponse();
    }
    catch {
      pr = ReturnProxy();
   }
}

/* Функция для получение прокси */
private WebProxy ReturnProxy() {
     WebProxy wbp = null;
     if ( proxyList.Count != 0) {
          string line = proxyList.Dequeue();
          wbp = new WebProxy ( line.Split ( ':')[0] , int.Parse ( line.Split ( ':' )[1]);
     }
     return wbp;
}

/* Функция для загрузки прокси */
private void LoadProxy () {
    string[] array = File.ReadAllLines ( "proxy.txt" );
    foreach ( string str in array ) {
         proxyList.Enqueue(str);
    }
    Array.Clear ( array  , 0 , array.Length);
}

Мб так

[megweg]

да, но есть прокси которые вместо целевой страницы дают свою, так что чекинг через гугл не всегда есть правильно !

[[Na`Vi]DendI]

Цитата: Сообщение от TeedI private Queue<string> proxyList = new Queue<string>(); private WebProxy pr = null; /* Функция отправки запроса */ private void Request ( ) { try { WebRequest req = WebRequest.Create ( "http://google.ru"); req.proxy = ( pr == null ) ? null : pr; req.Timeout = 4000; req.GetResponse(); } catch { pr = ReturnProxy(); } } /* Функция для получение прокси */ private WebProxy ReturnProxy() { WebProxy wbp = null; if ( proxyList.Count != 0) { string line = proxyList.Dequeue(); wbp = new WebProxy ( line.Split ( ':')[0] , int.Parse ( line.Split ( ':' )[1]); } return wbp; } /* Функция для загрузки прокси */ private void LoadProxy () { string[] array = File.ReadAllLines ( "proxy.txt" ); foreach ( string str in array ) { proxyList.Enqueue(str); } Array.Clear ( array , 0 , array.Length); } Мб так

Спасибо большое.Но в переменной pr почему-то всегда пусто.
Всё что мне надо это что бы при многопоточном бруте на каждую отправку запроса был новый прокси из списка,как только он закончится что бы прокси ишли снова с начала списка.

[TeedI]

Цитата: Сообщение от [Na`Vi]DendI Спасибо большое.Но в переменной pr почему-то всегда пусто. Всё что мне надо это что бы при многопоточном бруте на каждую отправку запроса был новый прокси из списка,как только он закончится что бы прокси ишли снова с начала списка.

Просто я чуток тупанул

public class UseProxy 
{
    private Queue<string> proxyList = new Queue<string>();
    private WebProxy pr = null;

    public UseProxy () {
       pr = ReturnProxy();
    }

    /* Функция отправки запроса */
    private void Request ( ) {
    try {
       WebRequest req = WebRequest.Create ( "http://google.ru");
      req.proxy = ( pr == null ) ? null : pr;
      req.Timeout = 4000;
      req.GetResponse();
    }
    catch {
      pr = ReturnProxy();
   }
}

/* Функция для получение прокси */
private WebProxy ReturnProxy() {
     WebProxy wbp = null;
     if ( proxyList.Count != 0) {
          string line = proxyList.Dequeue();
          wbp = new WebProxy ( line.Split ( ':')[0] , int.Parse ( line.Split ( ':' )[1]);
     }
     return wbp;
}

/* Функция для загрузки прокси */
private void LoadProxy () {
    string[] array = File.ReadAllLines ( "proxy.txt" );
    foreach ( string str in array ) {
         proxyList.Enqueue(str);
    }
    Array.Clear ( array  , 0 , array.Length);
 }
}

Ну и собстна , где-то там создаем класс и используем его элемент-функцию "Request" , которая в случаем не валидного прокси прочитает из очереди следующий

[[Na`Vi]DendI]

Цитата: Сообщение от TeedI Просто я чуток тупанул public class UseProxy { private Queue<string> proxyList = new Queue<string>(); private WebProxy pr = null; public UseProxy () { pr = ReturnProxy(); } /* Функция отправки запроса */ private void Request ( ) { try { WebRequest req = WebRequest.Create ( "http://google.ru"); req.proxy = ( pr == null ) ? null : pr; req.Timeout = 4000; req.GetResponse(); } catch { pr = ReturnProxy(); } } /* Функция для получение прокси */ private WebProxy ReturnProxy() { WebProxy wbp = null; if ( proxyList.Count != 0) { string line = proxyList.Dequeue(); wbp = new WebProxy ( line.Split ( ':')[0] , int.Parse ( line.Split ( ':' )[1]); } return wbp; } /* Функция для загрузки прокси */ private void LoadProxy () { string[] array = File.ReadAllLines ( "proxy.txt" ); foreach ( string str in array ) { proxyList.Enqueue(str); } Array.Clear ( array , 0 , array.Length); } } Ну и собстна , где-то там создаем класс и используем его элемент-функцию "Request" , которая в случаем не валидного прокси прочитает из очереди следующий

К сожалению все ровно не работает,ставлю на свой реквест это pr == null ) ? null : pr и все ровно "ноль на массу"...

[the-boxi]

используй lock

[Yukikaze]

Второй день слежу за вашими велосипедами, это так забавно ^^
Ща ченить накидаю
Если я не ошибаюсь, здесь нужно применить паттерн синглтон

[[Na`Vi]DendI]

Цитата: Сообщение от the-boxi используй lock

нене отпадает, думаю объяснять почему - нет смысла так как минус только 1, и очень очевидный.

Цитата: Сообщение от Yukikaze Второй день слежу за вашими велосипедами, это так забавно ^^ Ща ченить накидаю Если я не ошибаюсь, здесь нужно применить паттерн синглтон

Был бы очень вам преблагодарен)

[Yukikaze]

Чето подумал и решил, что можно отделаться одним статичным классом

    static class ProxyQ
    {
        private static readonly object sync = new object();
        public static readonly Queue<string> Proxyes;
        static ProxyQ()
        {
            Proxyes = new Queue<string>();
        }
        private static bool Check(string proxy)
        {
            HttpWebRequest req = (HttpWebRequest)WebRequest.Create("http://google.ru/");
            req.Proxy = new WebProxy(proxy);
            req.Timeout = 5000;
            try
            {
                HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
                return resp.StatusCode == HttpStatusCode.OK;
            }
            catch
            {
                return false;
            }
        }

        public static void Add(IEnumerable<string> proxyes)
        {
            foreach (string proxy in proxyes)
            {
                Proxyes.Enqueue(proxy);
            }
        }

        public static void Add(string proxy)
        {
            Proxyes.Enqueue(proxy);
        }

        public static string Get()
        {
            while (Proxyes.Count > 0)
            {
                string proxy;
                lock (sync) proxy = Proxyes.Dequeue();
                if (Check(proxy)) return proxy;
            }
            return null;
        }
    }

Вот пример использования

ProxyQ.Add("proxy"); //или ProxyQ.Add(new []{"proxy", "proxy", "proxy"}); или даже ProxyQ.Proxyes = new Queue<string>(массив проксей);
Console.WriteLine(ProxyQ.Get());

Метод Get() возвращает первый попавшийся рабочий прокси из очереди

[[Na`Vi]DendI]

Цитата: Сообщение от Yukikaze Чето подумал и решил, что можно отделаться одним статичным классом static class ProxyQ { private static readonly object sync = new object(); public static readonly Queue<string> Proxyes; static ProxyQ() { Proxyes = new Queue<string>(); } private static bool Check(string proxy) { HttpWebRequest req = (HttpWebRequest)WebRequest.Create("http://google.ru/"); req.Proxy = new WebProxy(proxy); req.Timeout = 5000; try { HttpWebResponse resp = (HttpWebResponse)req.GetResponse(); return resp.StatusCode == HttpStatusCode.OK; } catch { return false; } } public static void Add(IEnumerable<string> proxyes) { foreach (string proxy in proxyes) { Proxyes.Enqueue(proxy); } } public static void Add(string proxy) { Proxyes.Enqueue(proxy); } public static string Get() { while (Proxyes.Count > 0) { string proxy; lock (sync) proxy = Proxyes.Dequeue(); if (Check(proxy)) return proxy; } return null; } } Вот пример использования ProxyQ.Add("proxy"); //или ProxyQ.Add(new []{"proxy", "proxy", "proxy"}); или даже ProxyQ.Proxyes = new Queue<string>(массив проксей); Console.WriteLine(ProxyQ.Get()); Метод Get() возвращает первый попавшийся рабочий прокси из очереди

Спасибо большое) Разобрал код всё отлично,но не могу понять одного,как впихнуть в мой класс в реквест уже чекнутые прокси ? Спасибо еще раз .

[Yukikaze]

не понял вопроса...
Тебе нужно заюзать прокси в реквесте

WebRequest req = WebRequest.Create(url);
req.Proxy = new WebProxy(ProxyQ.Get());

или сохранить уже чекнутые для дальнейшего использования?

WebRequest req = WebRequest.Create(url);
string proxy = ProxyQ.Get();
гдетоОбъявленныйСписок.Add(proxy);
req.Proxy = new WebProxy(proxy);

[[Na`Vi]DendI]

Цитата: Сообщение от Yukikaze не понял вопроса... Тебе нужно заюзать прокси в реквесте WebRequest req = WebRequest.Create(url); req.Proxy = new WebProxy(ProxyQ.Get()); или сохранить уже чекнутые для дальнейшего использования? WebRequest req = WebRequest.Create(url); string proxy = ProxyQ.Get(); гдетоОбъявленныйСписок.Add(proxy); req.Proxy = new WebProxy(ProxyQ.Get());

Спасибо.Видимо это я туповат еще..Все сделал точно так,но результата нет..(