NserviceBus如何实现数据预加载?

发布于 2024-10-08 21:47:20 字数 253 浏览 1 评论 0原文

我使用 NserviceBus 为我的主应用程序实现一些插件。主要应用程序是一个网站。在启动期间,插件需要从主应用程序(即所有用户)检索一些数据,然后处理对此数据的任何更改。为了始终拥有最新的数据。

我看到的问题是我们异步预加载数据,因此在预加载时我无法处理主应用程序的任何更改,因为插件仍未设置。

这个场景如何用NserviceBus来实现?我的意思是如何延迟消息处理直到预加载完成。看来这是常见的情况,所以解决方案应该很简单,但我找不到一个简单的解决方案。

I use NserviceBus to implement some plugins to my main application. Main application is a web site. During startup plugin needs to retrieve some data from main application(i.e. all users), and then to handle any changes to this data. In order always to have up to date data.

The problem I see is that we preload data asynchronously, so while that preloading I can't handle any changes from main application, because plugin is still not set up.

How this scenario can be implemented with NserviceBus? I mean how can I delay message handling until preload is completed. It seems this is common scenraion so the solution should be simple, but I fail to find an easy one.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

多彩岁月 2024-10-15 21:47:20

难道您不能在 NSB 中使用 Saga 来跟踪所有预加载,然后确保所有处理程序在尝试处理应用程序更改消息之前验证没有正在进行的 Saga 吗?

Couldn't you use a Saga in NSB to keep track of all your pre-loading, and then ensure all your handlers verify there is no Saga in progress before they attempt to handle application change messages?

流绪微梦 2024-10-15 21:47:20

您可以手动配置总线并仅在加载数据后启动它:

bus = Configure.With()
    .StructureMapBuilder(ObjectFactory.Container)
    .XmlSerializer()
    .MsmqTransport()
        .IsTransactional(true)
        .PurgeOnStartup(false)
    .MsmqSubscriptionStorage()
    .Sagas()
    .UnicastBus()
        .ImpersonateSender(false)
    .CreateBus()
    .Start();

这只是一个示例。您必须自己编辑配置。

对于替代方案,请发布有关您的数据性质以及正在对它们进行哪些转换的更多详细信息。

you can configure your bus manually and start it only after your data has been loaded:

bus = Configure.With()
    .StructureMapBuilder(ObjectFactory.Container)
    .XmlSerializer()
    .MsmqTransport()
        .IsTransactional(true)
        .PurgeOnStartup(false)
    .MsmqSubscriptionStorage()
    .Sagas()
    .UnicastBus()
        .ImpersonateSender(false)
    .CreateBus()
    .Start();

this is just an example. you have to edit the configuration for yourself.

for alternatives please post more details about the nature of your data and what transformations are being done with them.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文