订阅者无法处理来自发布者的消息

Question

我正在 ASP.NET MVC3 上测试 NServiceBus。目前，我可以向后端发送命令消息，并且消息处理程序正在侦听它。但是当我尝试发布相同的消息时，消息处理程序没有监听。

我发现的问题是消息没有发布到订阅者的队列中。当我调试并检查 NServiceBusHost 控制台时，它说

2012-01-19 22:53:35,042 [1] INFO  NServiceBus.Unicast.UnicastBus [(null)] <(null
)> - Subscribing to SampleMessage.Person1WasCreated, SampleMessage, Version=1.0.
0.0, Culture=neutral, PublicKeyToken=null at publisher queue Test-web

我几天来一遍又一遍地检查我的配置设置，这对我来说似乎是正确的。谁能帮我检查一下我缺少什么吗？我想做的事情是从网络发布消息，并且该消息应该在后端（ServiceHost2）处理。

ASP.NET MVC3 Web.config

<configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="MsmqSubscriptionStorageConfig" type="NServiceBus.Config.MsmqSubscriptionStorageConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core"/>
  </configSections>
  <MsmqTransportConfig InputQueue="Test-web" ErrorQueue="Test-web-error" NumberOfWorkerThreads="1" MaxRetries="5" />
  <MsmqSubscriptionStorageConfig Queue="Test-subscriptionstorage" />

Global.asax.cs

protected void Application_Start()
        {
            AreaRegistration.RegisterAllAreas();

            RegisterGlobalFilters(GlobalFilters.Filters);
            RegisterRoutes(RouteTable.Routes);

            Global.Bus = Configure.WithWeb()
               .Log4Net()
                .CastleWindsorBuilder()
                .XmlSerializer()
                .MsmqTransport().IsTransactional(false)
                .UnicastBus()
                .LoadMessageHandlers()
                .MsmqSubscriptionStorage()
                .CreateBus()
                .Start()
                ;
        }

ServiceHost2 项目中的 App.Config

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="MsmqSubscriptionStorageConfig" type="NServiceBus.Config.MsmqSubscriptionStorageConfig, NServiceBus.Core" />
  </configSections>
  <MsmqSubscriptionStorageConfig Queue="Service2-AC1-subscriptionstorage" />
  <MsmqTransportConfig InputQueue="Service2-AC1" ErrorQueue="Service2-AC1-Error" NumberOfWorkerThreads="1" MaxRetries="5" />
  <UnicastBusConfig>
    <MessageEndpointMappings>
    <add Messages="SampleMessage" Endpoint="Test-web" />
    </MessageEndpointMappings>
  </UnicastBusConfig>
  <appSettings>
    <add key="EndpointConfigurationType" value="ServiceHost2.EndpointConfig, ServiceHost2"/>
  </appSettings>
</configuration>

的 EndpointConfig

namespace ServiceHost2
{
    public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization
    {
        public void Init()
        {
            Configure.With()
                .Log4Net()
                .CastleWindsorBuilder()
                .MsmqTransport()
                .MsmqSubscriptionStorage()
                .XmlSerializer()
                .UnicastBus().LoadMessageHandlers()
                ;
        }
    }
}

ServiceHost2控制器中发布消息

public ActionResult CreatePerson(Person p)
        {
            var Person1WasCreated = new Person1WasCreated {Id = p.Id,Name = p.Name};
            Global.Bus.Publish(Person1WasCreated);
            return View();
        }

方法谢谢。

Answer 1

我想我找到了原因。我今天读了这篇关于 为什么不从 Web 应用程序发布 NServiceBus 消息？

它非常清楚地表明，消息不应该从 Web 发布。不知何故，我的网络项目创建的订阅存储不允许任何内容订阅它。

所以我的解决方案是，我将命令消息从 Web 发送到 Service1 中的消息处理程序，并向 Service2 发布新的事件消息。甚至事件消息也能够订阅到 Service1 的订阅存储中。现在一切正常。谢谢。