标签: nservicebus

我们刚刚发布了一个完全托管在Amazon EC2上的项目,该项目中还有一个简单的消息传递系统.我们有一个非常简单的小型pub/sub机制,我们收到一条消息,然后根据其类型确定用于消息的处理程序.在我们的新项目中,我们也有类似的机制,并且可能有一些稍微复杂的要求,但即使我们可以取消使用我们自己的代码来解决消息处理程序,这也很酷.

我们真的很想使用NServiceBus,因为pub/sub模型非常好,但到目前为止我们一直在使用Amazon SQS作为队列提供者.我们的每台EC2机器都有一个工作人员正在侦听相同的SQS队列并从中拉出消息来处理它们.显然,在NServiceBus中,不支持SQS作为传输层(我知道这是因为NServiceBus是围绕可靠且低延迟的队列构建的).

我知道NServiceBus有一个分销商,我可以想象在它自己的EC2实例上托管它,但问题是那里有一个巨大的单点故障,所以如果这个故障发生,我们基本上就搞砸了.根据我的收集,人们设置Windows故障转移群集来处理内部网络的这个问题,但我不知道这是否适用于EC2.

这是我在实际上尝试在基于云的环境中使用NServiceBus的人可以找到的唯一博客文章之一,他似乎并不推荐它.我只是想知道这里有没有其他人尝试过,如果有的话,他们会提供什么建议吗？似乎很遗憾,我们无法仅仅因为我们托管在云上而使用这样一个伟大的框架.

看起来Azure Queues正在取得一些进展,这是我们可能会看到的,但是现在我们希望将基础设施保留在亚马逊,因为我们有很多可以重复使用的构建自动化,这是基于.

nservicebus amazon-ec2

jac*_*ida

lucky-day

13
推荐指数

1
解决办法

944
查看次数

不在NServiceBus中自动创建队列

我正在运行NServiceBus 3.0.0 rc2但是当我启动应用程序(作为本地管理员)而没有预先创建MSMQ时,它出错了:

队列不存在或您没有足够的权限来执行操作.

使用NServiceBus 2.6没有发生这种情况.

以下是我的配置:

var bus = Configure.With()
    .Log4Net()
    .NinjectBuilder()
    .XmlSerializer()
    .DefiningCommandsAs(t => typeof(ICommand).IsAssignableFrom(t))
    .DefiningEventsAs(t => typeof(IEvent).IsAssignableFrom(t))
    .DefiningMessagesAs(t => typeof(IMessage).IsAssignableFrom(t))
    .MsmqTransport()
        .DefineEndpointName("subscriber.input")
        .IsTransactional(true)
        .PurgeOnStartup(false)
    .UnicastBus()
        .LoadMessageHandlers() 
        .ImpersonateSender(false)
    .CreateBus()
    .Start();

Run Code Online (Sandbox Code Playgroud)

和

<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>    
  <MsmqTransportConfig ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5" />    
  <UnicastBusConfig>
    <MessageEndpointMappings>
      <add Messages="MyEvents" Endpoint="publisher.input" />
    </MessageEndpointMappings>
  </UnicastBusConfig>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/>
  </startup>
</configuration>

Run Code Online (Sandbox Code Playgroud)

我可以看到一个配置扩展方法来禁用自动创建队列但没有启用它.

如果我预先创建队列,它工作正常.

.net c# msmq exception-handling nservicebus

Not*_*ple

2012 02-08

13
推荐指数

2
解决办法

7461
查看次数

如何在NServiceBus中按名称空间配置MessageEndpointMapping

我试图通过从不同的命名空间向不同的端点发送消息来配置我的NServiceBus配置中的消息端点映射.

因此,我在web.config中配置了以下内容:

<MessageEndpointMappings>
    <add Messages="Company.Messages.Accounts" Endpoint="ServiceInput" />
    <add Messages="Company.Messages.Payments" Endpoint="ServiceInput" />
    <add Messages="Company.Messages.Cancellations" Endpoint="ServiceInput" />
    <add Messages="Company.Messages.Notifications" Endpoint="ServiceInput" />
</MessageEndpointMappings>

Run Code Online (Sandbox Code Playgroud)

但是,当我的应用程序启动时,我收到以下异常:

Spring.Objects.PropertyAccessExceptionsException:PropertyAccessExceptionsException(1个错误); 嵌套的PropertyAccessExceptions是:[Spring.Core.TypeMismatchException:无法将类型[System.Collections.Hashtable]的属性值转换为属性'MessageOwners'所需的类型[System.Collections.IDictionary].,内部异常:System.ArgumentException:问题加载消息程序集:Company.Messages.Payments ---> System.IO.FileNotFoundException:无法加载文件或程序集"Company.Messages.Payments"或其依赖项之一.该系统找不到指定的文件.文件名称:'Company.Messages.Payments'

我觉得有趣的是它似乎找到了Company.Messages.Accounts但在第二个配置的行上失败了.我想也许它不喜欢让它们全部转到同一个端点,但更改此配置以使它们进入不同的端点并没有改变我收到的错误消息.

我究竟做错了什么？是不是可以通过命名空间来分割消息(我所见过的只是按类型和汇编)？

谢谢,史蒂夫

messaging msmq nservicebus

Ste*_*ing

2011 03-10

12
推荐指数

2
解决办法

7910
查看次数