11

我的应用程序由一个 ASP.NET MVC 3 应用程序和一个 Windows 服务组成，它们都在同一个盒子上。MVC 应用程序使用 MassTransit 将消息放置在 MSMQ 队列上。该服务使用 MassTransit 从 MSMQ 读取这些消息并执行一些工作。当我加载服务和应用程序并让它们同时运行时，一切似乎都运行良好。但是，如果我只加载 Web 应用程序，我的消息不会被添加到 MSMQ 并且基本上会消失。奇怪的是，如果我加载我的 Web 应用程序，然后启动并立即停止所述服务，则从 Web 应用程序发送的后续消息将添加到队列中。

将 MassTransit 与 StructureMap 和/或 MVC 结合使用的优秀/现代示例并不多，因此我的配置可能存在问题，但经过几个小时的反复试验后，我不确定如何继续。我也可能在滥用 MassTransit - 我真正需要的是来自 Web 应用程序的“一劳永逸”解决方案......

我的服务如下所示：

class Program
{
    static void Main(string[] args)
    {
        Bus.Initialize(sbc =>
        {
            sbc.UseMsmq();
            sbc.VerifyMsmqConfiguration();
            sbc.UseMulticastSubscriptionClient();
            sbc.ReceiveFrom("msmq://localhost/receiver");
        });

        ObjectFactory.Initialize(x =>
        {
            x.AddRegistry(new EmailSenderRegistry());
        });

        var host = HostFactory.New(c =>
        {
            c.SetServiceName("MyApp.EmailMessageReader");
            c.SetDisplayName("MyApp.EmailMessageReader");
            c.SetDescription("MyApp.EmailMessageReader");

            c.Service<ClientService>(a =>
            {
                a.ConstructUsing(service => new ClientService());
                a.WhenStarted(o => o.Start());
                a.WhenStopped(x=>x.Stop());
            });
        });

        host.Run();
    }
}

internal class ClientService 
{
    public void Start()
    {
        Bus.Instance.SubscribeConsumer<EmailPrepService>();
    }

    public void Stop()
    {
        // do nothing
    }
}

public class EmailPrepService : Consumes<EmailMessage>.All
{
    public void Consume(EmailMessage message)
    {
        PrepareEmailForSending(message);
        var emailService = ObjectFactory.GetInstance<IEmailSender>();
        emailService.SendEmail(message);
    }
}

我的 Web 应用程序如下所示：

public class BusRegistry : Registry
{
    public BusRegistry()
    {
        For<IServiceBus>().Singleton().Use(context => ServiceBusFactory.New(sbc =>
        {
            sbc.ReceiveFrom("msmq://localhost/sender");             
            sbc.UseMsmq();
            sbc.UseMulticastSubscriptionClient();
            sbc.UseControlBus();
            sbc.Subscribe(subs => { subs.LoadFrom(context.GetInstance<IContainer>()); });
        }));            
    }
}

任何帮助，将不胜感激！

4

1 回答 1

10

当您使用 MulticastSubscriptionClient 时，您的订阅是“暂时的”而不是“永久的”，即它们在总线关闭时自动取消订阅。

您的选择是 a) 使用RabbitMQ作为传输或 b) 如果您需要使用 MSMQ，则使用 MassTransit 的 SubscriptionServices 进行订阅，因为它们随后存储在数据库中并在总线实例之间持续存在。

有关详细信息，请参阅http://docs.masstransit-project.com/en/latest/overview/subscriptions.html 。

于 2012-04-24T15:45:18.560 回答