开始 NServiceBus 和依赖注入和实例

Question

我在 NServiceBus 方面遇到了一些问题，我可以让 pubsub 示例正常工作，但现在我正在尝试将其集成到生产项目中，但我无法让它工作！

我的发布者代码与发布者示例完全相同（我刚刚导入了该项目以排除任何其他问题），但随后我创建了一个 void 函数并从我的 WPF 应用程序中调用它，然后我得到一条消息“you can't callbus without创建总线实例”错误

 public void RunTest()
            {
                    var eventMessage = new MarketPriceMessage();
                    eventMessage.Ticker = "IBM";
                    eventMessage.DataType = "Bid";
                    eventMessage.Value = (decimal)23.23423;
                    eventMessage.EventId = Guid.NewGuid();
                    eventMessage.Time = DateTime.Now; // > 30 ? (DateTime?)DateTime.Now : null;
                    eventMessage.Duration = TimeSpan.FromSeconds(99999D);



                    Bus.Publish(eventMessage);
            }

关于那里发生的事情以及我哪里出错了有什么想法吗？

以下是我在 WPF 应用程序内部使用的代码：

    public partial class App : Application
{
    public IBus bus { get; set; }

     protected override void OnStartup(StartupEventArgs e)
    {
        base.OnStartup(e);

        NServiceBus.Configure.With()
               .Log4Net()
               .SpringBuilder()
               .XmlSerializer()
               .MsmqTransport()
               .UnicastBus()
               .LoadMessageHandlers()
               .CreateBus()
               .Start();
    }
}

}

和

namespace WpfApplication2
{
    class EndpointConfig : IConfigureThisEndpoint, AsA_Publisher { }

}

当

namespace WpfApplication2
{
    public class SubscriptionAuthorizer : IAuthorizeSubscriptions
    {
        public bool AuthorizeSubscribe(string messageType, string clientEndpoint, string clientWindowsIdentity, IDictionary<string, string> headers)
        {
            return true;
        }

        public bool AuthorizeUnsubscribe(string messageType, string clientEndpoint, string clientWindowsIdentity, IDictionary<string, string> headers)
        {
            return true;
        }
    }
}

应用程序配置

<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core"/>
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core"/>
  </configSections>

  <MsmqTransportConfig 
                       InputQueue="WpfApplication2InputQueue" 
                       ErrorQueue="error" 
                       NumberOfWorkerThreads="1" 
                       MaxRetries="5"/>
  <UnicastBusConfig>
    <!--DistributorControlAddress="" DistributorDataAddress="" ForwardReceivedMessagesTo="">-->
    <MessageEndpointMappings>
    </MessageEndpointMappings>
  </UnicastBusConfig>

我单步执行代码时，我可以看到总线是一个 null 对象。

我照常添加参考文献

Answer 1

我对 WPF 不太熟悉，但看起来有一个 Application.Startup 事件可以工作。您需要“手动”配置总线，如 docs 中所示

Answer 2

如果您没有使用 Autofac 或其他容器，问题是您跳过了对总线变量的赋值。我通常将其放在 Global.asax Application_Startup 中，但这种方式也应该有效。

如果您使用容器，并且注册了实现 ServiceContract 的类，则可以在实例化时注入本地 IBus 构造函数/属性。

public IBus bus { get; set; }

protected override void OnStartup(StartupEventArgs e)
{
   base.OnStartup(e);

   bus = NServiceBus.Configure.With() // keep a reference to the returned bus. 
           .Log4Net()
           .SpringBuilder()
           .XmlSerializer()
           .MsmqTransport()
           .UnicastBus()
           .LoadMessageHandlers()
           .CreateBus()
           .Start();
}