c# - Reactive Extension .Net - 高可用性

Question

我们使用 Reactive Extension 在特定时间触发特定操作。

例如:特定用户操作后两分钟做某事。

语法:

var observable = Observable.Timer(new TimeSpan(0, 0, someTime)).Take(1);
var subscribe = observable.Subscribe(i =>
                    {
                        DoSomething();
                        }
                    });

但是现在如果IIS/服务器重启，这个触发器就丢失了。这需要持久化，因为我们有高可用部署和多个托管代码的应用服务器。

帮助我们找到解决这个问题的方法。

Answer 1

But now if the IIS / server is restarted, this trigger is lost. This is required to be persisted as we have high available deployment with multiple App Servers hosting the code.

可能响应式扩展不是这里的答案。

看来您应该使用消息队列或服务总线。

如果您想深入了解这种方法，请检查这些技术:

• MSMQ .
• RabbitMQ
• ZeroMQ
• Azure Service Bus

另外，看看 MassTransit ，一种可以使用上述某些消息传递技术的服务总线。