Рефераты | Рефераты по информатике, программированию | MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных | страница реферата 7 | Большая Энциклопедия Рефератов от А до Я
Большая Энциклопедия Рефератов от А до Я
  • Рефераты, курсовые, шпаргалки, сочинения, изложения
  • Дипломы, диссертации, решебники, рассказы, тезисы
  • Конспекты, отчеты, доклады, контрольные работы


    • Рефераты | Рефераты по информатике, программированию | MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных


    Рефераты | Рефераты по информатике, программированию | MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных

    MSSQL 2005 (Yukon) – работа с очередями и асинхронная обработка данных




    Категория реферата: Рефераты по информатике, программированию
    Теги реферата: реферат биография, скачать на телефон шпаргалки
    Добавил(а) на сайт: Kozin.



    Предыдущая страница реферата | 2  3  4  5  6  7  8  9  10  11  12 |



      ON CONTRACT   [TestContract];

      SEND ON CONVERSATION @convHandler

       MESSAGE TYPE [TestType] (N'The data hase been changed')

     END CONVERSATION @convHandler

    GO

    Передавать в сообщении никакой ценной информации нам не надо, так как принимающая сторона должна просто узнать, о том, что таблица поменялась, а признаком этого служит сам факт доставки сообщения. Более того, в данной ситуации нет необходимости даже вызывать команду SEND, так как закрытие диалога (END CONVERSATION) вызывает посылку специального сообщения об этом печальном событии на принимающую сторону. Однако в реальной ситуации может понадобиться передать некоторую информацию, и если ее необходимо структурировать, то придется воспользоваться XML.

    Теперь займемся принимающей стороной. Для начала создадим процедуру пересчета агрегата:

    CREATE PROCEDURE AggRecalculate AS

     -- очистка очереди

     --

     RECEIVE * FROM [TargetQueue]

     -- небольшая задержка для имитации действительно долгого расчета

     --

     WAITFOR DELAY '00:00:02'

     UPDATE Big_Aggregate

      SET Agg = (SELECT SUM(Data) FROM Very_Big_Table),

        [Time] = GetDate()

    GO

    Процедура готова, но есть одна проблема. Как выполнить эту процедуру при появлении сообщения в очереди? Конечно, можно, как и раньше, обернуть RECEIVE в WAITFOR, но в этом случае кто-то должен запусить процедуру, чтобы она начала ждать сообщений из очереди. И мало того, сообщение-то у нас может быть не одно. Значит, нужно чтобы после получения кто-то активизировал процедуру снова. Другими словами, нужен некий монитор, который следил бы за состоянием очереди и при появлении в ней сообщений вызывал нашу процедуру. К счастью, все уже сделано за нас. Такой монитор имеется в Service Broker, и для его включения достаточно немного изменить параметры очереди, указав, какую процедуру надо вызвать при получении сообщения:

    ALTER QUEUE [TargetQueue]

     WITH ACTIVATION(

      STATUS = ON,

      PROCEDURE_NAME = AggRecalculate,

      MAX_QUEUE_READERS = 1,

      EXECUTE AS OWNER)


    Рекомендуем скачать другие рефераты по теме: рефераты на казахском языке, реферат на тему время.



    Предыдущая страница реферата | 2  3  4  5  6  7  8  9  10  11  12 |




    Поделитесь этой записью или добавьте в закладки

       

    Категории:



    Разделы сайта




    •