如何在达到日期时仅创建一次事件？

Question

假设我将来可以安排一件事情（例如表演）。

例如，我想在预定日期之前发出“ 10天”活动。 或者 我想在预定日期之后发出“ 3天”活动（演出发生了）。

我已经存储在DB的预定日期中。

从建筑的角度来看，最好的方法是什么？

我考虑对我的数据库进行定期投票以获取匹配日期，但恐怕要面对以下几个问题：

• 如何避免到达日期后产生多个事件（现在（） + 10天＆gt;计划日期）
• 如何避免丢失的事件（假设我每分钟使用CRON并将范围限制为一分钟，我可能会错过事件）。

我正在寻找企业模式，而且我很确定它存在于以有效方式管理此用例的策略。

Answer 1

在我看来，事件的排放是一个领域的关注。满足技术要求（例如域之间的数据传播）不仅仅是基础架构的要求。因此，我同意，业务逻辑不是您应该将其委派给RabbitMQ的东西。

鉴于此，我将构建将事件处理为域逻辑。

show

public class Show : EntityBase
{
    public DateTime ScheduledDate { get; set; }
    public string Name { get; set; }
    public bool PreShowNotificationSent { get; set; }
    public bool PostShowNotificationSent { get; set; }

    public void NotifyPre()
    {
        if (PreShowNotificationSent)
        {
            throw InvalidOperationException("Notification already sent");
        }
 
        base.AddDomainEvent(PreShowNotificationSentEvent(this));

        PreShowNotificationSent = true;
    }

    // repeat for NotifyPost()
}

然后在启动时初始化背景服务，该服务将根据您的首选时间表（例如每1分钟）运行。

该服务将每1分钟启动一次命令处理程序（sendproshownotifications）。

该命令处理程序将从您的存储库中检索一个“显示器”实体（该实体是处理通知的汇总）。存储库将为所有符合通知标准的表演示例和子对象检索，并为适当的“ Preshownotificationent”或“ shownotificationent”具有“错误”。

显示器

public class ShowNotifier
{
    List<Show> ShowsNeedingPreNotification { get; set; }
    List<Show> ShowsNeedingPostNotification { get; set; }

    public void Notify()
    {
        foreach (Show show in ShowsNeedingPreNotification)
        {
            show.NotifyPre();
        }

        foreach (Show show in ShowsNeedingPostNotification)
        {
            show.NotifyPost();
        }
    }
}

示例限量存储库

public async Task<ShowNotifier> GetWithPendingAsync()
{
    List<Show> pre = await _db.Shows.Where(s => 
        s.ScheduledDate is-within-10-days
        && s.PreShowNotificationSent == false).ToListAsync();

    List<Show> post = // similar to above for post notifications

    return new ShowNotifier()
    {
        ShowsNeedingPreNotification = pre;
        ShowsNeetingPostNotification = post;
    }
}

命令处理程序

ShowNotifier notifier = await _showNotifierRepository.GetWithPendingAsync();

notifier.Notify();

域事件处理程序（用于preshownotificationenteventEvent）

// Publish the integration event on the bus
await EventBus.PublishAsync(new ShowComingUpIntegrationEvent(
    domainEvent.Show.Name,
    domainEvent.Show.ScheduledDate));

使用上述方法将保持核心逻辑您的域名，同时确保每场演出仅发送一个事件。

根据您的样式，您可以将显示器从域实体中提起，并使其成为一种域服务，它使用显示存储库在调用NotifyPre或NotifyPost之前检索显示。

Answer 2

您还可以在服务总线上发布延迟消息（事件）。如果您不使用消息总线系统，则可以应用玉米员系统，并在发布事件（如果已发布事件）中进行跟踪。