SignalR 客户端未通过 Masstransit 接收消息

Question

我在通过 MassTransit 和 SignalR 向客户发送消息时遇到问题

启动：

        //SignalR
        services.AddSignalR().AddMassTransitBackplane();     
        #region MassTransit RabbitMq

        services.AddScoped<SendCosistListToScaleConsumer>();
        services.AddScoped<CreateConsistListConsumer>();

        services.AddMassTransit(x => 
        {
            x.AddSignalRHubConsumers<NotifyHub>();

            x.AddBus(provider => Bus.Factory.CreateUsingRabbitMq(conf =>
            {
                conf.Host(Configuration["Rabbit:Host"], host => {
                    host.Username(Configuration["Rabbit:Username"]);
                    host.Password(Configuration["Rabbit:Password"]);
                });                   

               conf.ReceiveEndpoint(Configuration["Rabbit:ReceiveEndpoint"], e => {
                    e.PrefetchCount = 16;
                    e.UseMessageRetry(n => n.Interval(3, 100));

                    #region Consumers
                    e.Consumer<SendCosistListToScaleConsumer>();
                    e.Consumer<CreateConsistListConsumer>();
                   #endregion
               });
                conf.AddSignalRHubEndpoints<NotifyHub>(provider);
            }));
        });
        services.AddMassTransitHostedService();
        #endregion

....

app.UseSignalR(endpoints =>
{
    endpoints.MapHub<NotifyHub>("/notify");
});

消费者：

public class CreateConsistListConsumer : IConsumer<ICreateConsistList>
    {
        IReadOnlyList<IHubProtocol> protocols = new IHubProtocol[] { new JsonHubProtocol() };
        public Task Consume(ConsumeContext<ICreateConsistList> context)
        {
            context.Publish<All<NotifyHub>>(
               new
               {
                   Message = protocols.ToProtocolDictionary("SendMessageToAllUsers", new object[] { "CompanyId", context.Message.CompanyId })
               });
            return Task.CompletedTask;
        }
    }

控制台应用程序（SignalR 客户端）：

   hubConnection.On<Object>("SendMessageToAllUsers", param => {
        Console.WriteLine(param);
     });

如果我正确理解 MassTransii 和 SignalR 的工作原理，那么此代码足以向客户端发送消息。 在调试的帮助下，我发现 CreateConsistListConsumer 正在工作，但客户端没有收到报告。 同时，客户端连接到集线器并正确接收来自其他来源的消息，但不是来自 MassTransit。

我做错了什么？

Answer 1

上周我也遇到了同样的问题。

看来 SignalR 正在处理集线器方面做一些特殊的工作，但无法使 Masstransit SignalR 服务正常工作。

我最终使用了here 所述的静态集线器引用。

基本上，我只是调用 Core DI 来获取我的中心上下文，然后将其存储到静态属性中（如上面列出的 Github 问题中的示例）。

当需要时，我从我的 MassTransit Consumer 中调用引用，然后我就完成了。