MassTransit 2.6.1 请求/响应模式 - 响应超时

我正在将 MassTransit 作为 ServiceBus 实现来在 Web 项目中使用。

我正在玩请求/响应 http://docs.masstransit-project.com/en/latest/overview/request.html模式，并且我发现消费者接收消息并响应与请求发布者处理响应之间有很长的延迟；有时，响应似乎永远不会通过（让它运行 10 分钟，响应仍然没有通过）。我唯一一次看到句柄委托被响应调用是在 30 秒超时期限之后并且抛出超时异常；在这种情况下，将命中处理程序委托上设置的断点。

设置是一个标准事务 - 我有一个正在发布请求的 Web 应用程序，一个正在使用请求并发送响应的控制台应用程序，以便 Web 应用程序处理回调中的响应。

我使用的是 Castle Windsor，容器是使用 WebActivator 在 Web 项目中初始化的：

[assembly: WebActivator.PreApplicationStartMethod(typeof(BootStrapper), "PreStart")]
[assembly: WebActivator.PostApplicationStartMethod(typeof(BootStrapper), "PostStart")]
[assembly: WebActivator.ApplicationShutdownMethodAttribute(typeof(BootStrapper), "Stop")]

namespace Web.App_Start
{
    public static class BootStrapper
    {
        internal static IWindsorContainer Container { get; private set; }

        public static void PreStart()
        {
            Container = new WindsorContainer().Install(FromAssembly.This());
        }

        public static void PostStart()
        {
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);

            ApiConfig.Configure(Container);
            MvcConfig.Configure(Container);
        }

        public static void Stop()
        {
            if (Container != null)
                Container.Dispose();
        }
    }
}

在网络应用程序项目中（一个 ASP.NET Web API 项目），MassTransit 的 WindsorInstaller 看起来像

public class MassTransitInstaller : IWindsorInstaller
{
    public void Install(IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(AllTypes.FromThisAssembly().BasedOn<IConsumer>());

        var bus = ServiceBusFactory.New(configurator =>
        {
            configurator.UseMsmq();
            configurator.VerifyMsmqConfiguration();            
            configurator.UseMulticastSubscriptionClient();

            configurator.ReceiveFrom("msmq://localhost/web");

            configurator.EnableMessageTracing();
            configurator.Subscribe(x => x.LoadFrom(container));
        });

        container.Register(Component.For<IServiceBus>().Instance(bus));
    }
}

在控制台应用程序项目中，WindsorInstaller 看起来像

public class MassTransitInstaller : IWindsorInstaller
{
    public void Install(IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(AllTypes.FromAssemblyContaining<BasicRequestCommandHandler>().BasedOn<IConsumer>());

        var bus = ServiceBusFactory.New(configurator =>
        {
            configurator.UseMsmq();
            configurator.VerifyMsmqConfiguration();
            configurator.UseMulticastSubscriptionClient();

            configurator.ReceiveFrom("msmq://localhost/console");

            configurator.Subscribe(x => x.LoadFrom(container));
        });

        container.Register(Component.For<IServiceBus>().Instance(bus));
    }
}

我有一个ApiController使用以下 GET 操作方法

public class ExampleController : ApiController
{
    private readonly IServiceBus _bus;

    public HelloController(IServiceBus bus)
    {
        _bus = bus;
    }

    // GET api/hello?text={some text}
    public Task<IBasicResponseCommand> Get(string text)
    {
        var command = new BasicRequestCommand {Text = text};

        var tcs = new TaskCompletionSource<IBasicResponseCommand>();

        _bus.PublishRequest(command, c =>
        {
            c.Handle<IBasicResponseCommand>(r =>
            {
                tcs.SetResult(r);
            });
        });

        return tcs.Task;
    }
}

BasicRequestCommand 和 BasicResponseCommand 看起来像这样

public interface IBasicRequestCommand
{
    Guid CorrelationId { get; set; }
    string Text { get; set; }
}

public class BasicRequestCommand :
    CorrelatedBy<Guid>, IBasicRequestCommand
{
    public Guid CorrelationId { get; set; }
    public string Text { get; set; }

    public BasicRequestCommand()
    {
        CorrelationId = Guid.NewGuid();
    }
}

public interface IBasicResponseCommand
{
    Guid CorrelationId { get; set; }
    string Text { get; set; }
}

public class BasicResponseCommand :
    CorrelatedBy<Guid>, IBasicResponseCommand
{
    public Guid CorrelationId { get; set; }
    public string Text { get; set; }
}

以及响应控制台应用程序中的 BasicRequestCommand 的处理程序：

public class BasicRequestCommandHandler : Consumes<IBasicRequestCommand>.Context
{
    public void Consume(IConsumeContext<IBasicRequestCommand> context)
    {
        Console.Out.WriteLine("received message text " + context.Message.Text);

        context.Respond(new BasicResponseCommand { Text = "Hello " + context.Message.Text, CorrelationId = context.Message.CorrelationId });
    }
}

我预计所有这些都在本地运行，请求/响应最多只需几秒钟。我在配置中遗漏了什么吗？

此外，我想将 MassTransit 连接到 log4net。我正在使用 Windsor 的 log4net 日志记录工具，并且在 web.config 中有一个 log4net 部分。这一切都工作正常ILoggerWindsor 提供的实现（以及 NHibernate 日志记录），但它是文档中不清楚如何配置 MassTransit 以使用它进行日志记录 http://docs.masstransit-project.com/en/latest/overview/logging.html。有任何想法吗？

正如安德烈·沃尔科夫和克里斯·帕特森正在讨论 https://groups.google.com/forum/?fromgroups=#!searchin/masstransit-discuss/SynchronizationContext/masstransit-discuss/oC1FOe6KsAU/YUrKZKiscD8J在MassTransit google group上，这个问题似乎源于交换 https://github.com/phatboyg/MassTransit/commit/0000e38f775507b10e9fef9bbc3862532ec8cb2c使用大众运输SynchronizationContext，由于某种原因无法按预期工作。

目前，一种解决方法似乎是过渡到异步 MassTransit 请求，或者返回到不使用有问题的 v2.1.1SynchronizationContext.

（如果没有其他人首先这样做，将在这里为后代发布有关此问题的更新。）