问题标签 [servicebus]

我有一个订单 Web 服务，它具有创建订单的方法。当调用该方法时，一条消息被发送到服务总线并由订单消息处理程序处理。

我必须每天和每月生成一份订单报告。通常我会让订单消息处理程序将订单存储在数据库中，然后有一个从数据库读取并生成报告的计划任务。但我想知道是否有更面向消息的方式来做到这一点？

我想过让订单消息处理程序发布一条消息，各种报告服务（例如每日和每月）可以订阅。消息将在给定队列上累积，直到服务以给定的时间间隔（每天/每月）激活。然后，服务将处理其队列上的消息并生成报告。这是要走的路还是我要走的路？

任何指针将不胜感激。

更新

是否可以（使用 NServiceBus）将消息保存在发布者队列中，然后仅在给定的时间间隔发布它们？还是应该反过来，以便发布者立即发布并安排订阅者的处理？

我的系统分为两部分。两个部分使用 Rhino Service Bus 相互通信。在 Windows 7 上没有问题，但如果我在其他任何地方启动它（WinXP、Server 2003、...），当我调用时会出现以下异常Rhino.ServiceBus.Hosting.DefaultHost.Start(..)：

这是 Spring 日志的片段形式：

我正在考虑分布式网站，其中网站（多实例）由应用服务器（多实例）支持。我正在努力定义它们之间的通信机制。我看到了很多选项，例如 WCF、消息传递服务，或者通过完全消除 App Server 来建议的许多选项。

那么，对于预计有数百万访问者的全球级网站，您会怎么做。

好的，所以这些问题很多，但它们在某种程度上是相关的。服务总线是否有助于可扩展的分布式站点......或者我在这里混合了这些词。

非常感谢任何指导

我们在 Azure SB 中有许多主题，并通过从登台到生产的 VIP 交换不断更新我们的环境。

当实例在暂存中运行时，我们不希望订阅者读取和删除旨在向我们在生产槽中运行的实例发送事件的消息。

我想出的解决方案是创建名称中包含 RoleEnvironment.SubscriptionId 的订阅。然后在 RoleEntryPoint.OnStop() 期间删除这些以避免未使用的订阅。

有没有更优雅的解决方案，我是否遗漏了一些明显的东西？

I'm trying to disable HTTP keep-alive, and I can't seem to find any documentation on how to achieve that. Ultimately, I am occasionally getting:

System.ServiceModel.CommunicationException: The underlying connection was closed: A connection that was expected to be kept alive was closed by the server

I've heard the best approach is simply to disable HTTP keep-alive.

有没有办法延迟企业服务总线中消息的消费，直到 X 类似消息准备好或 Y 时间过去？

我的目标是在消费者中序列化和聚合多条消息，这样我就不会为消息而存储，而是为批处理。

我目前正在玩 Rhino ESB。我想知道我对这个 ESB 或你知道的任何其他东西的选择。

谢谢！

I am reading a lot about Servicebus implementations (NServicebus, MassTransit,...) and I think I have understand how a Servicebus works. I am still not sure what the right scenario is to use one, because I know myself and I tend to use technologies although they may be an overhead for needs.

So my question is: What are some good reasons/scenarios to use a Servicebus and do I need to use DDD technics to use it?

Some scenarios I thought of:

• Communication with external systems (e.g. my application is communicating with external systems and I want to make sure these get called, e.g. I persist an object within my database but I also have to call an external Webservice to synchronize data. I would create a Command and I would have 2 Handlers that get the event, one persisting to my database, the other one handling the webservice. If on command fails it will be retried)
• Scalability (I would be able to scale out on multiple machines)
• It may lead to cleaner code (instead of performing several sequential tasks when e.g. an Entity is updated I oculd have different Messagehandlers that perform these tasks in isolation, e.g. save the entity, another Handler could perform an update on a denormalized datastore etc).

我正在与第三方进行一些开发，该第三方向我指定的公共 URL 发出 Get 或 POST。

我想做的是在我的开发机器可以收听的 Azure 服务总线上设置一个中继服务。当请求进来时，我想转发该请求，就好像我的 Web 服务直接从第三方服务获取请求一样。

准备好后，我会将应用程序部署到公共服务，更改第三方服务发送的 URL，瞧，我应该启动并运行。

我正在寻找的东西看起来完全像这样：Clemens the Master of Service Bus，但它来自 2009 CTP。我正在努力，但还没有使用 2012 年的所有新位让它工作（也就是现在它在我的头上）。有人想帮忙吗？

Clemens 还帮助其他人使用服务总线创建反向代理，但我似乎找不到它。是的，我也发过 Clemens 的推文，但我敢肯定他是个大忙人！

ps 我知道应用程序请求路由，但我的开发机器不在公共 URL 上，我需要在服务总线上的客户端侦听器收到从服务器端端点中继的消息后重写 URL。

情况

我有一个使用 Windows Azure AppFabric 服务总线NetTcpRelayBinding连接到端点的客户端库。客户端库由应用程序托管，不一定是 .NET 应用程序。无论如何，app.config 是不可能的，这意味着一切都应该在代码中配置。

Machine.config 是一种选择，但如果可以避免它会更好。本地自定义代理或前端服务器可能是另一种选择，但我想先探索这个选项，然后再彻底改变架构。

系统绑定没有问题，但是我还没有想出或找到如何在代码中将以下配置添加到ChannelFactory的解决方案：

我对 ServiceBus 的工作方式很感兴趣。我的意思不是具体的实现，而是一般的想法，如果可能的话，模式可以这样说。是不是里面封装了 Observer 逻辑？也许有人知道诸如“创建自己的 ServiceBus 教程”或“为傻瓜创建自己的 ServiceBus”之类的文章 =)