小编Jon*_*Jon的帖子

我正在浏览示例并阅读文档,但我仍然不确定如何为我的场景配置rebus(或者使用总线是一个很好的选择).

我有一个要做的任务生产者,比如说ImportOrder和CalculateOrderPrice

我想从生产者转储消息并将大量这些消息排队.我想要两个侦听ImportOrder的客户端和10个侦听CalculatePriceOfOrder的客户端.我不希望同一个订单同时转到多个端点,我正在尝试分散工作量.

到目前为止生产者配置:

 <rebus inputQueue="publisher.input" errorQueue="publisher.error" workers="1" maxRetries="5">

var adapter = new BuiltinContainerAdapter();
            Configure.With(adapter)
                   .Logging(l => l.Log4Net())
                        .Transport(t => t.UseMsmqAndGetInputQueueNameFromAppConfig())
                        .Subscriptions(s => s.StoreInXmlFile(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "rebus_subscriptions.xml")))
                        .MessageOwnership(d => d.FromRebusConfigurationSection())
                        .CreateBus()
                        .Start();

目前消费者配置:

<rebus inputQueue="calcserver1.input" errorQueue="calcserver1.error" workers="1" maxRetries="5">
<endpoints>
  <add messages="Messages.RecalculateContractMessage,  Messages" endpoint="publisher.RecalculateContract@se-devws-0007.sirius.local"/>
</endpoints>

Configure.With(adapter)
               .Logging(l => l.Log4Net())
                .Transport(t => t.UseMsmqAndGetInputQueueNameFromAppConfig())
                .MessageOwnership(d => d.FromRebusConfigurationSection())
                .CreateBus()
                .Start();

        adapter.Bus.Subscribe<RecalculateContractMessage>();

我似乎无法配置此设置,如果我使用msmq或sqlserver并不重要.

• rebus(或任何服务总线类型的解决方案)听起来不太合适吗？
  
• 我应该使用pub/sub还是普通发送模式？如果当时只有一个端点或几个端点处理消息,那么该选择会影响吗？
  
• 有人能指出一个很好的例子或解释如何设置这个场景吗？

在设置我的模拟调用函数时,我得到了一个我从NSubstitute没想到的行为.行为的简化版本是

[Test]
public void NSubstituteTest()
{
    var mockedFoo = Substitute.For<IFoo>();

    mockedFoo.GenerateString(Arg.Any<string>()).Returns(x => GetValue(x.Args()[0]));
    mockedFoo.GenerateString("0").Returns("hi");


    string result1 = mockedFoo.GenerateString("0");
    string result2 = mockedFoo.GenerateString("1");

    Assert.AreEqual("hi", result1);
    Assert.AreEqual("1", result2);
}

private string GetValue(object val)
{
    string returnValue = val != null ? val.ToString() : "I am null";
    System.Diagnostics.Trace.WriteLine(returnValue);
    return returnValue;
}

测试通过,但我得到输出:0 1

这表明调用了mockedFoo.GenerateString("0"); 实际上会导致调用GetValue()函数.

如果我对Moq做同样的事情:

[Test]
public void MoqTest()
{
    var mockedFoo = new Mock<IFoo>();

    mockedFoo.Setup(x => x.GenerateString(It.IsAny<string>())).Returns((object s) => GetValue(s));
    mockedFoo.Setup(x => x.GenerateString("0")).Returns("hi");


    string result1 = mockedFoo.Object.GenerateString("0");
    string result2 = mockedFoo.Object.GenerateString("1"); …