Сервисные группы разговора брокера SQL-сервера

Группы разговоров являются локальным примитивом, используемым для блокировки. Сообщения в группе диалога не имеют гарантии порядка, и группы диалога не передаются по сети.

Порядок сообщений гарантируется компонентом Service Broker в рамках диалога. Таким образом, чтобы сохранить порядок согласованных сообщений при обработке, отправляйте их в одном диалоге.

Группы бесед необходимы для объединения набора бесед, связанных друг с другом. Оба глагола GET CONVERSATION GROUP и RECEIVE гарантируют, что они заблокируют всю группу преобразования, таким образом предотвращая обработку связанных сообщений другими потоками. Например, рассмотрим сайт для путешествий. Он получает сообщение с просьбой забронировать праздничный пакет. В результате он инициирует разговор со службой бронирования отелей и отправляет запрос на резервирование номера, он инициирует разговор со службой бронирования авиабилетов и запрашивает бронирование путешествия, он инициирует разговор со службой агентства по аренде автомобилей и запрашивает бронирование автомобиля. Эти три новых диалога, которые он создал, находятся в той же группе, что и первоначальный диалог, в котором был получен запрос (приложение использовало предложение WITH RELATED_CONVERSATION в BEGIN DIALOG во всех трех их). Затем он фиксируется и переходит к обработке сообщений в очереди. Более поздние ответы на эти 3 коррелированных запроса начинают поступать в довольно случайное время. Скажем, на первом месте стоит реакция отеля. Сообщение принимается приложением, и оно обновляет статус запроса с ответом от отеля. В то же время приходит ответ авиакомпании. Если другому потоку будет разрешено забрать его, он попытается обновить статус того же запроса , что приведет к блокировке или даже взаимоблокировке потока который обрабатывает ответ отеля. Когда ответ отеля обрабатывается, поток фиксируется и, таким образом, разблокирует всю группу разговоров, позволяя любому потоку (включая его самого) получить ответ авиакомпании и обработать его.

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

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

он попытается обновить статус того же запроса , что приведет к блокировке или даже взаимоблокировке потока, обрабатывающего ответ отеля. Когда ответ отеля обрабатывается, поток фиксируется и, таким образом, разблокирует всю группу разговоров, позволяя любому потоку (включая его самого) получить ответ авиакомпании и обработать его.

он будет пытаться обновить статус того же запроса , что приведет к блокировке или даже взаимоблокировке потока, обрабатывающего ответ отеля. Когда ответ отеля обрабатывается, поток фиксируется и, таким образом, разблокирует всю группу разговоров, позволяя любому потоку (включая его самого) получить ответ авиакомпании и обработать его.