Claw.ru | Рефераты по информатике, программированию | MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных | Категория реферата: Рефераты по информатике, программированию | Теги реферата: реферат биография, скачать на телефон шпаргалки | Добавил(а) на сайт: Kozin. Предыдущая страница реферата | 12  13  14  15  16  17  18  19  20  21  22 | Следующая страница реферата    SqlConnection asyncConnect = new SqlConnection(     _connectionString + "Asynchronous Processing=true;");    SqlCommand cmd2 = new SqlCommand(     "WAITFOR (Receive convert(xml, message_body) from NotifyTestQueue)",     asyncConnect);    asyncConnect.Open();    cmd2.BeginExecuteReader(     new AsyncCallback(Callback),     cmd2,     CommandBehavior.CloseConnection);   }   public void Callback(IAsyncResult result)   {    SqlDataReader DR = null;    try    {     // Объект SqlCommand, для вызова асинхронного EndExecuteReader, был     // передан при вызове BeginExecuteReader, иначе из этого метода     // добраться до него было бы проблематично     SqlCommand cmd = (SqlCommand)result.AsyncState;     DR = cmd.EndExecuteReader(result);     if (DR.Read())      Console.WriteLine(DR[0]);     DR.Close();    }    catch (Exception ex)    {     // Так как этот метод вызывается совсем из другого потока, то здесь     // единственный шанс отловить и обработать какое-либо исключение.     //     Console.WriteLine(      String.Format("Last error: {0}", ex.Message));    }    finally    {     if (DR != null && !DR.IsClosed)     {      DR.Close();     }    }   }  } }

Постоянное соединение с БД удерживать по-прежнему необходимо, но потребность в создании отдельного потока для ожидания изменений данных отпала. Первая часть процедуры GetData практически полностью повторяет аналогичную процедуру из предыдущего примера, но после закрытия подключения для первого запроса вместо вызова WaitForChanges() создается подключение с возможностью выполнения асинхронных команд. Обратите внимание на выражение Asyncronous Processing = true, добавленное в строку подключения. Далее создается обычный SqlCommand, со знакомым уже запросом WAITFOR(RECEIVE …), и открывается подключение к БД. После этого выполняется первая часть асинхронной команды, передающая текст запроса на выполнение. В качестве дополнительных параметров указывается функция обратного вызова Callback(), сам объект SqlCommand, который затем передастся в Callback() как одно из свойств IAsyncResult, и CommandBehaviour указывается такой, чтобы закрыть подключение после завершения чтения данных – ведь внутри Callback() объект SqlCommand будет уже недоступен. На этом функция GetData() завершает свою работу, и основной поток идет заниматься своими делами.

В тот момент, когда в очередь попадает извещение, ожидание заканчивается. Сетевой драйвер оповещает, что асинхронная операция закончена. Вызывается метод Callback(), в который в качестве параметра передается IAsyncResult, позволяющий, во-первых, получить ответ от сервера, а во-вторых, содержащий в одном из полей и сам объект SqlCommand, метод которого EndExecuteReader добывает этот самый результат. Иными словами, мы сначала извлекаем из IAsyncResult объект SqlCommand, а затем в SqlCommand.EndExecueReader передаем все тот же IAsyncResult, чтобы получить SqlDataReader с результатом. В данном случае результат представляет собой знакомую уже XML-строку.

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

Использование оповещения ASP.Net 2.0

Как известно, в ASP.Net существует совершенно замечательный объект Cache, который позволяет легко и непринужденно кэшировать практически что угодно, с весьма гибко настраиваемым механизмом обновления кэша – как по времени, так и по изменениям источников данных. К сожалению, предыдущие версии не поддерживали основной источник данных, БД. В этой версии благодаря классу SqlDependency эта печальная традиция нарушена. Простейший пример реализации данного механизма в ASP.Net 2.0 вообще не требует ни строчки кода, а пишется исключительно в декларативном стиле: