0

у меня есть вопросик для пэт проекта. Мне нужно реализовать отложенное выполнение некой задачи, допустим: Человек создал заметку, структура такая

class Note
{
     public int Id { get; set; }
     public string Text { get; set; }
     public DateTime Create { get; set; }
     public int CreatedBy { get; set; }
}

И хочет её опубликовать в определенной время, допустим через 2,5 дня. Как реализовать данную функцию в среде выполнения asp.net core 3.1, а также учесть будущею нагрузку, если не один человек захочет создать, а больше 2 тысяч людей? Я слышал про библиотеку Hangfire вроде созданный для этой проблемы, но до конца не уверен.

4
  • Создайте таблицу в базе в которой одна из колонок будет содержать время публикации и периодически опрашивайте эту таблицу из вашего приложения.
    – Vas Mil
    13 мая 2020 в 9:53
  • @VasyaMilovidov, я в принципе так и думал сделать, но тут вопрос в другом, как сделать счётчик и как правильно опрашивать бд, типа на конкретную минуту искать запись, если запись есть, то добавлять в основную таблицу и удалять из временной?
    – Yarik08
    13 мая 2020 в 10:12
  • 1) Опрашивайте базу с такой частотой которая вам необходима по вашим задачам, насколько критично является публикация позже на 10 секунд если не критична то можно опрашивать реже. 2) Выборку из базы делайте по критериям 1-й истекла дата публикации 2-й критерий публикация еще не была опубликована. После публикации отмечайте в таблице те записи которые были опубликованы что бы не публиковать их повторно
    – Vas Mil
    13 мая 2020 в 10:43
  • Что значит опубликовать?
    – tym32167
    13 мая 2020 в 11:01

1 ответ 1

1

Написал для вас абстрактно как это может быть написано:


class Publications {
    public DateTime PublicationDate { get; set; }
    public bool IsPublicationDone { get; set; }
}


public class Example {
    /// Для простоты пример используем массив вместо таблицы в БД
    private Publications[] PublicationTable { get; set; }

    private Timer timer;

    /// <summary>
    /// Интервал проверки публикаций.
    /// </summary>
    private readonly TimeSpan checkPeriod = new TimeSpan(0, 0, 10);

    /// После вызова этого метода начнется проверка по таблице
    private void StartCheck() {

        timer = new System.Threading.Timer(Check, null, TimeSpan.Zero, checkPeriod);

    }

    private async void Check(object state) {
        /// На время действия с публикациями временно отключаем таймер что бы он
        /// нас не нагнал пока мы тут возимся
        timer.Change(int.MaxValue, int.MaxValue);
        try {
            foreach(var currentPublictaion in PublicationTable) {
                if(!currentPublictaion.IsPublicationDone && currentPublictaion.PublicationDate < DateTime.Now) {
                    /// Тут мы публикуем то что соответствует currentPublictaion
                    /// .....

                    /// Отмечаем что публикация прошла
                    currentPublictaion.IsPublicationDone = true;
                }
            }

        } finally {
            /// Возвращаем таймер в исходное состояние
            timer.Change(checkPeriod, checkPeriod);
        }
    }
}

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.