Моя система должна будет каждые, например, 60 секунд отправлять много http запросов. Это рассылка пуш уведомлений с помощью FCM Cloud Messaging. Вот документация. Я не особо опытный .NET разработчик. Хочу поинтересоваться у людей, имевших опыт реализации бекграундовых задач с рассылкой, как лучше это сделать. Я пробовал такой код:
public class Example
{
private static Timer aTimer;
public static void Main()
{
// Create a timer and set a two second interval.
aTimer = new System.Timers.Timer();
aTimer.Interval = 2000;
// Hook up the Elapsed event for the timer.
aTimer.Elapsed += OnTimedEvent;
// Have the timer fire repeated events (true is the default)
aTimer.AutoReset = true;
// Start the timer
aTimer.Enabled = true;
Console.WriteLine("Press the Enter key to exit the program at any time... ");
Console.ReadLine();
}
private static void OnTimedEvent(Object source, System.Timers.ElapsedEventArgs e)
{
Console.WriteLine("The Elapsed event was raised at {0}", e.SignalTime);
}
}
Это пример из официальной документации майкрософт по классу System.Timers
. Поначалу мне показалось, что он подходит идеально. Поскольку у меня к реализации были требования, запускать и останавливать рассылку из веба (контроллер MVC), выводить на вьюху идет ли рассылка, использовать DI. Но потом я столкнулся с проблемой. Если одна задача не успела закончиться, а другая начинается, то система падает. Падает не просто задача, а вообще все, в том числе и MVC.
Потом я подумал, а может сделать вот как. Каждую минуту происходит выборка пользователей на пуш. Все они добавляются в некую очередь (может rebbitMQ). А очередь эта работает так, как сможет. Я имею в виду, в своем темпе трудится или простаивает, если задач на пуш не пришло. Я пользователей повторно не пушу каждые 10 секунд, так что рано или поздно эта очередь начнет работать в лайтовом режиме. Но иногда ей придется потрудиться. Это та схема, которая мне видится в голове. То есть, финализирую. Каждые 60 секунд запускается выборка пользователей на пуш, пользователи добавляются в некую очередь, которая в своем темпе рассылает пуши, пока есть задачи. Тут и вопросы возникают:
- Жизнеспособно ли это?
- Пойдет ли обычный таймер для записи задач на пуш в очередь? Или использовать крон с консольным приложением?
- Или может есть какой то готовый scheduler под такие задачи и моя схема с добавлением задач на пуш в очередь и рассылкой - оверинженеринг?
Я пробовал такой scheduler https://github.com/fluentscheduler/FluentScheduler. У него очень странный DI. Там все как то на статических методах. Пробовал Hosted services. Но я не понял, как остановить или запустить такой сервис из веба методы Start и Stop работают странно. Я по этому поводу задавал вопрос тут.
В общем прошу поделиться опытом тех людей, кто решал что то подобное. Заранее огромное спасибо!
UPDATE
Итак, благодаря комментариям пользователя @tym32167 я пришел к решению просто дождаться когда на определенной итерации моего таймера метод с работой завершится. Для этого, в начале этого метода я остановлю таймер, а когда он завершиться, запущу снова. Вот код:
public class Scheduler
{
private const int MSecond = 1000;
private readonly int _seconds = MSecond * 10;
private Timer _aTimer;
public void Start()
{
Console.WriteLine("Sending is started ...");
_aTimer = new Timer();
_aTimer.Interval = _seconds;
_aTimer.Elapsed += OnTimedEvent;
_aTimer.AutoReset = true;
_aTimer.Enabled = true;
}
public bool IsWorking()
{
return _aTimer != null;
}
private async void OnTimedEvent(object sender, ElapsedEventArgs e)
{
await JustDoIt();
}
private async Task JustDoIt()
{
_aTimer.Stop();
// большая и трудная работа
await Task.Delay(1000 * 12);
Console.WriteLine("Done !!");
_aTimer.Start();
}
public void Stop()
{
_aTimer.Stop();
_aTimer = null;
}
}
Это эмуляция реальной задачи, поскольку он просто ждет и печатает в консоль "Done". При этом, заметьте, я пытаюсь эмулировать ситуацию, когда метод работает дольше, чем таймер. Таймр в примере работает 10 секунд, а метод 12. Если бы одновременно, запустилась бы параллельная задача с выполнением этого же метода, то, возможно, они могли бы испортить данные в базе, поскольку в моем реальном проекте, этот метод пишет в базу и читает. А то что реализованно в этом коде работает так. Сначала запускается таймер, выполняется метод с работой. В начале метода таймер выключается, дальше выполняется код (чтение, запись в базу), таймер включается, работаем дальше в бесконечном цикле. Все ли корректно в этом классе?
success: 0
. Такой json там можно найти. Вариант, чтоб следующий запуск гарантированно дождался предыдущего - это то что надо.