Из синхронного сокета в асинхронный

[nbit]

В MSDN есть замечательный пример получения кода html страницы http://msdn.microsoft.com/ru-ru/library/system.net.sockets.socket.aspx, но к сожалению в этом примере производится блокирование до тех пор, пока не будет принята вся страница. Если не сложно помогите пожалуйста переделать его под асинхронные сокеты, буду премного благодарен за помощь.

Код: (C#)

using System;
using System.Text;
using System.IO;
using System.Net;
using System.Net.Sockets;

public class GetSocket
{
    private static Socket ConnectSocket(string server, int port)
    {
        Socket s = null;
        IPHostEntry hostEntry = null;

        // Get host related information.
        hostEntry = Dns.GetHostEntry(server);

        // Loop through the AddressList to obtain the supported AddressFamily. This is to avoid
        // an exception that occurs when the host IP Address is not compatible with the address family
        // (typical in the IPv6 case).
        foreach(IPAddress address in hostEntry.AddressList)
        {
            IPEndPoint ipe = new IPEndPoint(address, port);
            Socket tempSocket =
                new Socket(ipe.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            tempSocket.Connect(ipe);

            if(tempSocket.Connected)
            {
                s = tempSocket;
                break;
            }
            else
            {
                continue;
            }
        }
        return s;
    }

    // This method requests the home page content for the specified server.
    private static string SocketSendReceive(string server, int port)
    {
        string request = "GET / HTTP/1.1\r\nHost: " + server +
            "\r\nConnection: Close\r\n\r\n";
        Byte[] bytesSent = Encoding.ASCII.GetBytes(request);
        Byte[] bytesReceived = new Byte[256];

        // Create a socket connection with the specified server and port.
        Socket s = ConnectSocket(server, port);

        if (s == null)
            return ("Connection failed");

        // Send request to the server.
        s.Send(bytesSent, bytesSent.Length, 0);  

        // Receive the server home page content.
        int bytes = 0;
        string page = "Default HTML page on " + server + ":\r\n";

        // The following will block until te page is transmitted.
        do {
            bytes = s.Receive(bytesReceived, bytesReceived.Length, 0);
            page = page + Encoding.ASCII.GetString(bytesReceived, 0, bytes);
        }
        while (bytes > 0);

        return page;
    }

    public static void Main(string[] args)
    {
        string host;
        int port = 80;

        if (args.Length == 0)
            // If no server name is passed as argument to this program,
            // use the current host name as the default.
            host = Dns.GetHostName();
        else
            host = args[0];

        string result = SocketSendReceive(host, port);
        Console.WriteLine(result);
    }
}

[Dimka]

nbit, так в параллельный поток запусти или через System.Threading.Task асинхронную задачу (если .NET 4.x). Только что это тебе даст? Основной поток у тебя ничего не делает. Следовательно последние две строчки кода потребуют синхронизации этих потоков. Тогда какой смысл огород городить?

[nbit]

Да мне не на потоках надо, а с помощью асинхронных сокетов, т.к. будет десятки запросов в секунду, я именно их и выбрал из-за того что можно сделать высокопроизводительное приложение на их основе.

[RXL]

nbit, надеюсь ты не путаешь два термина: асинхронный ввод-вывод и неблокируемый. Асинхронный как раз блокируемый и под его обслуживание ОС создает отдельный поток. Неблокируемый ввод-вывод можно осуществлять в рамках одного потока.

[Dimka]

nbit, может тогда ты задачу опишешь, а мы решение посоветуем.

[nbit]

да задача простая, мне просто нужно получить html-код страницы (пишу crawler), но не одной, а сразу очень многих, так чтобы по максимуму загрузить канал насколько это возможно. У меня почти все уже сделано, но я реализовал на обычном WebRequest'e и в 1 поток что очень медленно (тестово), если же создавать каждый запрос в отдельном потоке ресурсов компьютера просто не хватит учитывая очень большое количество запросов.

[RXL]

Почему же не хватит? Всем хватает, а тебе не хватит

Что нужно хранить для одного запроса?
Данные состояния уровня сокета. Данные состояния уровня HTTP. Данные уровня приложения.
Код потока должен работать с этими данными.
Соотв., запускаешь N  потоков с N блоками данных.
Можно и в один поток, если код у тебя написан как конечный автомат.

[nbit]

Для каждого потока ОС минимум выделяет 1Мб памяти, при 1000-2000 запросов соответственно будут большие накладные расходы (1-2Гб). А насчет асинхронных и не блокируемых я что то окончательно запутался, здесь http://hashcode.ru/questions/47841/%D0%B8%D0%B7-%D1%81%D0%B8%D0%BD%D1%85%D1%80%D0%BE%D0%BD%D0%BD%D0%BE%D0%B3%D0%BE-%D1%81%D0%BE%D0%BA%D0%B5%D1%82%D0%B0-%D0%B2-%D0%B0%D1%81%D0%B8%D0%BD%D1%85%D1%80%D0%BE%D0%BD%D0%BD%D1%8B%D0%B9 ответили что это одно и то же.

[Dimka]

А насчет асинхронных и не блокируемых я что то окончательно запутался

Асинхронный - это в параллельном потоке. Тот же BeginConnect запускает Connect в отдельном потоке, а EndConnect получает результат.

Неблокирующая операция ввода-вывода - это другое. Для этого не создаётся отдельных потоков, а на уровне ядра операционной системы происходит управление устройствами ввода-вывода, работа которых на порядки медленнее работы центрального процессора. За ввод-вывод отвечают соответствующие устройства компьютера и их драйверы. Результаты (в твоём случае ввода) накапливаются в очередях и по окончании операции возникает событие готовности, что операция завершена. При помощи специальных средств программа, работающая в 1 поток на процессоре, может обслуживать множество параллельных операций ввода-вывода. В основном обслуживание заключается в запуске нескольких неблокирующих операций чтения, обработки результатов по мере готовности и запуске неблокирующих операций записи. Это делается в цикле. Сам этот подход к обработке называется мультиплексированием. Чем-то это похоже на жонглёра, который подбрасывает тарелочки: пока бОльшая часть тарелочек летит в воздухе, он обслуживает лишь одну (ловит и подбрасывает на новый круг), при этом работа жонглёра строго последовательна, но все тарелочки движутся параллельно.

Что же касается AsyncConnect, то по большому счёту это мало отличается от Begin/EndConnect. Разница может быть в том, что в одном случае запускается новый поток, а в другом - используется механизм заданий для системного пула потоков (к сожалению, в MSDN на уровне описания класса этот вопрос не раскрыт).

Работа с пулом потоков имеет меньше накладных расходов (поскольку нет запуска новых потоков), но при этом количество потоков ограничено (по умолчанию 25), и сами задания выстраиваются в очередь. Короче говоря, параллельно будут работать лишь столько заданий, сколько есть потоков, а остальные будут отложены. Как я понимаю, это не то, что тебе нужно.

[inputdtd]

Пришлось зарегится. Что бы мои недруги не расслаблялись.

А насчет асинхронных и не блокируемых я что то окончательно запутался

Что же касается AsyncConnect, то по большому счёту это мало отличается от Begin/EndConnect. Разница может быть в том, что в одном случае запускается новый поток, а в другом - используется механизм заданий для системного пула потоков (к сожалению, в MSDN на уровне описания класса этот вопрос не раскрыт).

Разница есть и существенная.  Вот тут можно посмотреть: http://msdn.microsoft.com/ru-ru/magazine/cc163356.aspx

У меня сервер на асинхронных сокетах работал при 30 тысячах подключений. Так што срач не влетел.

[Dimka]

Что бы мои недруги не расслаблялись.

Это кто? Здесь недругов не водится

http://msdn.microsoft.com/ru-ru/magazine/cc163356.aspx

Замечательно. Если мультиплексирование поддерживается Async-методами в 3.5, то стоит воспользоваться.