Vadim Romanenko,
хотите некое альтернативное решение?
я правда не могу сказать как скажется такое решение на производительности сервера, это надо тестировать но руки не доходили.
данный подход основывается на функционале используемом в мониторах трасс и XE, а именно это процедура и функция:
1.
2.
sp_trace_getdata
fn_MSxe_read_event_stream
первая работает с серверными трассами, вторая с расширенными событиями, обе возвращают данные в виде потока.
также у нас есть средство позволяющее вызвать пользовательское событие:
1.
2.
3.
4.
5.
6.
7.
sp_trace_generateevent
[ @eventid=] event_id Is the ID of the event to turn on. event_id is int, with no default. The ID must be one of the event numbers from 82 through 91, which represent user-defined events as set with sp_trace_setevent.
[ @userinfo= ] 'user_info' Is the optional user-defined string identifying the reason for the event. user_info is nvarchar(128), with a default of NULL.
[ @userdata= ] user_data Is the optional user-specified data for the event. user_data is varbinary(8000), with a default of NULL.
итого все что требуется в приложении:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
public static void Main(string[] args) {
using (var cn = new SqlConnection("some_string")) {
using (var cmd = new SqlCommand($"select [type], [data] from sys.fn_MSxe_read_event_stream('my_app', null);", cn) {
try {
cn.Open();
var reader = cmd.ExecuteReader();
while (reader.Read()) {
var somepayload = ParseData(reader.GetSqlBytes(1).ToSqlBinary().Value);
DoAction(somepayload);
}
}
finnaly {}
}
}
}
//остается только написать метод Parse которые будет парсить поток байт, там вполне все тривиально
//описание выходного потока для данных процедур можно найти в инете
на сервере:
1.
2.
3.
4.
5.
create event session [my_app2] on server
add event user_event (where event_id = 90 or event_id = 91) --соответственно никто не мешает расширить фильтр скажем на user_info
go
alter event session [my_app] on server state = start;
go
в таком случае сможете отсылать уведомления в приложение без особых заморочек с service broker
при этом у вас есть возможность логировать уведомления можно для расширенных событий настроить цель в файл к примеру.
и на декларативном уровне у вас появляется некоторая возможность конфигурирования уведомлений в user_info можно передавать nvarchar(128) а в data varbinary(8000), а то как вы уже будете использовать эту информацию зависит от вас.
1.
2.
exec [sp_trace_generateevent] 90, N'some event 1', null
exec [sp_trace_generateevent] 91, N'some event 2', null
при обращении к функции fn_MSxe_read_event_stream запрос подключается к сиквелу в режиме чтения с типом ожидания XE_LIVE_TARGET_TVF, тоже самое делает студия когды вы щелкаете "наблюдать за данными предаваемыми в режиме реального времени"
