如果在相同的15秒时间范围内,如何计算流事件数?

对于触发的每个数据到达事件,递增一个计数器。设置一个计时器每15秒响一次。根据需要记录计数器值(在列表、字典等中),然后重置计数器。

可以使用HashMap将键设为[0-59],值设为数据点列表。

使用堆也可以使列表更智能一些,以便最高或最低值位于顶部。如果下一个数据点大于最高元素,则可以将其放在堆的顶部。

如果这个过程是在非零时间范围内开始的呢?

我觉得你把事情复杂化了。我只想用一个表达式来过滤时间框架:

使用生成的列表和Linq的示例:

var start = DateTime.Now.AddHours(-1);
        List<DateTime> times = new List<DateTime>();

        int i = 1;
        var currentTime = new DateTime();
        do
        {
            currentTime = start.AddSeconds(.5 * i);
            times.Add(currentTime);
            i++;
        } while (currentTime < DateTime.Now);

        times.Where(t => t >= start.AddSeconds(15) && t <= start.AddSeconds(30))
           .ToList().ForEach(f => Console.WriteLine(f));

在第一次输入时,将窗口的开头设置为 DateTime 并初始化组以保留数据点。

• 如果经过的时间超过了窗口持续时间,则存储计数和组(或发送它们),并将窗口开始时间重置为 DataTime